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

KafkaProducer should not invoke callback in send()

    Details

    • Type: Bug
    • Status: Patch Available
    • Priority: Critical
    • Resolution: Unresolved
    • Affects Version/s: 0.9.0.0
    • Fix Version/s: 2.0.0
    • Component/s: clients, producer
    • Labels:
      None

      Description

      Currently KafkaProducer will invoke callback.onComplete() if it receives an ApiException during send(). This breaks the guarantee that callback will be invoked in order. It seems ApiException in send() only comes from metadata refresh. If so, we can probably simply throw it instead of invoking callback().

        Attachments

          Activity

            People

            • Assignee:
              becket_qin Jiangjie Qin
              Reporter:
              becket_qin Jiangjie Qin
              Reviewer:
              Guozhang Wang
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated: