Я создал поток из Kafka, используя KSQL для темы Kafka, которая уже содержит некоторые сообщения.Но не получил ни одного сообщения из этой темы в созданный поток.Сообщения в формате Avro и генерируются через некоторое время.
Я хочу читать с начала, т.е. с самого раннего сообщения.Также попытался установить свойство смещения как можно раньше, но не получил ни одного сообщения.
create stream sample_transition with(topic_name='transition',value_format='avro');