我想从kafka console consumer命令获取窗口开始时间戳(这里是1530008520000)。
它与ksql配合使用:
ksql> select * from DEV_MONITOR_RULE_2557_104782_233_2_TABLE;
1530008581051 | 2557 : Window{start=1530008520000 end=-} | 2557 | 2 | 1530008581051
但它不适用于Kafka控制台消费者?
./bin/kafka-console-consumer --zookeeper 10.12.0.157:2181 --topic DEV_MONITOR_RULE_2557_104782_233_2_TABLE
{"HITCOUNTS":2,"TENANTID":2557,"HITTIME":1530008581051}
如何从kafka控制台用户打印窗口开始时间(这里是1530008520000)?
谢谢!
2条答案
按热度按时间qnakjoqk1#
窗口开始时间反映在
ROWTIME
以及Kafka消息的时间戳。您可以使用用于处理kafka消息的标准api访问此时间戳。阿飞
kafka-console-consumer
不支持显示时间戳。不管怎样kafkacat
做。下面是ksql中的一些聚合数据
ROWTIME
显示窗口的开始(和TIMESTAMPTOSTRING
习惯了漂亮的印刷品):同样的主题
kafkacat
:z9gpfhce2#
你试过Kafka控制台消费者选项吗
print.timestamp=true
?