[ https://issues.apache.org/jira/browse/KAFKA-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Dong Lin resolved KAFKA-3089. ----------------------------- Resolution: Fixed > VerifiableProducer should do a clean shutdown in stop_node() > ------------------------------------------------------------ > > Key: KAFKA-3089 > URL: https://issues.apache.org/jira/browse/KAFKA-3089 > Project: Kafka > Issue Type: Improvement > Reporter: Dong Lin > Assignee: Dong Lin > Priority: Major > > 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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)