我正在使用Kafka流,并希望将Java的一些使用者偏移量重置为开始。
KafkaConsumer.seekToBeginning(...)
听起来像是正确的事情,但是我使用Kafka Streams:
KafkaStreams streams = new KafkaStreams(builder, props);
...
streams.start();
Run Code Online (Sandbox Code Playgroud)
我想根据我定义的具体流管道,这将在引擎盖下创建多个消费者。我可以访问那些吗?还是有其他方法以编程方式重置偏移量?