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

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

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    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

          This comment will be Viewable by All Users Viewable by All Users
          Cancel

          People

            Unassigned Unassigned
            Enhon Enhon Bryant
            Jun Rao Jun Rao

            Dates

              Created:
              Updated:

              Slack

                Issue deployment