Sorry.. sent it to the wrong group š Ifat From: "Afek, Ifat (Nokia - IL/Kfar Sava)" <[email protected]> Reply-To: "[email protected]" <[email protected]> Date: Sunday, 24 July 2022 at 15:26 To: "[email protected]" <[email protected]> Subject: Suspected SPAM - 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
