Hi, I used the 3.0.1-1.18 connector flink 1.18.0 but it seems the *OffsetResetStrategy* no longer exists. Is there any way we can achieve the same startingoffset reset strategy in flink?
E.g. (Kafka connector 1.17.1) kafka.setStartingOffsets(OffsetsInitializer.committedOffsets( *OffsetResetStrategy.LATEST*)) We upgraded our kafka brokers to version 3.4.1 Regards, Patricia On Thu, Nov 9, 2023, 6:38 PM Junrui Lee <jrlee....@gmail.com> wrote: > Hi, > > The externalized Flink Kafka connector v3.0.1 uses Kafka 3.2.3, see > > https://github.com/apache/flink-connector-kafka/blob/ea4fac3966c84f4cae8b80d70873254f03b1c333/pom.xml#L53 > > And you can download it from here: > https://flink.apache.org/downloads/#apache-flink-kafka-connector-301 > > Best, > Junrui > > patricia lee <plee3...@gmail.com> 于2023年11月9日周四 16:00写道： > >> Hi, >> >> I am upgrading my project to Flink 1.18 but seems kafka connector 1.18.0 >> not available yet? >> >> I couldn't pull the jar file flink-kafka-connector. But when I check on >> mvn repo the versions available were: >> >> 3.0.1-1.18 >> 3.0.1-1.17 >> >> But on the documentation it says -1.18 >> >> Questions: >> 1. Is 3.0.1-1.18 can only be used for kafka version 3? >> 2. Where can we find the flink-kafka-connector 1.18.0? >> >> >> Thanks! >> >
