KafkaProducer -org.apache.kafka.clients.producer.internals.Sender - NETWORK_EXCEPTION. Error Message: Disconnected from node 0

[Sivananthanhere]

Our Application is Flink application , There is a kafka connector is using internally by flink . We are using below dependency

    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-connector-kafka</artifactId>
        <version>1.15.0</version>
    </dependency>

Which contains Kafka-client 3.0.0. So Flink sink will send msg to topic by kafka producer internally , this case we are getting the below error. Because of that we are getting the delay (30-60 secs) in processing . This will causes the performance issue. This error is intermittent not every time.

Please help me out if you have any solution for this.

2022-10-19 07:33:14.240 [kafka-producer-network-thread | producer-1] WARN org.apache.kafka.clients.producer.internals.Sender - [Producer clientId=producer-1] Got error produce response with correlation id 38 on topic-partition ccs-fsm-ingress-0, retrying (2147483646 attempts left). Error: NETWORK_EXCEPTION. Error Message: Disconnected from node 0

[nwroblewski]

Similar things happens with consumers in spring based apps