0
我们使用Kafka流将数据写入接收器主题。我正在运行一个avro-consumer命令行来检查sink主题中是否有数据:Kafka:消费者无法读取主题中的记录
bin/kafka-avro-console-consumer --topic sink.output.topic --from-beginning - 新的消费者--bootstrap服务器
我看到数据时,我同时运行了消费者,而卡夫卡流应用程序正在运行,但如果我停止消费,并在几分钟后再次运行,我没有看到任何数据。很少的可能性:
1)这是因为kafka流从输出主题中消除记录每次它推动记录下沉?
2)或者这只是一个消费者相关的问题?
Kafka Streams不会从输出主题中删除任何数据。 –