[jira] [Created] (KAFKA-1585) Client: Infinite conflict in /consumers/

2014-08-10 Thread Artur Denysenko (JIRA)
Artur Denysenko created KAFKA-1585: -- Summary: Client: Infinite conflict in /consumers/ Key: KAFKA-1585 URL: https://issues.apache.org/jira/browse/KAFKA-1585 Project: Kafka Issue Type: Bug

[jira] [Updated] (KAFKA-1585) Client: Infinite conflict in /consumers/

2014-08-10 Thread Artur Denysenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur Denysenko updated KAFKA-1585: --- Description: Periodically we have kafka consumers cycling in to conflict in /consumers/.

[jira] [Updated] (KAFKA-1585) Client: Infinite conflict in /consumers/

2014-08-10 Thread Artur Denysenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur Denysenko updated KAFKA-1585: --- Component/s: consumer Client: Infinite conflict in /consumers/

[jira] [Updated] (KAFKA-1585) Client: Infinite conflict in /consumers/

2014-08-10 Thread Artur Denysenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur Denysenko updated KAFKA-1585: --- Description: Periodically we have kafka consumers cycling in conflict in /consumers/ and I

[jira] [Updated] (KAFKA-1585) Client: Infinite conflict in /consumers/

2014-08-10 Thread Artur Denysenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur Denysenko updated KAFKA-1585: --- Priority: Critical (was: Major) Client: Infinite conflict in /consumers/

[jira] [Updated] (KAFKA-1585) Client: Infinite conflict in /consumers/

2014-08-10 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joe Stein updated KAFKA-1585: - Fix Version/s: 0.8.2 Client: Infinite conflict in /consumers/

[jira] [Commented] (KAFKA-1585) Client: Infinite conflict in /consumers/

2014-08-10 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092050#comment-14092050 ] Joe Stein commented on KAFKA-1585: -- FWIW there were a lot of bug fixes released in the

[jira] [Commented] (KAFKA-1451) Broker stuck due to leader election race

2014-08-10 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092051#comment-14092051 ] Joe Stein commented on KAFKA-1451: -- Hi, two issues so far where found with leader

Re: Review Request 24006: Patch for KAFKA-1420

2014-08-10 Thread Jonathan Natkins
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24006/#review50126 --- core/src/test/scala/unit/kafka/admin/AdminTest.scala

[jira] [Commented] (KAFKA-1420) Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with TestUtils.createTopic in unit tests

2014-08-10 Thread Jonathan Natkins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092203#comment-14092203 ] Jonathan Natkins commented on KAFKA-1420: - Updated reviewboard

[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

2014-08-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092205#comment-14092205 ] Jun Rao commented on KAFKA-1510: Thinking about this a bit more, would it be more reliable

[jira] [Commented] (KAFKA-1585) Client: Infinite conflict in /consumers/

2014-08-10 Thread Artur Denysenko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092207#comment-14092207 ] Artur Denysenko commented on KAFKA-1585: I've tried with Zookeeper 3.4.6 - same

[jira] [Created] (KAFKA-1586) support sticky partitioning in the new producer

2014-08-10 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-1586: -- Summary: support sticky partitioning in the new producer Key: KAFKA-1586 URL: https://issues.apache.org/jira/browse/KAFKA-1586 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-1586) support sticky partitioning in the new producer

2014-08-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092237#comment-14092237 ] Jun Rao commented on KAFKA-1586: One way to address this issue is introduce a new config

[jira] [Commented] (KAFKA-1451) Broker stuck due to leader election race

2014-08-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092253#comment-14092253 ] Jun Rao commented on KAFKA-1451: Joe, KAFKA-1387 seems to be related to broker

[jira] [Commented] (KAFKA-1387) Kafka getting stuck creating ephemeral node it has already created when two zookeeper sessions are established in a very short period of time

2014-08-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092255#comment-14092255 ] Jun Rao commented on KAFKA-1387: Hmm, this seems really weird. Not sure why starting two

Re: Review Request 24214: Patch for KAFKA-1374

2014-08-10 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24214/#review50128 --- core/src/main/scala/kafka/log/LogCleaner.scala

Re: Review Request 24510: Patch for KAFKA-1582

2014-08-10 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24510/#review50127 --- Thanks for the patch. Could you take a look at the following

[jira] [Commented] (KAFKA-1587) Possible Memory Leak when we use Kafka 8.0 Producer for sending messages

2014-08-10 Thread Gopinath Sundaram (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092292#comment-14092292 ] Gopinath Sundaram commented on KAFKA-1587: -- I found this issue

[jira] [Resolved] (KAFKA-1419) cross build for scala 2.11

2014-08-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1419. Resolution: Fixed Thanks for the patch. +1. Committed to trunk after fixing README and the 2.11

Re: Review Request 24510: Patch for KAFKA-1582

2014-08-10 Thread Dong Lin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24510/ --- (Updated Aug. 11, 2014, 4:23 a.m.) Review request for kafka. Bugs:

Re: Review Request 24006: Patch for KAFKA-1420

2014-08-10 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24006/#review50137 --- Thanks for the patch. One comment below.

[jira] [Commented] (KAFKA-1582) System Test should wait for producer to finish

2014-08-10 Thread Dong Lin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092428#comment-14092428 ] Dong Lin commented on KAFKA-1582: - Updated reviewboard

Re: Review Request 24214: Patch for KAFKA-1374

2014-08-10 Thread Manikumar Reddy O
On Aug. 10, 2014, 11:44 p.m., Jun Rao wrote: core/src/main/scala/kafka/log/LogCleaner.scala, lines 400-420 https://reviews.apache.org/r/24214/diff/4/?file=657033#file657033line400 Thinking about this a bit more. I am wondering if it would be better if we introduce a per-topic

Re: Review Request 24510: Patch for KAFKA-1582

2014-08-10 Thread Dong Lin
On Aug. 11, 2014, 12:06 a.m., Jun Rao wrote: system_test/utils/kafka_system_test_utils.py, lines 1121-1124 https://reviews.apache.org/r/24510/diff/1/?file=656792#file656792line1121 Does this work as expected? I tried the following test. However, the pid in the file tt

[jira] [Updated] (KAFKA-1574) unit tests can hang on socketserver shutdown

2014-08-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1574: --- Summary: unit tests can hang on socketserver shutdown (was: unit tests can hand on socketserver shutdown)

Review Request 24540: Patch for KAFKA-1574

2014-08-10 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24540/ --- Review request for kafka. Bugs: KAFKA-1574

[jira] [Commented] (KAFKA-1574) unit tests can hang on socketserver shutdown

2014-08-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092436#comment-14092436 ] Jun Rao commented on KAFKA-1574: Created reviewboard https://reviews.apache.org/r/24540/

[jira] [Updated] (KAFKA-1574) unit tests can hang on socketserver shutdown

2014-08-10 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1574?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1574: --- Attachment: KAFKA-1574.patch unit tests can hang on socketserver shutdown

Re: Review Request 24540: Patch for KAFKA-1574

2014-08-10 Thread Jay Kreps
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24540/#review50148 --- Ship it! Ship It! - Jay Kreps On Aug. 11, 2014, 4:44 a.m., Jun

Re: Review Request 24540: Patch for KAFKA-1574

2014-08-10 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24540/#review50157 --- Ship it! Ship It! - Guozhang Wang On Aug. 11, 2014, 4:44 a.m.,

[jira] [Commented] (KAFKA-1588) Offset response does not support two requests for the same topic/partition combo

2014-08-10 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14092461#comment-14092461 ] Guozhang Wang commented on KAFKA-1588: -- As have discussed with Todd, changing the map

Re: Review Request 24006: Patch for KAFKA-1420

2014-08-10 Thread Guozhang Wang
On Aug. 10, 2014, 9:12 p.m., Jonathan Natkins wrote: core/src/test/scala/unit/kafka/admin/AdminTest.scala, line 114 https://reviews.apache.org/r/24006/diff/3-4/?file=646111#file646111line114 I wasn't totally sure I understood this comment, so I made a change that I think reflects

Re: Review Request 24510: Patch for KAFKA-1582

2014-08-10 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24510/#review50159 --- Ship it! Ship It! - Guozhang Wang On Aug. 11, 2014, 4:23 a.m.,

Jenkins build is back to normal : Kafka-trunk #243

2014-08-10 Thread Apache Jenkins Server
See https://builds.apache.org/job/Kafka-trunk/243/changes