[ 
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

Reply via email to