Крючкова марина Сергеевна created FLINK-28099:
-------------------------------------------------
Summary: KafkaSink timeout exception
Key: FLINK-28099
URL: https://issues.apache.org/jira/browse/FLINK-28099
Project: Flink
Issue Type: Bug
Environment: Flink 1.14.3
Reporter: Крючкова марина Сергеевна
Hello!
I'm trying to replace FlinkKafkaProducer with KafkaSink, but jobs fail with
this exception:
Caused by: org.apache.kafka.common.errors.TimeoutException: Expiring 10
record(s) for enriched_flow-21:120015 ms has passed since batch creation
so I have two questions:
1) Why jobs worked fine with FlinkKafkaProducer and fail with KafkaSink with
the same configuration?
2) How to make that flink jobs won't fail with that exception? We use
DeliveryGuarantee.NONE because we don't have checkpoints yet, so its ok if
there will be some data loss
Thanks in advance!
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
