我使用ksql为已经包含一些消息的kafka主题创建了一个来自kafka的流。但没有收到任何消息从该主题进入流创建。消息采用avro格式，并在一段时间后生成。
我想从头读，也就是从最早的味精开始读。还尝试将offset属性设置为earlish，但未接收任何消息。 create stream sample_transition with(topic_name='transition',value_format='avro');
我使用ksql为已经包含一些消息的kafka主题创建了一个来自kafka的流。但没有收到任何消息从该主题进入流创建。消息采用avro格式，并在一段时间后生成。
我想从头读，也就是从最早的味精开始读。还尝试将offset属性设置为earlish，但未接收任何消息。 create stream sample_transition with(topic_name='transition',value_format='avro');
1条答案
按热度按时间7cwmlq891#
你需要设置
auto.offset.reset正确配置。默认为“最新”。如果希望newqueryed读取某个主题中的所有数据，则需要将其设置为“最早”。比较：https://docs.confluent.io/current/ksql/docs/installation/server-config/config-reference.html#ksql-流自动偏移复位