pache.org
> *Subject:* Re: Flink KafkaProducer flushing on savepoints
>
> Hi,
>
> What Flink version and which FlinkKafkaProducer version are you using?
> `FlinkKafkaProducerBase` is no longer used in the latest version. I would
> guess some older versions, and FlinkKafkaProducer010
Sent: 03 March 2021 21:10
To: Witzany, Tomas
Cc: user@flink.apache.org
Subject: Re: Flink KafkaProducer flushing on savepoints
Hi,
What Flink version and which FlinkKafkaProducer version are you using?
`FlinkKafkaProducerBase` is no longer used in the latest version. I would guess
some older
Hi,
What Flink version and which FlinkKafkaProducer version are you using?
`FlinkKafkaProducerBase` is no longer used in the latest version. I would
guess some older versions, and FlinkKafkaProducer010 or later (no longer
supported).
I would suggest either to use the universal FlinkKafkaProducer
Hi,
I have a question about the at-least-once guarantees for Kafka producers when
checkpointing is disabled. In our data pipeline we have a Flink job on an
unlimited stream that originally, we had checkpoints turned on. Further this
job is cancelled with a savepoint once a day to do some data
