KSQL流未从主题中获取输出

Question

我已经将kafka连接到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).

遵循these步骤

请帮助解决从AVRO到CSV的转换以及创建的流有什么问题。

Answer 1

使用(KAFKA_TOPIC='kafka'，VALUE_FORMAT=‘AVRO’)创建流source_avro；

是否确定要将MySQL数据摄取到的主题名为kafka

我首先用PRINT (https://docs.confluent.io/current/ksql/docs/developer-guide/syntax-reference.html#print)检查主题的数据：

PRINT 'nameOfYourActualInputTopic' FROM BEGINNING;