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
