You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@beam.apache.org by "Afek, Ifat (Nokia - IL/Kfar Sava)" <if...@nokia.com> on 2022/07/24 12:25:56 UTC

Running Beam Kafka Consume with auto.offset.reset "earliest"

Hi,

I’m running a HOP pipeline that reads from Kafka using Beam Kafka Consume and writes to Kafka using Beam Kafka Produce.
How can I modify the value of “auto.offset.reset” to be “earliest”? I tried to add it as a configuration option of the Beam Kafka Consume, as well as a variable in the Flink run configuration, but neither worked.

I will appreciate your help,
Thanks,
Ifat