含笑半步颠

0 声望

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

个人动态
  • 半兽人 回复 含笑半步颠 在 kafka生产者 batch.size 中 ：

    稍后我找找这个参数，信息太多，我忘记在哪里看的了。

    7年前
  • 含笑半步颠 回复 半兽人 在 kafka生产者 batch.size 中 ：

    我特别想知道，当我调用了send发送了一万条消息以后，我不调用flush方法的话，这一万条消息会什么时候刷新到kafka的分区中去，我测试的时候是延迟大概五六秒会到队列，但是如果我send很大的量消息，比如100万，当线程执行完毕以后，main方法结束，只有几十万消息刷到了kafka分区，剩下的几十万丢失了。所以如果我知道他刷消息的时机就可以避免这个问题了

    7年前
  • 含笑半步颠 回复 半兽人 在 kafka生产者 batch.size 中 ：

    这个时间可以配置吗？还是代码中根据某种算法确定的，或者是写死的一个固定值？

    7年前
  • 订阅了 kafka 主题！ · 7年前