[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=15946408#comment-15946408 ] Bo Wang edited comment on KAFKA-4966 at 3/29/17 2:06 AM: - Hi, Ismael Juma. I used

[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

[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:

[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=15047899#comment-15047899 ] Bo Wang commented on KAFKA-2965: https://github.com/apache/kafka/pull/646 [~gwenshap] please review it.

[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) >

[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

[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] [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:

[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=15047855#comment-15047855 ] Bo Wang commented on KAFKA-2965: According to the code, I think the name of the two variable needs to be

[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] [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=15047873#comment-15047873 ] Bo Wang commented on KAFKA-2965: patch submit. please review it. thanks. > Two variables should be

[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] [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] [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=14956579#comment-14956579 ] Bo Wang commented on KAFKA-1554: @ Jun Rao, @Mayuresh Gharat , I don't think this patch is available. The

[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: --- 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-tabpanelfocusedCommentId=14661164#comment-14661164 ] Bo Wang commented on KAFKA-2414: The exception sometimes occurs , how can I fix or avoid

[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:

[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

[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

[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] [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] [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] [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:

[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-tabpanelfocusedCommentId=14640080#comment-14640080 ] Bo Wang commented on KAFKA-1482: When I execute unit tests reported the same fault！

[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

[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) The shell script should be optimized , even kafka-run-class.sh has a

[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

[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

[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-tabpanelfocusedCommentId=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: --- 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-tabpanelfocusedCommentId=14502583#comment-14502583 ] Bo Wang edited comment on KAFKA-2122 at 4/20/15 10:27 AM: -- Which