Re: How to set consumer.overrides.auto.offset.reset as latest in MM2 ?

2020-10-15 Thread Yu Watanabe
Hello. Since my environment uses kafka 2.4.0 , I got over the situation by replacing the connec-mirror-2.4.0.jar with a new file in MM2 . Below are notes for what I have done. I am not sure if this is the right approach but would like to share it. 1.Having below offset in my source kafka cluster,

How to set consumer.overrides.auto.offset.reset as latest in MM2 ?

2020-10-13 Thread Yu Watanabe
Hello. I use kafka 2.4.0 in strimzi 0.17.0 . I have set consumer.overrides.auto.offset.reset in Mirror Maker 2 but Source Connector still reads from the earliest offset . I understand that this seems to be an issue and will be fixed in 2.7.0. https://issues.apache.org/jira/browse/KAFKA-10160