如何访问kafka主题中所有未提交消息的列表
1 回答
1
要访问未提交的消息，首先假设您正在提交。否则，您只是在消费一个主题。
从 Kafka 获取任何记录的唯一方法是使用消费者 API。
不需要提交（禁用自动提交并且不在代码中显式调用提交方法）。但是，如果应用程序因任何原因重新启动，该auto.offset.reset属性将始终应用于您正在使用的任何主题，这意味着您要么跳过所有内容，要么必须阻止您的主要代码执行，直到该消费者从主题的开头读取所有内容。Confluent Schema Registry 是一款不提交任何偏移量或创建消费者组的流行应用程序。Kafka Streams 变更日志主题也这样做。
如果你想让“另一个消费者”阅读整个主题，它需要有一个不同的组 id。而已
于 2022-01-17T12:55:29.257 回答