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

VerifiableProducer should do a clean shutdown in stop_node()

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: None
    • Component/s: None
    • Labels:
      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

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

                Dates

                • Created:
                  Updated:
                  Resolved: