在 KStream 中从头开始阅读 Kafka 主题
Read Kafka topic from beginning in KStream
我的 spring 引导项目有一个演示 Kafka Streams 的应用程序 API。我可以使用命令
使用主题 customer 中的所有消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic customer --from-beginning
Kafka Streams API 中使用 KStream 或 KTable 消费消息的类似命令是什么？我试过了
properties.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,"earliest");
properties.put("auto.offset.reset", "earliest");
两者均无效。我确实创建了一个测试用例来使用 KafkaConsumer 而不是 Streams，它没有用。代码上传到Github以供参考。任何帮助都会很棒。
工具 bin/kafka-streams-application-reset.sh 允许从 v1.1 开始搜索。
我的 spring 引导项目有一个演示 Kafka Streams 的应用程序 API。我可以使用命令
使用主题customer 中的所有消息
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic customer --from-beginning
Kafka Streams API 中使用 KStream 或 KTable 消费消息的类似命令是什么？我试过了
properties.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG,"earliest");
properties.put("auto.offset.reset", "earliest");
两者均无效。我确实创建了一个测试用例来使用 KafkaConsumer 而不是 Streams，它没有用。代码上传到Github以供参考。任何帮助都会很棒。
工具 bin/kafka-streams-application-reset.sh 允许从 v1.1 开始搜索。