[ https://issues.apache.org/jira/browse/KAFKA-3320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15213677#comment-15213677 ]
Anna Povzner commented on KAFKA-3320: ------------------------------------- If you look at verifiable_producer.py, it collects all successfully produced messages into acked_values. If producer send() was unsuccessful, those messages are collected into not_acked_values. However, our tests do not check whether any produce send() got an error. Suppose the test tried to produce 100 messages, and only 50 were successfully produced. If the consumer successfully consumed 50 messages, then the test is considered a success. It would be good to verify that we also did not get any produce errors for some tests. > Add successful acks verification to ProduceConsumeValidateTest > -------------------------------------------------------------- > > Key: KAFKA-3320 > URL: https://issues.apache.org/jira/browse/KAFKA-3320 > Project: Kafka > Issue Type: Test > Reporter: Anna Povzner > > Currently ProduceConsumeValidateTest only validates that each acked message > was consumed. Some tests may want an additional verification that all acks > were successful. > This JIRA is to add an addition optional verification that all acks were > successful and use it in couple of tests that need that verification. Example > is compression test. -- This message was sent by Atlassian JIRA (v6.3.4#6332)