lixen9 最近的时间轴更新 lixen9 最近的时间轴更新 |
lixen9V2EX 第 452490 号会员，加入于 2019-11-12 16:39:01 +08:00今日活跃度排名 4308 |
| 慢收一个网易云音乐的 88vip 会员 二手交易 • lixen9 • 130 天前 |
| 今年公司体检无了，收两个招行体检 二手交易 • lixen9 • 210 天前 |
lixen9 最近回复了
3 天前 回复了 liangc230323 创建的主题 › 开源软件 › 为什么国内的开源软件，都在打着开源的口号在赚钱 |
因为用爱发不了电
3 天前 回复了 lerefe 创建的主题 › 问与答 › 你们公司什么场景用的什么图数据库 |
做知识图谱，使用过 janusgraph ，大问题不多，小 bug 还是不少，索引这块有点坑，不过这个是由于我们使用的是 es 做索引导致的
6 天前 回复了 bapaws 创建的主题 › 分享创造 › 今天过生日， 33 了。没啥成就，有几个自己开发的 App，每个送 1000 个年会员吧 |
生日快乐～～
40 天前 回复了 Pig930 创建的主题 › Apple › 2024 年 4 月， macOS 上最好用的浏览器是什么？ |
最近在使用 ARC
52 天前 回复了 EchoWhale 创建的主题 › 问与答 › 看了医生做完检查，再看报告是不是就只能插队了 |
我都是医生门口排队
53 天前 回复了 nutting 创建的主题 › 随想 › 想消费，没啥可买的了？ |
买个自行车吧
53 天前 回复了 sankooc 创建的主题 › 问与答 › 如何确认 kafka consumer 的可用性 |
简单看了下代码，KafkaConsumer 对象在 close 方法中会调用 ConsumerCoordinator 的 close 方法，然后 ConsumerCoordinator 在调用 close 方法的时候会在 finally 块中调用 super.close()方法，在 super 的 close 方法中会将心跳线程关闭。
53 天前 回复了 sankooc 创建的主题 › 问与答 › 如何确认 kafka consumer 的可用性 |
@sankooc 是这个名称的
53 天前 回复了 sankooc 创建的主题 › 问与答 › 如何确认 kafka consumer 的可用性 |
我理解只要线程存在应该就可以 consumer 停止之后，这个线程应该会消失，你可以测试看看，好久没看过那块代码了
54 天前 回复了 sankooc 创建的主题 › 问与答 › 如何确认 kafka consumer 的可用性 |
那也可以试试监测 consumer 的心跳线程，心跳线程会在消费者启动的时候开启，在消费者关闭的时候结束，只需要监测这个线程是否存活应该就行
Select Language