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

Socket server may throw IllegalStateException

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Not A Problem
    • Affects Version/s: 0.9.0.0
    • Fix Version/s: None
    • Component/s: network
    • Labels:
      None

      Description

      The Processor in SocketServer will try to drain all the responses in the response queue and pass them to selector for sending.

      If there are more than one response in the response queue (e.g. a producer with max in flight request greater than 1), an IllegalStateException would be thrown because the processor will call selector.send() before the previous send is finished.

        Attachments

          Activity

            People

            • Assignee:
              becket_qin Jiangjie Qin
              Reporter:
              becket_qin Jiangjie Qin
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: