我想重置与给定消费者对应的先前偏移量。原因：我编写应用程序的springboot消费代码使用“earliest”作为自动偏移重置的值。由于偏移量已存储在\uu消费者\u偏移量中，因此将自动偏移量重置的值更改为最新值将不起作用。注意：我使用的Kafka版本高于0.9。不确定删除消费者是否有帮助，因为我知道偏移量现在存储在主题\uu消费者\u偏移量中。
vwkv1x7d1#
如果侦听器实现了 ConsumerSeekAware . 请参阅文档。
ConsumerSeekAware
void registerSeekCallback(ConsumerSeekCallback callback); void onPartitionsAssigned(Map<TopicPartition, Long> assignments, ConsumerSeekCallback callback); void onIdleContainer(Map<TopicPartition, Long> assignments, ConsumerSeekCallback callback);
回调函数提供：
void seek(String topic, int partition, long offset);
1条答案
按热度按时间vwkv1x7d1#
如果侦听器实现了
ConsumerSeekAware. 请参阅文档。回调函数提供：