[jira] [Comment Edited] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14074122#comment-14074122 ] Joe Stein edited comment on KAFKA-1555 at 7/25/14 6:11 AM: --- The

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14074122#comment-14074122 ] Joe Stein commented on KAFKA-1555: -- The simplification and guarantee provided with ack=-1

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14074119#comment-14074119 ] Dmitry Bugaychenko commented on KAFKA-1414: --- I'm not a scala expert, but the thr

Re: Gradle hanging on unit test run against ProducerFailureHangingTest->testBrokerFailure

Hey Gouzhang, Yes, I spotted that commit and had updated my working copy to that, but the test is still hanging. If it's any help, the test looks like it's doing _something_ as the CPU usage ramps up significantly and stays there until I kill the process. /Dave On Thu, Jul 24, 2014 at 4:10 PM, G

[jira] [Commented] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14074081#comment-14074081 ] Jun Rao commented on KAFKA-1029: I think the proposed fix in KAFKA-1451 will fix this issu

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14074070#comment-14074070 ] Jun Rao commented on KAFKA-1555: Sudarshan, Our replication guarantees are the following.

[jira] [Commented] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14074064#comment-14074064 ] Jun Rao commented on KAFKA-1211: Not quite. The case that I described above could happen w

Re: Review Request 23702: Patch for KAFKA-1070

> On July 24, 2014, 1:41 a.m., Jun Rao wrote: > > core/src/main/scala/kafka/server/KafkaServer.scala, lines 359-369 > > > > > > Does this cover the case for metaBrokerIdSet.size == 1 and brokerId < > > 0? In this case

[jira] [Commented] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14074036#comment-14074036 ] Sriharsha Chintalapani commented on KAFKA-1070: --- Updated reviewboard https:/

[jira] [Updated] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1070: -- Attachment: KAFKA-1070_2014-07-24_21:05:33.patch > Auto-assign node id > --

Re: Review Request 23702: Patch for KAFKA-1070

> On July 24, 2014, 1:21 a.m., Neha Narkhede wrote: > > core/src/main/scala/kafka/utils/ZkUtils.scala, line 133 > > > > > > It will be good to refer to 1000 as a static variable inside > > KafkaConfig eg. KafkaConfig.

Re: Review Request 23702: Patch for KAFKA-1070

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23702/ --- (Updated July 25, 2014, 4:05 a.m.) Review request for kafka. Bugs: KAFKA-1070

[jira] [Commented] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14074028#comment-14074028 ] Sriharsha Chintalapani commented on KAFKA-1070: --- Updated reviewboard https:/

[jira] [Updated] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1070: -- Attachment: KAFKA-1070_2014-07-24_20:58:17.patch > Auto-assign node id > --

Re: Review Request 23702: Patch for KAFKA-1070

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23702/ --- (Updated July 25, 2014, 3:58 a.m.) Review request for kafka. Bugs: KAFKA-1070

[jira] [Created] (KAFKA-1556) Sorry it's Just Test

sungjubong created KAFKA-1556: - Summary: Sorry it's Just Test Key: KAFKA-1556 URL: https://issues.apache.org/jira/browse/KAFKA-1556 Project: Kafka Issue Type: Test Components: core

Build failed in Jenkins: Kafka-trunk #232

See Changes: [jay.kreps] KAFKA-1544 Log cleaner takes a long time to shut down. Patch from Manikumar Reddy. [neha.narkhede] KAFKA-1483 Split Brain about Leader Partitions; reviewed by Guozhang, Jun and Neha --

[jira] [Resolved] (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 resolved KAFKA-1483. -- Resolution: Fixed Assignee: Sriharsha Chintalapani (was: Neha Narkhede) Sorry about the

[jira] [Resolved] (KAFKA-1544) LogCleaner may take a long time to shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1544. -- Resolution: Fixed Fix Version/s: 0.8.2 Committed, thanks! > LogCleaner may take a long time to

[jira] [Updated] (KAFKA-1527) SimpleConsumer should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Raul Castro Fernandez updated KAFKA-1527: - Attachment: KAFKA-1527.patch > SimpleConsumer should be transaction-aware > -

[jira] [Commented] (KAFKA-1527) SimpleConsumer should be transaction-aware

[ https://issues.apache.org/jira/browse/KAFKA-1527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073830#comment-14073830 ] Raul Castro Fernandez commented on KAFKA-1527: -- Created reviewboard https://r

Review Request 23906: Patch for KAFKA-1527

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

Review Request 23905: Patch for KAFKA-1527

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

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

[ https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073666#comment-14073666 ] Joe Stein edited comment on KAFKA-1419 at 7/24/14 9:15 PM: --- Than

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

[ https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073666#comment-14073666 ] Joe Stein commented on KAFKA-1419: -- Thanks [~joecrobak] for the feedback/review. Yes, we

[jira] [Commented] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073665#comment-14073665 ] Jon Bringhurst commented on KAFKA-1070: --- [~clarkhaskins], [~sriharsha], having Reser

[jira] [Comment Edited] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073665#comment-14073665 ] Jon Bringhurst edited comment on KAFKA-1070 at 7/24/14 9:16 PM:

[jira] [Commented] (KAFKA-1399) Drop Scala 2.8.x support

[ https://issues.apache.org/jira/browse/KAFKA-1399?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073661#comment-14073661 ] Joe Stein commented on KAFKA-1399: -- +1 to drop scala 2.8 support, lets do it in the chang

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

[ https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073651#comment-14073651 ] Joe Crobak commented on KAFKA-1419: --- I tried out this patch earlier today, and I have a

[jira] [Commented] (KAFKA-1414) Speedup broker startup after hard reset

[ https://issues.apache.org/jira/browse/KAFKA-1414?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073649#comment-14073649 ] Anton Karamanov commented on KAFKA-1414: So what about the last version of a patch

[jira] [Commented] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073563#comment-14073563 ] Clark Haskins commented on KAFKA-1070: -- We currently have node IDs in the 0-1 ran

[jira] Subscription: outstanding kafka patches

Issue Subscription Filter: outstanding kafka patches (111 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-1550 Patch review tool should use git format-patch to generate patch https://issues.apache.org/jira/browse/KAFKA-1550 KAFKA-

[jira] [Commented] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073478#comment-14073478 ] Guozhang Wang commented on KAFKA-1211: -- What I meant is that the ack=-1 should be alr

[jira] [Commented] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073449#comment-14073449 ] Jun Rao commented on KAFKA-1211: The issue is that this problem not only affects ack>1, bu

[jira] [Commented] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073422#comment-14073422 ] Guozhang Wang commented on KAFKA-1211: -- Jun, I think in your review of KAFKA-1430's p

[jira] [Updated] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1211: --- Fix Version/s: 0.9.0 > Hold the produce request with ack > 1 in purgatory until replicas' HW has > larger th

[jira] [Commented] (KAFKA-328) Write unit test for kafka server startup and shutdown API

[ https://issues.apache.org/jira/browse/KAFKA-328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073400#comment-14073400 ] Balaji Seshadri commented on KAFKA-328: --- [~nehanarkhede] i didnot see any such unit t

[jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication

[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073394#comment-14073394 ] Guozhang Wang commented on KAFKA-42: I think this is just due to the review-tool, which

[jira] [Commented] (KAFKA-328) Write unit test for kafka server startup and shutdown API

[ https://issues.apache.org/jira/browse/KAFKA-328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073391#comment-14073391 ] Balaji Seshadri commented on KAFKA-328: --- [~nehanarkhede] can you please advise on my

[jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication

[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073383#comment-14073383 ] Jun Rao commented on KAFKA-42: -- This jira is already closed. Is the patch for this jira? > Sup

[jira] [Commented] (KAFKA-1476) Get a list of consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073374#comment-14073374 ] Balaji Seshadri commented on KAFKA-1476: Hi [~neha.narkh...@gmail.com], Looks li

[jira] [Comment Edited] (KAFKA-1476) Get a list of consumer groups

[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073374#comment-14073374 ] Balaji Seshadri edited comment on KAFKA-1476 at 7/24/14 4:50 PM: ---

[jira] [Comment Edited] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073346#comment-14073346 ] Jun Rao edited comment on KAFKA-1211 at 7/24/14 4:34 PM: - Yes, thi

[jira] [Comment Edited] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073346#comment-14073346 ] Jun Rao edited comment on KAFKA-1211 at 7/24/14 4:32 PM: - Yes, thi

[jira] [Comment Edited] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073346#comment-14073346 ] Jun Rao edited comment on KAFKA-1211 at 7/24/14 4:30 PM: - Yes, thi

[jira] [Resolved] (KAFKA-1150) Fetch on a replicated topic does not return as soon as possible

[ https://issues.apache.org/jira/browse/KAFKA-1150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-1150. -- Resolution: Duplicate > Fetch on a replicated topic does not return as soon as possible > -

[jira] [Commented] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073346#comment-14073346 ] Jun Rao commented on KAFKA-1211: Yes, this is a potential problem. Waiting for HW to be pr

[jira] [Updated] (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 ] Ivan Lyutov updated KAFKA-1419: --- Attachment: KAFKA-1419.patch > cross build for scala 2.11 > -- > >

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

[ https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073337#comment-14073337 ] Ivan Lyutov commented on KAFKA-1419: Created reviewboard https://reviews.apache.org/r/

Review Request 23895: Patch for KAFKA-1419

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

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073326#comment-14073326 ] Sudarshan Kadambi commented on KAFKA-1555: -- Neha and Jun: I want to make sure we

[jira] [Commented] (KAFKA-42) Support rebalancing the partitions with replication

[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073298#comment-14073298 ] Ivan Lyutov commented on KAFKA-42: -- Updated reviewboard against branch apache/0.8.1 > Sup

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

[ https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073300#comment-14073300 ] Ivan Lyutov commented on KAFKA-1419: Created reviewboard against branch apache/0.8.1

[jira] [Updated] (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 ] Ivan Lyutov updated KAFKA-1419: --- Attachment: KAFKA-1419.patch > cross build for scala 2.11 > -- > >

[jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication

[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Lyutov updated KAFKA-42: - Attachment: KAFKA-42_2014-07-24_15:37:26.patch > Support rebalancing the partitions with replication >

[jira] [Updated] (KAFKA-42) Support rebalancing the partitions with replication

[ https://issues.apache.org/jira/browse/KAFKA-42?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Lyutov updated KAFKA-42: - Attachment: KAFKA-42_2014-07-24_15:36:04.patch > Support rebalancing the partitions with replication >

Re: Review Request 23858: Patch for KAFKA-1544

> On July 23, 2014, 4:56 p.m., Jay Kreps wrote: > > Is this better than using a condition? I was imagining replacing sleep with > > shutdownCondition.await(backoffMs, TimeUnit.MILLISECONDS) and then in > > shutdown() we call shutdownCondition.signal(). > > Jay Kreps wrote: > Actually a con

[jira] [Commented] (KAFKA-1544) LogCleaner may take a long time to shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073282#comment-14073282 ] Manikumar Reddy commented on KAFKA-1544: Updated reviewboard https://reviews.apach

[jira] [Updated] (KAFKA-1544) LogCleaner may take a long time to shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-1544: --- Attachment: KAFKA-1544_2014-07-24_20:38:52.patch > LogCleaner may take a long time to shutdow

Re: Review Request 23858: Patch for KAFKA-1544

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/23858/ --- (Updated July 24, 2014, 3:11 p.m.) Review request for kafka. Bugs: KAFKA-1544

Re: Gradle hanging on unit test run against ProducerFailureHangingTest->testBrokerFailure

Hi Dave, KAFKA-1533 has just been committed targeting at this issue. Did your update on trunk include this commit? commit ff05e9b3616a222e29a42f6e8fdf41945a417f41 Author: Guozhang Wang Date: Tue Jul 22 14:14:19 2014 -0700 Guozhang kafka-1533; transient unit test failure in ProducerFailur

[jira] [Commented] (KAFKA-1150) Fetch on a replicated topic does not return as soon as possible

[ https://issues.apache.org/jira/browse/KAFKA-1150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073276#comment-14073276 ] Guozhang Wang commented on KAFKA-1150: -- Awesome! > Fetch on a replicated topic does

Gradle hanging on unit test run against ProducerFailureHangingTest->testBrokerFailure

Hey all, I'm trying my hand at writing some patches for open issues, but I'm running into issues with running gradlew test. It hangs every time when trying to run testBrokerFailure in the ProducerFailureHangingTest suite. It was working for a time, but I updated to trunk HEAD and it's no longer wo

[jira] [Commented] (KAFKA-1150) Fetch on a replicated topic does not return as soon as possible

[ https://issues.apache.org/jira/browse/KAFKA-1150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14073025#comment-14073025 ] Simon Cooper commented on KAFKA-1150: - Yes, I built a replicated system with the patch

[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=14072913#comment-14072913 ] Nicolae Marasoiu commented on KAFKA-1510: - [~jjkoshy] Yes I am going to tackle thi

[jira] [Commented] (KAFKA-1029) Zookeeper leader election stuck in ephemeral node retry loop

[ https://issues.apache.org/jira/browse/KAFKA-1029?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14072905#comment-14072905 ] vincent ye commented on KAFKA-1029: --- I think the problem is because registerSessionExpir