gt;>>
>>> [1]
>>> https://github.com/apache/flink/blob/980e31dcc29ec6cc60ed59569f1f1cb7c47747b7/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java#L871
>>>
>>> Best
>>> Yun Tang
>>
KafkaProducer.java#L871
>>
>> Best
>> Yun Tang
>> ------
>> *From:* Maxim Parkachov
>> *Sent:* Monday, April 6, 2020 23:16
>> *To:* user@flink.apache.org
>> *Subject:* New kafka producer on each checkpoint
>>
>> Hi e
569f1f1cb7c47747b7/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java#L871
>
> Best
> Yun Tang
> --
> *From:* Maxim Parkachov
> *Sent:* Monday, April 6, 2020 23:16
> *To:*
/flink/streaming/connectors/kafka/FlinkKafkaProducer.java#L871
Best
Yun Tang
From: Maxim Parkachov
Sent: Monday, April 6, 2020 23:16
To: user@flink.apache.org
Subject: New kafka producer on each checkpoint
Hi everyone,
I'm trying to test exactly once function
Hi everyone,
I'm trying to test exactly once functionality with my job under production
load. The job is reading from kafka, using kafka timestamp as event time,
aggregates every minute and outputs to other kafka topic. I use checkpoint
interval 10 seconds.
Everything seems to be working fine, bu
