我正在通过汇合平台快速启动（docker）。我可以创建一个主题，发布消息 kafka-node ，订阅 kafka-console-subscribe.sh 还有 CREATE STREAM 在ksql编辑器中。我还设置了 auto.offset.reset 至 Earliest 在我的查询编辑器中。
首先，我在控制中心的窗口中没有看到任何输出。第二，即使我不再在主题中插入任何消息，消息的数量仍会不断增加，这是我最初插入的数量！
少了什么？
我正在通过汇合平台快速启动（docker）。我可以创建一个主题，发布消息 kafka-node ，订阅 kafka-console-subscribe.sh 还有 CREATE STREAM 在ksql编辑器中。我还设置了 auto.offset.reset 至 Earliest 在我的查询编辑器中。
首先，我在控制中心的窗口中没有看到任何输出。第二，即使我不再在主题中插入任何消息，消息的数量仍会不断增加，这是我最初插入的数量！
少了什么？
1条答案
按热度按时间wmomyfyw1#
消息计数将增加，因为
DataGen快速入门使用的连接器不断产生对Kafka主题的测试数据。如果你已经准备好了
auto.offset.reset至Earliest而不是earliest，那么这就可以解释为什么没有看到任何输出