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

[ https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Artur Denysenko updated KAFKA-1585: --- Attachment: kafka_consumer_ephemeral_node_extract.zip > Client: Infinite "conflict in /consum

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

[ 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/". P

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

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

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

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14092050#comment-14092050 ] Joe Stein commented on KAFKA-1585: -- FWIW there were a lot of bug fixes released in the Zo

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

[ https://issues.apache.org/jira/browse/KAFKA-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14092051#comment-14092051 ] Joe Stein commented on KAFKA-1451: -- Hi, two issues so far where found with leader electio

Re: Review Request 24196: Patch for KAFKA-1567

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24196/#review50125 --- core/src/main/scala/kafka/metrics/KafkaMetricsGroup.scala

Re: Review Request 24006: Patch for KAFKA-1420

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24006/ --- (Updated Aug. 10, 2014, 9:11 p.m.) Review request for kafka. Bugs: KAFKA-1420

Re: Review Request 24006: Patch for KAFKA-1420

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

[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14092203#comment-14092203 ] Jonathan Natkins commented on KAFKA-1420: - Updated reviewboard https://reviews.apa

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

[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Natkins updated KAFKA-1420: Attachment: KAFKA-1420_2014-08-10_14:12:05.patch > Replace AdminUtils.createOrUpdateTopicPa

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

[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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/"

[ https://issues.apache.org/jira/browse/KAFKA-1585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14092207#comment-14092207 ] Artur Denysenko commented on KAFKA-1585: I've tried with Zookeeper 3.4.6 - same pr

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

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 C

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

[ https://issues.apache.org/jira/browse/KAFKA-1586?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ https://issues.apache.org/jira/browse/KAFKA-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14092253#comment-14092253 ] Jun Rao commented on KAFKA-1451: Joe, KAFKA-1387 seems to be related to broker registrati

[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

[ https://issues.apache.org/jira/browse/KAFKA-1387?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14092255#comment-14092255 ] Jun Rao commented on KAFKA-1387: Hmm, this seems really weird. Not sure why starting two b

Re: Review Request 24214: Patch for KAFKA-1374

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

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

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

Gopinath Sundaram created KAFKA-1587: Summary: Possible Memory Leak when we use Kafka 8.0 Producer for sending messages Key: KAFKA-1587 URL: https://issues.apache.org/jira/browse/KAFKA-1587 Projec

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

[ https://issues.apache.org/jira/browse/KAFKA-1587?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14092292#comment-14092292 ] Gopinath Sundaram commented on KAFKA-1587: -- I found this issue https://issues.apa

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

Todd Palino created KAFKA-1588: -- Summary: Offset response does not support two requests for the same topic/partition combo Key: KAFKA-1588 URL: https://issues.apache.org/jira/browse/KAFKA-1588 Project: K

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

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

Re: Review Request 24510: Patch for KAFKA-1582

--- 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: KAFKA-1582

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

[ https://issues.apache.org/jira/browse/KAFKA-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-1582: Attachment: KAFKA-1582_2014-08-10_21:24:07.patch > System Test should wait for producer to finish > ---

Re: Review Request 24006: Patch for KAFKA-1420

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24006/#review50137 --- Thanks for the patch. One comment below. core/src/test/scala/unit/

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

[ https://issues.apache.org/jira/browse/KAFKA-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14092428#comment-14092428 ] Dong Lin commented on KAFKA-1582: - Updated reviewboard https://reviews.apache.org/r/24510/

Re: Review Request 24214: Patch for KAFKA-1374

> On Aug. 10, 2014, 11:44 p.m., Jun Rao wrote: > > core/src/main/scala/kafka/log/LogCleaner.scala, lines 400-420 > > > > > > Thinking about this a bit more. I am wondering if it would be better if > > we introduce a p

Re: Review Request 24510: Patch for KAFKA-1582

> On Aug. 11, 2014, 12:06 a.m., Jun Rao wrote: > > system_test/utils/kafka_system_test_utils.py, lines 1121-1124 > > > > > > Does this work as expected? > > > > I tried the following test. However, the pid in

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

[ 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

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24540/ --- Review request for kafka. Bugs: KAFKA-1574 https://issues.apache.org/jira/b

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

[ https://issues.apache.org/jira/browse/KAFKA-1574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

[ 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

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

Re: Review Request 24540: Patch for KAFKA-1574

--- 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., J

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

[ https://issues.apache.org/jira/browse/KAFKA-1588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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

> On Aug. 10, 2014, 9:12 p.m., Jonathan Natkins wrote: > > core/src/test/scala/unit/kafka/admin/AdminTest.scala, line 114 > > > > > > I wasn't totally sure I understood this comment, so I made a change > > that I th

Re: Review Request 24510: Patch for KAFKA-1582

--- 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., D

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

See

Re: Review Request 24006: Patch for KAFKA-1420

Ah, gotcha. Given that, I think I made the right adjustment. Thanks for the clarification! On Sun, Aug 10, 2014 at 10:38 PM, Guozhang Wang wrote: > > > > On Aug. 10, 2014, 9:12 p.m., Jonathan Natkins wrote: > > > core/src/test/scala/unit/kafka/admin/AdminTest.scala, line 114 > > > < > https://r

Re: Review Request 24006: Patch for KAFKA-1420

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24006/ --- (Updated Aug. 11, 2014, 6:03 a.m.) Review request for kafka. Bugs: KAFKA-1420

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

[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Natkins updated KAFKA-1420: Attachment: KAFKA-1420_2014-08-10_23:03:46.patch > Replace AdminUtils.createOrUpdateTopicPa

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

[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14092485#comment-14092485 ] Jonathan Natkins commented on KAFKA-1420: - Updated reviewboard https://reviews.apa

[jira] [Commented] (KAFKA-1481) Stop using dashes AND underscores as separators in MBean names

[ https://issues.apache.org/jira/browse/KAFKA-1481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14092501#comment-14092501 ] Otis Gospodnetic commented on KAFKA-1481: - Looks like 0.9 has been pushed to Decem