空的 KSQL 流

Question

我在从 Kafka 主题获取数据时遇到问题。 这个主题内容对象，我真的不知道如何在流中存储一些变量。 并且我确定该主题存在

我有：

Ticket object:{

header object{storeID,storename.....}

body object{...}

}

我想将 storeID 放入流中

create stream test (StoreID VARCHAR) with (KAFKA_TOPIC= 'output__tfrema',VALUE_FORMAT='AVRO');

我尝试了那个例子，但它给了我 0 个数据，我希望它给我至少 10000 个数据。

谢谢

Answer 1

如果没有返回结果，可能有多种原因。

• 确保您已SET 'auto.offset.reset' = 'earliest';，以便您阅读主题开头的所有消息
• 您的 KSQL 服务器日志中是否存在反序列化错误？

您可以在这里阅读更多内容：https://www.confluent.io/blog/troubleshooting-ksql-part-1