卡夫卡消费者偏移自动复位等参数

创建两个(或多个)线程是正确的。

使用者不是线程安全的,无论如何都应该与其他进程隔离和分离。

您可以使用更高级别的Kafka库(例如Vert.x/Spring)来简化这一过程。

如果你需要使用一个消费者,那么我认为你可以设置 auto.reset.offset 到 latest 然后移动的偏移量 topicA 手动(如果需要)。为此,在订阅和轮询循环之间,您可以:

1. 获取分配给使用者的分区(方法 assignment )
2. 检查主题的承诺偏移量 topicA 通过筛选的分区 topicA 从上一点(方法 committed ). 如果结果是 null ,然后打电话 seekToBeginning 方法