两口吃个小胖子

0 声望

这家伙太懒,什么都没留下

个人动态
  • 半兽人 回复 两口吃个小胖子kafka生产者Java客户端 中 :

    对 只有进程退出,最后一次才需要执行。

    3年前
  • 订阅了 kafka 主题! · 3年前
  • 关注了用户 半兽人 · 3年前
  • 两口吃个小胖子 回复 無名kafka生产者Java客户端 中 :

    kafka 官方建议调用producer.send后使用close()方法,看了一下代码close方法会会将缓存队列状态置为关闭,唤醒io线程将内存中的数据发往broker,如果每次send后都调close方法会不会有问题,我理解应该是服务停止时才调用close方法避免消息丢失,求大神解答

    3年前