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

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14035911#comment-14035911 ] Jay Kreps commented on KAFKA-1316: -- Ack, this is dumb bug. Thanks! Will patch. > Refacto

[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-tabpanel&focusedCommentId=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 https://issues.apache.org/jira/b

[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-tabpanel&focusedCommentId=14036034#comment-14036034 ] Jay Kreps commented on KAFKA-1291: -- Created reviewboard https://reviews.apache.org/r/2274

[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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14036082#comment-14036082 ] Sriharsha Chintalapani commented on KAFKA-1382: --- [~junrao] Can you please ta

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

[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-tabpanel&focusedCommentId=14036189#comment-14036189 ] Jay Kreps commented on KAFKA-1291: -- Specifically it would be good for someone to sanity c

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 https://issues.apache.org/jira/b

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

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

[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., S

[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-tabpanel&focusedCommentId=14036932#comment-14036932 ] Neha Narkhede commented on KAFKA-1382: -- Thanks for the follow up patch. Pushed to tru

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-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14036964#comment-14036964 ] Jun Rao commented on KAFKA-1382: Thanks for the patch. This looks good to me. > Update zk

[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-1472) Add the compression ratio metrics in the new producer

[ https://issues.apache.org/jira/browse/KAFKA-1472?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1472. > Add the compression ratio metrics in the new producer > -

[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: https://is

[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-1146) toString() on KafkaStream gets stuck indefinitely

[ https://issues.apache.org/jira/browse/KAFKA-1146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1146. > toString() on KafkaStream gets stuck indefinitely > -

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

Build failed in Jenkins: Kafka-trunk #207

See Changes: [neha.narkhede] KAFKA-1382 follow up patch; reviewed by Neha Narkhede -- [...truncated 1446 lines...] java.net.BindException: Address already in use at sun.nio.ch.Net.bind(Nat

[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-tabpanel&focusedCommentId=14036969#comment-14036969 ] Babak Behzad commented on KAFKA-1283: - [~nehanarkhede]: I came up with a patch for thi

[jira] [Closed] (KAFKA-245) upgrade to zkclient 0.1

[ https://issues.apache.org/jira/browse/KAFKA-245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-245. --- > upgrade to zkclient 0.1 > --- > > Key: KAFKA-245 > U

[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-233) The producer's load balancing logic can send requests to dead brokers, when using the async producer option

[ https://issues.apache.org/jira/browse/KAFKA-233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-233. --- > The producer's load balancing logic can send requests to dead brokers, when > using the async producer

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