在Apache Kafka 0.10.0.0中看不到时间戳.RC4

嗨,我已经下载了Apache Kafka 0.10.0.0.来自这里的 RC4 ,它现在能够将时间戳附加到此处所述的消息.

然后我像往常一样在我的服务器上运行它并且它正在接收日志.

但是,当我运行Kafka使用者控制台查看主题时,日志看起来没有什么不同,没有时间戳？他们被送到Jaf的Kafka这会影响事情吗？你能在消费者控制台看到它们吗？如果不在哪里？

我想看看通过我的管道的第一阶段需要多长时间.

默认情况下,运行控制台使用者时不显示时间戳.您必须通过属性设置启用它:

# `print.timestamp=true` requires Kafka 0.10.0+
$ kafka-console-consumer.sh --property print.timestamp=true [...]

顺便说一句,你也可以考虑添加,--property print.key=true以便控制台消费者也打印Kafka消息的密钥.

此外,写入Kafka的应用程序必须支持新的Kafka 0.10消息格式,其中包括新的嵌入式时间戳.也许您无法看到时间戳,因为上游应用程序/生产者从未包含任何时间戳.