【发布时间】:2017-10-07 06:17:23
【问题描述】:
我们正在使用 Kafka 流将数据写入接收器主题。我正在运行 avro-consumer 命令行来检查接收器主题中是否有数据:
bin/kafka-avro-console-consumer --topic sink.output.topic --from-beginning --new-consumer --bootstrap-server
当我在 kafka 流应用程序运行时同时运行消费者时,我会看到数据,但如果我停止消费者并在几分钟后再次运行,我看不到任何数据。几种可能:
1) 这是因为 kafka 流每次将记录推送到接收器时都会从输出主题中清除记录吗?
2) 或者这只是与消费者相关的问题?
【问题讨论】:
-
Kafka Streams 不会从输出主题中删除任何数据。
标签: apache-kafka apache-kafka-streams