[ https://issues.apache.org/jira/browse/KAFKA-603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13494198#comment-13494198 ]
John Fung commented on KAFKA-603: --------------------------------- Thanks Joel for looking into this. The validation approach is modified to break down the messages received per partition as shown below: _test_case_name : testcase_4011 _test_class_name : ReplicaBasicTest arg : bounce_broker : true arg : broker_down_time_in_sec : 5 arg : broker_type : leader arg : log_retention_test : true arg : message_producing_free_time_sec : 15 arg : num_iteration : 1 arg : num_partition : 2 arg : replica_factor : 2 arg : sleep_seconds_between_producer_calls : 1 validation_status : Leader Election Latency - iter 1 brokerid 2 : 325.00 ms Leader Election Latency MAX : 325.00 Leader Election Latency MIN : 325.00 Unique messages from consumer on [test_1] : 4000 Unique messages from consumer on [test_1] at simple_consumer_test_1-0_r1.log : 2000 Unique messages from consumer on [test_1] at simple_consumer_test_1-0_r2.log : 2000 Unique messages from consumer on [test_1] at simple_consumer_test_1-0_r3.log : 0 Unique messages from consumer on [test_1] at simple_consumer_test_1-1_r1.log : 0 Unique messages from consumer on [test_1] at simple_consumer_test_1-1_r2.log : 2000 Unique messages from consumer on [test_1] at simple_consumer_test_1-1_r3.log : 2000 Unique messages from consumer on [test_2] : 3500 Unique messages from consumer on [test_2] at simple_consumer_test_2-0_r1.log : 1755 Unique messages from consumer on [test_2] at simple_consumer_test_2-0_r2.log : 1755 Unique messages from consumer on [test_2] at simple_consumer_test_2-0_r3.log : 0 Unique messages from consumer on [test_2] at simple_consumer_test_2-1_r1.log : 0 Unique messages from consumer on [test_2] at simple_consumer_test_2-1_r2.log : 1745 Unique messages from consumer on [test_2] at simple_consumer_test_2-1_r3.log : 1745 Unique messages from producer on [test_1] : 4000 Unique messages from producer on [test_2] : 3500 Validate for data matched on topic [test_1] : PASSED Validate for data matched on topic [test_1] across replicas : PASSED Validate for data matched on topic [test_2] : PASSED Validate for data matched on topic [test_2] across replicas : PASSED Validate leader election successful : PASSED This ticket can be closed now > System Test Data Validation Failure - Replication Factor less than No. of > Broker > --------------------------------------------------------------------------------- > > Key: KAFKA-603 > URL: https://issues.apache.org/jira/browse/KAFKA-603 > Project: Kafka > Issue Type: Bug > Reporter: John Fung > Priority: Critical > Attachments: kafka-603-reproduce-issue.patch > > -- 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