Я прохожу через Быстрый запуск платформы Confluent (Docker) . Я могу создать сообщение topi c, publi sh с kafka-node, подписаться на kafka-console-subscribe.sh, а также CREATE STREAM в редакторе K SQL. Я также установил auto.offset.reset в Earliest в моем редакторе запросов.
Во-первых, я не вижу любые выходные данные в окне центра управления. Во-вторых, даже если я не вставляю больше сообщений в топи c, количество сообщений продолжает увеличиваться на количество, которое я изначально вставил!
Чего не хватает?