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

VerifiableProducer should do a clean shutdown in stop_node()

    XMLWordPrintableJSON

Details

    • Improvement
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • None
    • None
    • None

    Description

      VerifiableProducer is closed by SIGKILL when stop_node() is called. For this reason, when stop_producer_and_consumer() is invoked in ProduceConsumeValidateTest, VerifiableProducer is killed immediately without allowing it to wait for acknowledgement. The reported number of messages produced by VerifiableProducer will thus be much smaller than the reported number of messages consumed by consumer, causing confusion to developers.

      For almost all other services, such as VerifiableConsumer and ConsoleConsumer, we send SIGINT when stop_node() is called. It is not clear why VerifiableProducer is different from them.

      Attachments

        Issue Links

          Activity

            People

              lindong Dong Lin
              lindong Dong Lin
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: