[ https://issues.apache.org/jira/browse/KAFKA-580?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13482484#comment-13482484 ]
John Fung commented on KAFKA-580: --------------------------------- Thanks Jun for the patch. The patch is applied to the latest 0.8 branch and testcase_0122 PASSES as shown below. There are data from 2 topics. Topic "test_1" are all matching and topic "test_2" has minor data loss. Please note that we have a new policy of 1% data loss tolerance for those test cases with leader failure and acks == 1. _test_case_name : testcase_0122 _test_class_name : ReplicaBasicTest arg : bounce_broker : true arg : broker_type : leader arg : message_producing_free_time_sec : 15 arg : num_iteration : 3 arg : num_partition : 3 arg : replica_factor : 3 arg : sleep_seconds_between_producer_calls : 1 validation_status : Leader Election Latency - iter 1 brokerid 1 : 375.00 ms Leader Election Latency - iter 2 brokerid 2 : 324.00 ms Leader Election Latency - iter 3 brokerid 3 : 326.00 ms Leader Election Latency MAX : 375.00 Leader Election Latency MIN : 324.00 Unique messages from consumer on [test_1] at simple_consumer_1.log : 3900 Unique messages from consumer on [test_1] at simple_consumer_2.log : 3900 Unique messages from consumer on [test_1] at simple_consumer_3.log : 3900 Unique messages from consumer on [test_2] at simple_consumer_1.log : 3893 Unique messages from consumer on [test_2] at simple_consumer_2.log : 3893 Unique messages from consumer on [test_2] at simple_consumer_3.log : 3893 Unique messages from producer on [test_1] : 3900 Unique messages from producer on [test_2] : 3900 Validate for data matched on topic [test_1] : PASSED Validate for data matched on topic [test_2] : PASSED Validate for merged log segment checksum in cluster [source] : PASSED Validate leader election successful : PASSED > system test testcase_0122 under replication fails due to large # of data loss > ----------------------------------------------------------------------------- > > Key: KAFKA-580 > URL: https://issues.apache.org/jira/browse/KAFKA-580 > Project: Kafka > Issue Type: Bug > Components: core > Affects Versions: 0.8 > Reporter: Jun Rao > Assignee: Jun Rao > Priority: Blocker > Labels: bugs > Attachments: kafka-580.patch > > > testcase_0122 fails sometimes because a large # of messages is lost with ack > = 1. In this case, we expect only a small number of messages to be lost when > there are broker failures. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira