You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "John Fung (JIRA)" <ji...@apache.org> on 2012/05/15 22:43:11 UTC
[jira] [Created] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
John Fung created KAFKA-341:
-------------------------------
Summary: Create a new single host system test to validate all replicas on 0.8 branch
Key: KAFKA-341
URL: https://issues.apache.org/jira/browse/KAFKA-341
Project: Kafka
Issue Type: Task
Reporter: John Fung
Assignee: John Fung
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
Posted by "Jun Rao (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13290215#comment-13290215 ]
Jun Rao commented on KAFKA-341:
-------------------------------
Thanks for the patch. Some comments:
1. Can we reuse kafka-run-class.sh in root/bin instead of making a copy in system_test/single_host_multi_brokers/bin?
2. This test can just focus of the replication of a single cluster. We probably don't need to bundle the mirroring test here. So, no need to set up a target cluster.
3. Can we print out either PASS or FAIL at the end of the test based on the validation that the test does?
4. Could you write a README for the test so that people know how to run it and how to interpret the output?
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
Posted by "John Fung (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
John Fung updated KAFKA-341:
----------------------------
Attachment: kafka-341-v4.patch
Uploaded kafka-341-v4.patch to fix the followings:
1. reduced sleep time
2. fixed the way to count checksum in producer log
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch, kafka-341-v2.patch, kafka-341-v3.patch, kafka-341-v4.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
Posted by "Joel Koshy (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13290284#comment-13290284 ]
Joel Koshy commented on KAFKA-341:
----------------------------------
I remembered I also had some review comments lying around.
John - I think it's great that we now have this system test to help
with 0.8 development. Brief comments - may have overlap with
Jun's:
- kafka-run-class should be removed.
- Add readme.
- run-test.sh:
- typo on line 56 in var name, but doesn't hurt
- typo on line 65 in var name, but doesn't hurt
- line 94-97: cut is brittle for this purpose. Better to use sed/awk.
- There are a lot of util functions such as info, kill_child_processes
that we use in all our scripts. It would be good to factor these out
into a common script and source it from the system tests.
- No need any references to any target cluster. E.g., zk_target,
kafka_target, etc. Likewise, should rename *_source_cluster to simply
*_cluster.
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
Posted by "John Fung (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
John Fung updated KAFKA-341:
----------------------------
Attachment: kafka-341-v1.patch
This patch has been tested based on the following pre-requisites:
1. Kafka 0.8 branch rev. 1342841
2. KAFKA-46 patch applied
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Comment Edited] (KAFKA-341) Create a new single host system
test to validate all replicas on 0.8 branch
Posted by "John Fung (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13285209#comment-13285209 ]
John Fung edited comment on KAFKA-341 at 5/29/12 10:41 PM:
-----------------------------------------------------------
This patch has been tested based on the following pre-requisites:
1. Kafka 0.8 branch rev. 1342841
2. KAFKA-46 patch applied
Please note the followings for this patch:
1. It creates a new folder "system_test/single_host_multi_brokers"
2. It starts up 3 brokers and have replicas enabled by default
3. At the end of the test, it will compare the logs and validate the data file checksum
4. Currently, the broker failure testing part is commented out. Please uncomment that after KAFKA-350 is fixed.
was (Author: jfung):
This patch has been tested based on the following pre-requisites:
1. Kafka 0.8 branch rev. 1342841
2. KAFKA-46 patch applied
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Comment Edited] (KAFKA-341) Create a new single host system
test to validate all replicas on 0.8 branch
Posted by "John Fung (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13293139#comment-13293139 ]
John Fung edited comment on KAFKA-341 at 6/11/12 10:29 PM:
-----------------------------------------------------------
Hi Jun, Joel,
Thanks for reviewing this patch. A v2 patch is attached to this JIRA. The following changes are made according to your suggestions.
** Changes not made from Review Suggestions
1. An extra copy of kafka-run-class.sh is added to the bin directory of this specific test folder because a customized copy of log4j.properties is required to enable some debugging code in ConsoleConsumer and ProducerPerformance for checksum validation
** Changes made from Review Suggestions
1. Move common functions to a separate script at system_test\common\util.sh
2. Fixed typos (line 56 & 65 in previous version)
3. Rename *_source_cluster to *_cluster
4. README added
5. PASS or FAIL validation is added at the end of the test
6. Target cluster related code removed
7. All the "cut" are replaced with "awk"
** Other changes made
1. The script will check the no. of brokers required and generate the corresponding no. of server.properties files
was (Author: jfung):
Changes not made from Review Suggestion
1. An extra copy of kafka-run-class.sh is added to the bin directory of this specific test folder because a customized copy of log4j.properties is required to enable some debugging code in ConsoleConsumer and ProducerPerformance for checksum validation
Changes made from Review Suggestion
1. Move common functions to a separate script at system_test\common\util.sh
2. Fixed typos (line 56 & 65 in previous version)
3. Rename *_source_cluster to *_cluster
4. README added
5. PASS or FAIL validation is added at the end of the test
6. Target cluster related code removed
7. All the "cut" are replaced with "awk"
Other changes made
1. The script will check the no. of brokers required and generate the corresponding no. of server.properties files
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch, kafka-341-v2.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
Posted by "John Fung (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
John Fung updated KAFKA-341:
----------------------------
Attachment: kafka-341-v3.patch
Uploaded kafka-341-v3.patch in which more comments are added to common/util.sh
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch, kafka-341-v2.patch, kafka-341-v3.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
Posted by "Jun Rao (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jun Rao updated KAFKA-341:
--------------------------
Resolution: Fixed
Fix Version/s: 0.8
Status: Resolved (was: Patch Available)
John, thanks for the patch. Just committed to 0.8.
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Fix For: 0.8
>
> Attachments: kafka-341-v1.patch, kafka-341-v2.patch, kafka-341-v3.patch, kafka-341-v4.patch, kafka-341-v5.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
Posted by "John Fung (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13293871#comment-13293871 ]
John Fung commented on KAFKA-341:
---------------------------------
Hi Jun,
I just uploaded a patch "kafka-341-v4.patch" which reduces sleep time. I also tried this patch with the latest 0.8 branch and I couldn't reproduce the exception you saw in ZK. Could you please try again with this latest patch?
Thanks,
John
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch, kafka-341-v2.patch, kafka-341-v3.patch, kafka-341-v4.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
Posted by "Jun Rao (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13293745#comment-13293745 ]
Jun Rao commented on KAFKA-341:
-------------------------------
Thanks for patch v2. I kept getting the following exception. Do you know why?
2012-06-12 09:24:23 creating topic [mytest] on [localhost:2181]
creation failed because of org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids
org.I0Itec.zkclient.exception.ZkNoNodeException: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids
at org.I0Itec.zkclient.exception.ZkException.create(ZkException.java:47)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:685)
at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:413)
at org.I0Itec.zkclient.ZkClient.getChildren(ZkClient.java:409)
at kafka.utils.ZkUtils$.getChildren(ZkUtils.scala:354)
at kafka.utils.ZkUtils$.getSortedBrokerList(ZkUtils.scala:69)
at kafka.admin.CreateTopicCommand$.createTopic(CreateTopicCommand.scala:87)
at kafka.admin.CreateTopicCommand$.main(CreateTopicCommand.scala:72)
at kafka.admin.CreateTopicCommand.main(CreateTopicCommand.scala)
Caused by: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /brokers/ids
at org.apache.zookeeper.KeeperException.create(KeeperException.java:102)
at org.apache.zookeeper.KeeperException.create(KeeperException.java:42)
at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1249)
at org.apache.zookeeper.ZooKeeper.getChildren(ZooKeeper.java:1277)
at org.I0Itec.zkclient.ZkConnection.getChildren(ZkConnection.java:99)
at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:416)
at org.I0Itec.zkclient.ZkClient$2.call(ZkClient.java:413)
at org.I0Itec.zkclient.ZkClient.retryUntilConnected(ZkClient.java:675)
... 7 more
Also, the test seems to be a bit long since there are a few places where we sleep for 10 or 30 seconds. Can those sleep be reduced?
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch, kafka-341-v2.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Commented] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
Posted by "Jun Rao (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13293958#comment-13293958 ]
Jun Rao commented on KAFKA-341:
-------------------------------
For sleep time, could we make it more adaptive? Basically, we can periodically check whether certain condition (so that we can do the verification) is met until some max time is reached. That way, we don't have to sleep for the max time in the normal case.
Otherwise, the patch looks fine. The ZK exception was due to some old brokers running in the background on my machine.
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch, kafka-341-v2.patch, kafka-341-v3.patch, kafka-341-v4.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Comment Edited] (KAFKA-341) Create a new single host system
test to validate all replicas on 0.8 branch
Posted by "John Fung (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13285209#comment-13285209 ]
John Fung edited comment on KAFKA-341 at 5/29/12 11:04 PM:
-----------------------------------------------------------
This patch has been tested based on the following pre-requisites:
1. Kafka 0.8 branch rev. 1342841
2. KAFKA-46 patch applied
This test will do the following:
1. 3 brokers are started up and have replicas enabled by default (no. of replicas should be less than or equal to no. of brokers)
2. The logs will be parsed to find out which broker is the leader
3. The leader will be stopped (currently commented out until KAFKA-350 is fixed)
4. Producer will send out some messages
5. Start the broker which is stopped in step 3 (currently commented out until KAFKA-350 is fixed)
6. Repeat Step 2 for all 3 brokers.
7. At the end of the test, it will compare the logs and validate the data file checksum
was (Author: jfung):
This patch has been tested based on the following pre-requisites:
1. Kafka 0.8 branch rev. 1342841
2. KAFKA-46 patch applied
Please note the followings for this patch:
1. It creates a new folder "system_test/single_host_multi_brokers"
2. It starts up 3 brokers and have replicas enabled by default
3. At the end of the test, it will compare the logs and validate the data file checksum
4. Currently, the broker failure testing part is commented out. Please uncomment that after KAFKA-350 is fixed.
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
Posted by "John Fung (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
John Fung updated KAFKA-341:
----------------------------
Status: Patch Available (was: Open)
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
Posted by "John Fung (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
John Fung updated KAFKA-341:
----------------------------
Attachment: kafka-341-v2.patch
Changes not made from Review Suggestion
1. An extra copy of kafka-run-class.sh is added to the bin directory of this specific test folder because a customized copy of log4j.properties is required to enable some debugging code in ConsoleConsumer and ProducerPerformance for checksum validation
Changes made from Review Suggestion
1. Move common functions to a separate script at system_test\common\util.sh
2. Fixed typos (line 56 & 65 in previous version)
3. Rename *_source_cluster to *_cluster
4. README added
5. PASS or FAIL validation is added at the end of the test
6. Target cluster related code removed
7. All the "cut" are replaced with "awk"
Other changes made
1. The script will check the no. of brokers required and generate the corresponding no. of server.properties files
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch, kafka-341-v2.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
[jira] [Updated] (KAFKA-341) Create a new single host system test
to validate all replicas on 0.8 branch
Posted by "John Fung (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/KAFKA-341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
John Fung updated KAFKA-341:
----------------------------
Attachment: kafka-341-v5.patch
Uploaded kafka-341-v5.patch based on Jun's suggestion to reduce the sleep time.
The change in this patch is in the validation stage, the script will compare the replicas' data sizes after a sleep of 5 sec repeatedly up to 30 sec max.
> Create a new single host system test to validate all replicas on 0.8 branch
> ---------------------------------------------------------------------------
>
> Key: KAFKA-341
> URL: https://issues.apache.org/jira/browse/KAFKA-341
> Project: Kafka
> Issue Type: Task
> Reporter: John Fung
> Assignee: John Fung
> Attachments: kafka-341-v1.patch, kafka-341-v2.patch, kafka-341-v3.patch, kafka-341-v4.patch, kafka-341-v5.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira