从 KStream 开始阅读 Kafka 主题

Question

我的 spring boot 项目有一个演示 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以供参考。任何帮助都会很棒。

Answer 1

该工具bin/kafka-streams-application-reset.sh允许从 v1.1 开始搜索。

参见 https://cwiki.apache.org/confluence/display/KAFKA/KIP-171+-+Extend+Consumer+Group+Reset+Offset+for+Stream+Application