[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14035620#comment-14035620 ] Łukasz Drumiński commented on KAFKA-1316: - Hello everyone, I have a problem with

[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14035911#comment-14035911 ] Jay Kreps commented on KAFKA-1316: -- Ack, this is dumb bug. Thanks! Will patch. Refactor

[jira] [Commented] (KAFKA-1308) Publish jar of test utilities to Maven

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14035969#comment-14035969 ] Ivan Lyutov commented on KAFKA-1308: +1 Patch looks nice. It might be very useful.

Review Request 22744: Patch for KAFKA-1291

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22744/ --- Review request for kafka. Bugs: KAFKA-1291

[jira] [Commented] (KAFKA-1291) Make wrapper shell scripts for important tools

[ https://issues.apache.org/jira/browse/KAFKA-1291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14036034#comment-14036034 ] Jay Kreps commented on KAFKA-1291: -- Created reviewboard

[jira] [Updated] (KAFKA-1291) Make wrapper shell scripts for important tools

[ https://issues.apache.org/jira/browse/KAFKA-1291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1291: - Attachment: KAFKA-1291.patch Make wrapper shell scripts for important tools

[jira] [Commented] (KAFKA-1291) Make wrapper shell scripts for important tools

[ https://issues.apache.org/jira/browse/KAFKA-1291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14036041#comment-14036041 ] Jay Kreps commented on KAFKA-1291: -- Hey [~sgeller] this is great! I updated this patch a

[jira] [Commented] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14036082#comment-14036082 ] Sriharsha Chintalapani commented on KAFKA-1382: --- [~junrao] Can you please

[jira] [Created] (KAFKA-1497) Change producer load-balancing algorithm in MirrorMaker

Ivan Kunz created KAFKA-1497: Summary: Change producer load-balancing algorithm in MirrorMaker Key: KAFKA-1497 URL: https://issues.apache.org/jira/browse/KAFKA-1497 Project: Kafka Issue Type:

Review Request 22762: Fix concurrent modification exception in Sender.

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22762/ --- Review request for kafka. Bugs: KAFKA-1316

[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14036582#comment-14036582 ] Jay Kreps commented on KAFKA-1316: -- Created reviewboard

[jira] [Updated] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps updated KAFKA-1316: - Attachment: KAFKA-1316.patch Refactor Sender --- Key: KAFKA-1316

Looking for review on two trivial patches

Looking for review: https://reviews.apache.org/r/22744/ https://reviews.apache.org/r/22762 -Jay

Re: Review Request 22744: Patch for KAFKA-1291

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22744/#review46173 --- bin/windows/kafka-simple-consumer-perf-test.bat

Re: Review Request 22762: Fix concurrent modification exception in Sender.

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22762/#review46175 --- Ship it! Ship It! - Neha Narkhede On June 18, 2014, 10:43 p.m.,

Re: Review Request 21899: Patch for KAFKA-1382

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21899/#review46183 --- Ship it! Ship It! - Neha Narkhede On June 16, 2014, 9:19 p.m.,

[jira] [Commented] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14036932#comment-14036932 ] Neha Narkhede commented on KAFKA-1382: -- Thanks for the follow up patch. Pushed to

Re: Review Request 22496: Patch for KAFKA-1096

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/22496/#review46184 --- core/src/main/scala/kafka/controller/KafkaController.scala

[jira] [Commented] (KAFKA-1308) Publish jar of test utilities to Maven

[ https://issues.apache.org/jira/browse/KAFKA-1308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14036961#comment-14036961 ] Jun Rao commented on KAFKA-1308: Thanks for the patch. I am not sure if it's worthwhile to

[jira] [Commented] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14036964#comment-14036964 ] Jun Rao commented on KAFKA-1382: Thanks for the patch. This looks good to me. Update

[jira] [Closed] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1438. Migrate kafka client tools -- Key: KAFKA-1438

[jira] [Closed] (KAFKA-1195) windows kafka-run-class.bat not updated

[ https://issues.apache.org/jira/browse/KAFKA-1195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1195. windows kafka-run-class.bat not updated ---

[jira] [Closed] (KAFKA-1189) kafka-server-stop.sh doesn't stop broker

[ https://issues.apache.org/jira/browse/KAFKA-1189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1189. kafka-server-stop.sh doesn't stop broker

[jira] [Updated] (KAFKA-1283) Log4jAppender is unable to send the message.

[ https://issues.apache.org/jira/browse/KAFKA-1283?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1283: - Assignee: Sriharsha Chintalapani (was: Jun Rao) Log4jAppender is unable to send the message.

[jira] [Closed] (KAFKA-616) Implement acks=0

[ https://issues.apache.org/jira/browse/KAFKA-616?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-616. --- Implement acks=0 Key: KAFKA-616 URL:

[jira] [Closed] (KAFKA-1079) Liars in PrimitiveApiTest that promise to test api in compression mode, but don't do this actually

[ https://issues.apache.org/jira/browse/KAFKA-1079?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1079. Liars in PrimitiveApiTest that promise to test api in compression mode, but don't do this actually

[jira] [Closed] (KAFKA-653) Allow getTopicMetadata to get metadata for all topics

[ https://issues.apache.org/jira/browse/KAFKA-653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-653. --- Allow getTopicMetadata to get metadata for all topics

[jira] [Closed] (KAFKA-1041) Number of file handles increases indefinitely in producer if broker host is unresolvable

[ https://issues.apache.org/jira/browse/KAFKA-1041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1041. Number of file handles increases indefinitely in producer if broker host is unresolvable

[jira] [Closed] (KAFKA-456) ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation

[ https://issues.apache.org/jira/browse/KAFKA-456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-456. --- ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation

[jira] [Commented] (KAFKA-1283) Log4jAppender is unable to send the message.

[ https://issues.apache.org/jira/browse/KAFKA-1283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14036969#comment-14036969 ] Babak Behzad commented on KAFKA-1283: - [~nehanarkhede]: I came up with a patch for

[jira] [Closed] (KAFKA-455) ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation

[ https://issues.apache.org/jira/browse/KAFKA-455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-455. --- ProducerSendThread calls ListBuffer.size a whole bunch. That is a O(n) operation

[jira] [Closed] (KAFKA-367) StringEncoder/StringDecoder use platform default character set

[ https://issues.apache.org/jira/browse/KAFKA-367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-367. --- StringEncoder/StringDecoder use platform default character set

[jira] [Closed] (KAFKA-215) Improve system tests for the mirroring code

[ https://issues.apache.org/jira/browse/KAFKA-215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-215. --- Improve system tests for the mirroring code ---

[jira] [Closed] (KAFKA-247) max.message.size and fetch.size defaults should be consistent

[ https://issues.apache.org/jira/browse/KAFKA-247?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-247. --- max.message.size and fetch.size defaults should be consistent

[jira] [Closed] (KAFKA-374) Move to java CRC32 implementation

[ https://issues.apache.org/jira/browse/KAFKA-374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-374. --- Move to java CRC32 implementation - Key: KAFKA-374

[jira] [Closed] (KAFKA-218) ZOOKEEPER-961 is nasty, upgrade to zk 3.3.4

[ https://issues.apache.org/jira/browse/KAFKA-218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-218. --- ZOOKEEPER-961 is nasty, upgrade to zk 3.3.4 ---

[jira] [Closed] (KAFKA-241) ConsumerIterator throws a IllegalStateException after a ConsumerTimeout occurs

[ https://issues.apache.org/jira/browse/KAFKA-241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-241. --- ConsumerIterator throws a IllegalStateException after a ConsumerTimeout occurs

[jira] [Closed] (KAFKA-220) LogManager test fails on linux

[ https://issues.apache.org/jira/browse/KAFKA-220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-220. --- LogManager test fails on linux -- Key: KAFKA-220

[jira] [Updated] (KAFKA-1483) Split Brain about Leader Partitions

[ https://issues.apache.org/jira/browse/KAFKA-1483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1483: - Assignee: Sriharsha Chintalapani (was: Jun Rao) Split Brain about Leader Partitions