Поток KSQL не получает вывод из темы

Question

Я подключил Кафку к MySQL.Тема содержит данные в формате AVRO.Теперь я хочу преобразовать эти данные в формат CSV.Для этого я использую поток KSQL.Когда я создаю поток наподобие

CREATE STREAM source_avro WITH (KAFKA_TOPIC='kafka', VALUE_FORMAT='AVRO');

(если я запускаю потребительскую команду с той же темой, она показывает данные), а затем дает select * from source_avro, она не показывает никаких данных.

SET 'auto.offset.reset'='earliest'; (Already done).

После этих шагов

Пожалуйста, помогите с решением по преобразованию AVRO в CSV и что не так с созданным потоком.

Answer 1

СОЗДАТЬ ПОТОК source_avro WITH (KAFKA_TOPIC = 'kafka', VALUE_FORMAT = 'AVRO');

Вы уверены, что тема, в которую вводятся данные MySQL, называется kafka?

Я бы сначала проверил данные темы с помощью PRINT (https://docs.confluent.io/current/ksql/docs/developer-guide/syntax-reference.html#print):

PRINT 'nameOfYourActualInputTopic' FROM BEGINNING;