flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vladimir Stoyak <vsto...@yahoo.com>
Subject Read Kafka topic from the beginning
Date Thu, 03 Dec 2015 15:01:21 GMT
I see that Flink 0.10.1 now supports Keyed Schemas which allows us to rely on Kafka topics
set to "compact" retention for data persistence.

In our topology we wanted to set some topics with Log Compactions enabled and read topic from
the beginning when the topology starts or component recovers. Does current Kafka Consumer
implementation allow to read all messages in a topic from the beginning or from a specific
offset.

Thanks,
Vladimir

Mime
View raw message