相关疑难解决方法(0)

将消费者补偿从Kafka Streams重新设置为开始

我正在使用Kafka流,并希望将Java的一些使用者偏移量重置为开始。 KafkaConsumer.seekToBeginning(...)听起来像是正确的事情,但是我使用Kafka Streams:

KafkaStreams streams = new KafkaStreams(builder, props);
...
streams.start();
Run Code Online (Sandbox Code Playgroud)

我想根据我定义的具体流管道,这将在引擎盖下创建多个消费者。我可以访问那些吗?还是有其他方法以编程方式重置偏移量?

java stream offset consumer apache-kafka

1
推荐指数
1
解决办法
1185
查看次数

标签 统计

apache-kafka ×1

consumer ×1

java ×1

offset ×1

stream ×1