lixen9 最近的时间轴更新 lixen9 最近的时间轴更新 |
lixen9V2EX 第 452490 号会员，加入于 2019-11-12 16:39:01 +08:00 |
| 慢收一个网易云音乐的 88vip 会员 二手交易 • lixen9 • 106 天前 |
| 今年公司体检无了，收两个招行体检 二手交易 • lixen9 • 186 天前 |
lixen9 最近回复了
16 天前 回复了 Pig930 创建的主题 › Apple › 2024 年 4 月， macOS 上最好用的浏览器是什么？ |
最近在使用 ARC
28 天前 回复了 EchoWhale 创建的主题 › 问与答 › 看了医生做完检查，再看报告是不是就只能插队了 |
我都是医生门口排队
29 天前 回复了 nutting 创建的主题 › 随想 › 想消费，没啥可买的了？ |
买个自行车吧
29 天前 回复了 sankooc 创建的主题 › 问与答 › 如何确认 kafka consumer 的可用性 |
简单看了下代码，KafkaConsumer 对象在 close 方法中会调用 ConsumerCoordinator 的 close 方法，然后 ConsumerCoordinator 在调用 close 方法的时候会在 finally 块中调用 super.close()方法，在 super 的 close 方法中会将心跳线程关闭。
29 天前 回复了 sankooc 创建的主题 › 问与答 › 如何确认 kafka consumer 的可用性 |
@sankooc 是这个名称的
29 天前 回复了 sankooc 创建的主题 › 问与答 › 如何确认 kafka consumer 的可用性 |
我理解只要线程存在应该就可以 consumer 停止之后，这个线程应该会消失，你可以测试看看，好久没看过那块代码了
30 天前 回复了 sankooc 创建的主题 › 问与答 › 如何确认 kafka consumer 的可用性 |
那也可以试试监测 consumer 的心跳线程，心跳线程会在消费者启动的时候开启，在消费者关闭的时候结束，只需要监测这个线程是否存活应该就行
31 天前 回复了 sankooc 创建的主题 › 问与答 › 如何确认 kafka consumer 的可用性 |
如果是基于 consumer group 去消费的话，那可以通过查看消费者对应的 consumer group 状态去做一个检测；如果是通过 assign 的方式消费的话，这个目前好像只能自行通过代码维护了
32 天前 回复了 BitPorter 创建的主题 › 深圳 › 想裸辞去深圳找工作，请老哥进来骂两句，不嫌麻烦的话再指导两句 |
今年这行情，建议骑驴找马
38 天前 回复了 echo0x000001 创建的主题 › 问与答 › 虚拟币入金被限制咋办 |
应该是对方限制了，早上在 okx 也遇到了，多换几个商家就好了
Select Language