You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Dong Lin (JIRA)" <ji...@apache.org> on 2018/07/12 22:26:00 UTC

[jira] [Resolved] (KAFKA-3089) VerifiableProducer should do a clean shutdown in stop_node()

     [ 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)