[jira] [Created] (FLINK-22798) Exception handling of transactional producer

[Shang Yuanchun (Jira)]

Jin Xu created FLINK-22798:
------------------------------

             Summary: Exception handling of transactional producer
                 Key: FLINK-22798
                 URL: https://issues.apache.org/jira/browse/FLINK-22798
             Project: Flink
          Issue Type: Bug
          Components: Connectors / Kafka
            Reporter: Jin Xu


[https://github.com/apache/flink/blob/8e90425462f287b94e867ba778d75abb193763bd/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java#L1013]

 

[https://github.com/apache/flink/blob/8e90425462f287b94e867ba778d75abb193763bd/flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer.java#L1047]

 

current implementation of commit and abort do not handle critical exception and try to recycle/reuse the producer.

 

Kafka doc [https://kafka.apache.org/11/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html]

recommends catch critical exceptions and should not recycle the producer.
{code:java}
catch (ProducerFencedException | OutOfOrderSequenceException | AuthorizationException e)
{code}
 

 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)