Re: Incompatible KafkaProducer version

2023-09-11 Thread Krzysztof Jankiewicz
ot released yet. Maybe you can package and check it by > yourself. > > Best, > Hang > > [1] https://github.com/apache/flink-connector-kafka/pull/11 > > Krzysztof Jankiewicz 于2023年9月10日周日 > 21:52写道: > >> Hi, >> >> I am currently working on a simple applicat

Incompatible KafkaProducer version

2023-09-10 Thread Krzysztof Jankiewicz
Hi, I am currently working on a simple application that requires exactly-once end-to-end guarantee. I am reading data from Kafka and writing it back to Kafka. When I use `DeliveryGuarantee.AT_LEAST_ONCE` at the Kafka Sink level, everything works fine. Here's the relevant code: KafkaSink sink =