apache-kafka - KSQL 如何从已经包含一些消息的主题中读取（使用 msgs）数据

我已经使用 KSQL 从 Kafka 创建了一个流，用于已经包含一些消息的 Kafka 主题。但没有从该主题接收任何消息到创建的流中。消息采用 Avro 格式，并在一段时间后生成。

我想从最早的味精开始阅读。还尝试将偏移属性设置为最早但未收到任何消息。

create stream sample_transition with(topic_name='transition',value_format='avro');

标签： apache-kafkaconfluent-platformksqldb

您需要auto.offset.reset正确设置配置。默认情况下它是“最新的”。如果您希望新查询从主题中读取所有数据，则需要将其设置为“最早”。

ksql> SET 'auto.offset.reset'='earliest';