Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9296

Correlation id for response () does not match request ()

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Blocker
    • Resolution: Unresolved
    • 0.11.0.2
    • None
    • clients, producer
    • Flink on k8s

    Description

      The Kafka client and broker I use are both version 0.11.0.2.   I use Kafka's producer to write data to broker. I encountered the following exceptions.

      2019-12-12 18:12:46,821 ERROR org.apache.kafka.clients.producer.internals.Sender - Uncaught error in kafka producer I/O thread:
      java.lang.IllegalStateException: Correlation id for response (11715816) does not match request (11715804), request header: {api_key=0,api_version=3,correlation_id=11715804,client_id=producer-3}
      at org.apache.kafka.clients.NetworkClient.correlate(NetworkClient.java:752)
      at org.apache.kafka.clients.NetworkClient.parseStructMaybeUpdateThrottleTimeMetrics(NetworkClient.java:561)
      at org.apache.kafka.clients.NetworkClient.handleCompletedReceives(NetworkClient.java:657)
      at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:442)
      at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:224)
      at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:162)
      at java.lang.Thread.run(Thread.java:748)

      Attachments

        Issue Links

          Activity

            People

              Unassigned Unassigned
              Enhon Enhon Bryant
              Jun Rao Jun Rao
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

                Created:
                Updated: