2017-10-07 331 views
0

我们使用Kafka流将数据写入接收器主题。我正在运行一个avro-consumer命令行来检查sink主题中是否有数据:Kafka:消费者无法读取主题中的记录

bin/kafka-avro-console-consumer --topic sink.output.topic --from-beginning - 新的消费者--bootstrap服务器

我看到数据时,我同时运行了消费者,而卡夫卡流应用程序正在运行,但如果我停止消费,并在几分钟后再次运行,我没有看到任何数据。很少的可能性:

1)这是因为kafka流从输出主题中消除记录每次它推动记录下沉?

2)或者这只是一个消费者相关的问题?

+0

Kafka Streams不会从输出主题中删除任何数据。 –

回答

0

我认为这是因为--from-beginning仅在消费者尚未建立偏移量时才使用。您是否尝试过使用--offset earliest