我正在经历 Confluent平台快速入门(Docker). 我可以创建一个主题,发布消息与 kafka-node
,订阅 kafka-console-subscribe.sh
并 CREATE STREAM
在KSQL编辑器中。我还设置了 auto.offset.reset
到 Earliest
在我的查询编辑器中。
首先,我做 不 在控制中心的窗口中看到任何输出。其次,虽然我没有再插入任何消息到主题中,但消息的数量却一直在增加,而且增加的数量是我原来插入的!这到底是怎么回事?
到底少了什么?
消息数量会增加,因为 DataGen
快速启动所使用的连接器不断产生测试数据到Kafka主题。
如果您已经设置了 auto.offset.reset
到 Earliest
而不是 earliest
那么这可能解释了为什么你没有看到任何输出。