You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Крючкова марина Сергеевна (Jira)" <ji...@apache.org> on 2022/06/16 14:37:00 UTC

[jira] [Created] (FLINK-28099) KafkaSink timeout exception

Крючкова марина Сергеевна 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)