相关疑难解决方法(0)

适用于Kafka 0.10.0.0及更高版本的session.timeout.ms和max.poll.interval.ms之间的差异

我不清楚为什么我们需要session.timeout.ms和max.poll.interval.ms以及何时使用一个或另一个或两者?似乎两者都表明时间协调器的上限将等待消费者获得心跳,然后再将其假死.

另外,对于基于KIP-62的 0.10.1.0+版本,它的表现如何?

apache-kafka kafka-consumer-api

36
推荐指数
1
解决办法
3万
查看次数

卡夫卡消费者.commitSync vs commitAsync

引自https://www.safaribooksonline.com/library/view/kafka-the-definitive/9781491936153/ch04.html#callout_kafka_consumers__reading_data_from_kafka_CO2-1

缺点是,commitSync()将重试提交,直到它成功或遇到不可恢复的失败,commitAsync()将不会重试.

这句话对我来说并不清楚.我认为消费者向代理发送提交请求,如果代理在某些超时内没有响应,则意味着提交失败.我错了吗 ?

你能澄清的差异commitSync ,并commitAsync在细节?
另外,请提供我更喜欢哪种提交类型的用例.

java offset apache-kafka kafka-consumer-api

6
推荐指数
2
解决办法
1万
查看次数

标签 统计

apache-kafka ×2

kafka-consumer-api ×2

java ×1

offset ×1