Dong Lin created KAFKA-3089:
-------------------------------
Summary: 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
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
(v6.3.4#6332)
