[jira] [Comment Edited] (KAFKA-4966) Producer throw a NullPointerException under a network environment where packet loss and error packets exist.

[ https://issues.apache.org/jira/browse/KAFKA-4966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946408#comment-15946408 ] Bo Wang edited comment on KAFKA-4966 at 3/29/17 2:06 AM: - Hi, Isma

[jira] [Commented] (KAFKA-4966) Producer throw a NullPointerException under a network environment where packet loss and error packets exist.

[ https://issues.apache.org/jira/browse/KAFKA-4966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15946408#comment-15946408 ] Bo Wang commented on KAFKA-4966: Hi, Ismael Juma. I used the 0.10.0.1 version and merged s

[jira] [Updated] (KAFKA-4966) Producer throw a NullPointerException under a network environment where packet loss and error packets exist.

[ https://issues.apache.org/jira/browse/KAFKA-4966?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-4966: --- Summary: Producer throw a NullPointerException under a network environment where packet loss and error packets

[jira] [Created] (KAFKA-4966) Producer maybe throw a NullPointerException under a network environment where packet loss and error packets exist.

Bo Wang created KAFKA-4966: -- Summary: Producer maybe throw a NullPointerException under a network environment where packet loss and error packets exist. Key: KAFKA-4966 URL: https://issues.apache.org/jira/browse/KAFKA-49

[jira] [Commented] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047899#comment-15047899 ] Bo Wang commented on KAFKA-2965: https://github.com/apache/kafka/pull/646 [~gwenshap] plea

[jira] [Commented] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047873#comment-15047873 ] Bo Wang commented on KAFKA-2965: patch submit. please review it. thanks. > Two variables

[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Labels: patch (was: ) Reviewer: (was: Neha Narkhede) Status: Patch Available (was: Open) > Two

[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Attachment: Kafka-2965.patch > Two variables should be exchanged. > -- > >

[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Fix Version/s: (was: 0.9.1.0) > Two variables should be exchanged. > -- >

[jira] [Commented] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15047855#comment-15047855 ] Bo Wang commented on KAFKA-2965: According to the code, I think the name of the two variab

[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Status: Open (was: Patch Available) > Two variables should be exchanged. > --

[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Reviewer: Neha Narkhede Fix Version/s: 0.9.1.0 Status: Patch Available (was: Open) > Two

[jira] [Updated] (KAFKA-2965) Two variables should be exchanged.

[ https://issues.apache.org/jira/browse/KAFKA-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2965: --- Description: Two variables should be exchanged in KafkaController.scala as follows： val topicsForWhichPartitio

[jira] [Created] (KAFKA-2965) Two variables should be exchanged.

Bo Wang created KAFKA-2965: -- Summary: Two variables should be exchanged. Key: KAFKA-2965 URL: https://issues.apache.org/jira/browse/KAFKA-2965 Project: Kafka Issue Type: Bug Components: co

[jira] [Commented] (KAFKA-1554) Corrupt index found on clean startup

[ https://issues.apache.org/jira/browse/KAFKA-1554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14956579#comment-14956579 ] Bo Wang commented on KAFKA-1554: @ Jun Rao, @Mayuresh Gharat , I don't think this patch i

[jira] [Created] (KAFKA-2560) Fatal error during KafkaServer startup because of Map failed error.

Bo Wang created KAFKA-2560: -- Summary: Fatal error during KafkaServer startup because of Map failed error. Key: KAFKA-2560 URL: https://issues.apache.org/jira/browse/KAFKA-2560 Project: Kafka Issue

[jira] [Updated] (KAFKA-2470) kafka-producer-perf-test.sh can't configure all to request-num-acks

[ https://issues.apache.org/jira/browse/KAFKA-2470?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2470: --- Fix Version/s: 0.8.3 > kafka-producer-perf-test.sh can't configure all to request-num-acks > -

[jira] [Created] (KAFKA-2470) kafka-producer-perf-test.sh can't configure all to request-num-acks

Bo Wang created KAFKA-2470: -- Summary: kafka-producer-perf-test.sh can't configure all to request-num-acks Key: KAFKA-2470 URL: https://issues.apache.org/jira/browse/KAFKA-2470 Project: Kafka Issue

[jira] [Updated] (KAFKA-2414) Running kafka-producer-perf-test.sh with " --messages 10000000 --message-size 1000 --new-producer" will get WARN Error in I/O.

[ https://issues.apache.org/jira/browse/KAFKA-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2414: --- Description: Running kafka-producer-perf-test.sh with " --messages 1000 --message-size 1000 --new-produ

[jira] [Updated] (KAFKA-2414) Running kafka-producer-perf-test.sh with " --messages 10000000 --message-size 1000 --new-producer" will get WARN Error in I/O.

[ https://issues.apache.org/jira/browse/KAFKA-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2414: --- Summary: Running kafka-producer-perf-test.sh with " --messages 1000 --message-size 1000 --new-producer"

[jira] [Commented] (KAFKA-2414) Running kafka-producer-perf-test.sh with " --messages 10000000 --message-size 1000 --new-producer" will got WARN Error in I/O.

[ https://issues.apache.org/jira/browse/KAFKA-2414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14661164#comment-14661164 ] Bo Wang commented on KAFKA-2414: The exception sometimes occurs , how can I fix or avoid t

[jira] [Created] (KAFKA-2414) Running kafka-producer-perf-test.sh with " --messages 10000000 --message-size 1000 --new-producer" will got WARN Error in I/O.

Bo Wang created KAFKA-2414: -- Summary: Running kafka-producer-perf-test.sh with " --messages 1000 --message-size 1000 --new-producer" will got WARN Error in I/O. Key: KAFKA-2414 URL: https://issues.apache.org/jira/b

[jira] [Updated] (KAFKA-2360) The kafka-consumer-perf-test.sh script help information print useless parameters.

[ https://issues.apache.org/jira/browse/KAFKA-2360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2360: --- Description: Run kafka-consumer-perf-test.sh --help to show help information, but found 3 parameters useless

[jira] [Updated] (KAFKA-2360) The kafka-consumer-perf-test.sh script help information print useless parameters.

[ https://issues.apache.org/jira/browse/KAFKA-2360?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2360: --- Description: Run kafka-consumer-perf-test.sh --help to show help information, but found 3 parameters useless

[jira] [Created] (KAFKA-2362) kafka-consumer-perf-test.sh got a negative result

Bo Wang created KAFKA-2362: -- Summary: kafka-consumer-perf-test.sh got a negative result Key: KAFKA-2362 URL: https://issues.apache.org/jira/browse/KAFKA-2362 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-2361) Unit Test BUILD FAILED

[ https://issues.apache.org/jira/browse/KAFKA-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2361: --- Affects Version/s: 0.8.2.1 Environment: Linux Remaining Estimate: 48h Original Estimate: 4

[jira] [Updated] (KAFKA-2361) Unit Test failed:testCleanShutdownAfterFailedStartup

[ https://issues.apache.org/jira/browse/KAFKA-2361?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2361: --- Priority: Minor (was: Major) > Unit Test failed:testCleanShutdownAfterFailedStartup > ---

[jira] [Created] (KAFKA-2361) Unit Test failed:testCleanShutdownAfterFailedStartup

Bo Wang created KAFKA-2361: -- Summary: Unit Test failed:testCleanShutdownAfterFailedStartup Key: KAFKA-2361 URL: https://issues.apache.org/jira/browse/KAFKA-2361 Project: Kafka Issue Type: Bug

[jira] [Created] (KAFKA-2360) The kafka-consumer-perf-test.sh script help information print useless parameters.

Bo Wang created KAFKA-2360: -- Summary: The kafka-consumer-perf-test.sh script help information print useless parameters. Key: KAFKA-2360 URL: https://issues.apache.org/jira/browse/KAFKA-2360 Project: Kafka

[jira] [Commented] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest

[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14640080#comment-14640080 ] Bo Wang commented on KAFKA-1482: When I execute unit tests reported the same fault！ > Tra

[jira] [Commented] (KAFKA-2254) The shell script should be optimized , even kafka-run-class.sh has a syntax error.

[ https://issues.apache.org/jira/browse/KAFKA-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14578153#comment-14578153 ] Bo Wang commented on KAFKA-2254: The trunk have fixed kafka-run-class.sh syntax error. >

[jira] [Updated] (KAFKA-2254) The shell script should be optimized , even kafka-run-class.sh has a syntax error.

[ https://issues.apache.org/jira/browse/KAFKA-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2254: --- Priority: Major (was: Critical) > The shell script should be optimized , even kafka-run-class.sh has a syntax

[jira] [Updated] (KAFKA-2254) The shell script should be optimized , even kafka-run-class.sh has a syntax error.

[ https://issues.apache.org/jira/browse/KAFKA-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2254: --- Status: Patch Available (was: Open) I create a patch kafka-shell-script.patch of the trunk . > The shell scr

[jira] [Updated] (KAFKA-2254) The shell script should be optimized , even kafka-run-class.sh has a syntax error.

[ https://issues.apache.org/jira/browse/KAFKA-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2254: --- Attachment: kafka-shell-script.patch > The shell script should be optimized , even kafka-run-class.sh has a sy

[jira] [Updated] (KAFKA-2254) The shell script should be optimized , even kafka-run-class.sh has a syntax error.

[ https://issues.apache.org/jira/browse/KAFKA-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2254: --- Status: Patch Available (was: Open) > The shell script should be optimized , even kafka-run-class.sh has a sy

[jira] [Updated] (KAFKA-2254) The shell script should be optimized , even kafka-run-class.sh has a syntax error.

[ https://issues.apache.org/jira/browse/KAFKA-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2254: --- Status: Open (was: Patch Available) > The shell script should be optimized , even kafka-run-class.sh has a sy

[jira] [Updated] (KAFKA-2254) The shell script should be optimized , even kafka-run-class.sh has a syntax error.

[ https://issues.apache.org/jira/browse/KAFKA-2254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bo Wang updated KAFKA-2254: --- Description: kafka-run-class.sh 128 line has a syntax error(missing a space): 127-loggc) 128 if [ -z

[jira] [Created] (KAFKA-2254) The shell script should be optimized , even kafka-run-class.sh has a syntax error.

Bo Wang created KAFKA-2254: -- Summary: The shell script should be optimized , even kafka-run-class.sh has a syntax error. Key: KAFKA-2254 URL: https://issues.apache.org/jira/browse/KAFKA-2254 Project: Kafka

[jira] [Comment Edited] (KAFKA-2122) Remove controller.message.queue.size Config

[ https://issues.apache.org/jira/browse/KAFKA-2122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14502583#comment-14502583 ] Bo Wang edited comment on KAFKA-2122 at 4/20/15 10:27 AM: -- Which