[
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