关于Kafka消费者中的偏移量的提交(Commits and Offsets)

关于Kafka消费者中的偏移量的提交 概述 KafkaConsumer API中多种提交偏移的方法 自动提交(Automatic Commit) 提交当前偏移量 异步提交(Asynchronous Commit) 结合同步和异步提交 提交指定的偏移量 参考资料 概述 每当咱们调用poll()时，它都会返回以前被写入Kafka的记录，即咱们组中的消费者尚未读过的记录。 这意味着咱们有一种方法能够跟踪

>>阅读原文<<