两口吃个小胖子

0 声望

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

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

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

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

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

    3年前