[jira] [Commented] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

[ https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14156057#comment-14156057 ] Neha Narkhede commented on KAFKA-1664: -- +1 on providing a more meaningful e

[jira] [Updated] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

[ https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1664: - Reviewer: Neha Narkhede > Kafka does not properly parse multiple ZK nodes with non-root chr

[jira] [Updated] (KAFKA-1664) Kafka does not properly parse multiple ZK nodes with non-root chroot

[ https://issues.apache.org/jira/browse/KAFKA-1664?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1664: - Labels: newbie (was: ) > Kafka does not properly parse multiple ZK nodes with non-root chr

[jira] [Updated] (KAFKA-1663) Controller unable to shutdown after a soft failure

[ https://issues.apache.org/jira/browse/KAFKA-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1663: - Priority: Blocker (was: Major) > Controller unable to shutdown after a soft fail

[jira] [Updated] (KAFKA-1663) Controller unable to shutdown after a soft failure

[ https://issues.apache.org/jira/browse/KAFKA-1663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1663: - Fix Version/s: 0.8.2 > Controller unable to shutdown after a soft fail

Re: LeaderNotAvailableException, although leader elected

Andras, Thanks for your feedback! In my opinion programmatic message sending must work out of the box on the first try, without any exceptions, warnings or the need for additional configuration. I'd be glad to support/contribute. I agree that the behavior of the producer for the first message o

[jira] [Commented] (KAFKA-1634) Update protocol wiki to reflect the new offset management feature

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154867#comment-14154867 ] Neha Narkhede commented on KAFKA-1634: -- [~jjkoshy] Thanks for the explanation

[jira] [Commented] (KAFKA-1558) AdminUtils.deleteTopic does not work

[ https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14154862#comment-14154862 ] Neha Narkhede commented on KAFKA-1558: -- [~sriharsha] Controller's inabili

[jira] [Updated] (KAFKA-1661) Move MockConsumer and MockProducer from src/main to src/test

[ https://issues.apache.org/jira/browse/KAFKA-1661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1661: - Reviewer: Neha Narkhede Assignee: (was: Neha Narkhede) [~Andras Hatvani] Feel free to

[jira] [Updated] (KAFKA-1661) Move MockConsumer and MockProducer from src/main to src/test

[ https://issues.apache.org/jira/browse/KAFKA-1661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1661: - Labels: newbie test (was: test) > Move MockConsumer and MockProducer from src/main to src/t

[jira] [Updated] (KAFKA-1661) Move MockConsumer and MockProducer from src/main to src/test

[ https://issues.apache.org/jira/browse/KAFKA-1661?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1661: - Priority: Trivial (was: Major) > Move MockConsumer and MockProducer from src/main to src/t

Re: [DISCUSS] 0.8.1.2 Release

Can we discuss the need for 0.8.1.2? I'm wondering if it's related to the timeline of 0.8.2 in any way? For instance, if we can get 0.8.2 out in the next 2-3 weeks, do we still need to get 0.8.1.2 out or can people just upgrade to 0.8.2? On Tue, Sep 30, 2014 at 9:53 AM, Joe Stein wrote: > Hi, I

[jira] [Commented] (KAFKA-1558) AdminUtils.deleteTopic does not work

[ https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14153631#comment-14153631 ] Neha Narkhede commented on KAFKA-1558: -- [~sriharsha] Thanks for running more t

[jira] [Commented] (KAFKA-1305) Controller can hang on controlled shutdown with auto leader balance enabled

[ https://issues.apache.org/jira/browse/KAFKA-1305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14152743#comment-14152743 ] Neha Narkhede commented on KAFKA-1305: -- This is a good but potentially very l

[jira] [Updated] (KAFKA-1656) "replica-assignment" option in "bin/kakfa-topics.sh" doesn't work with "alter"

[ https://issues.apache.org/jira/browse/KAFKA-1656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1656: - Labels: newbie (was: ) > "replica-assignment" option in "bin/kakfa-topics.sh&

[jira] [Updated] (KAFKA-1647) Replication offset checkpoints (high water marks) can be lost on hard kills and restarts

[ https://issues.apache.org/jira/browse/KAFKA-1647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1647: - Affects Version/s: 0.8.2 > Replication offset checkpoints (high water marks) can be lost on h

[jira] [Commented] (KAFKA-1634) Update protocol wiki to reflect the new offset management feature

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14152044#comment-14152044 ] Neha Narkhede commented on KAFKA-1634: -- Basically, I'm not sure this is g

[jira] [Updated] (KAFKA-1655) Allow high performance SimpleConsumer use cases to still work with new Kafka 0.9 consumer APIs

[ https://issues.apache.org/jira/browse/KAFKA-1655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1655: - Reviewer: Neha Narkhede Assignee: (was: Neha Narkhede) > Allow high performa

Re: [DISCUSS] 0.8.2 release branch, "unofficial" release candidates(s), 0.8.1.2 release

t; Twitter: @allthingshadoop <http://www.twitter.com/allthingshadoop> > ****/ > > On Mon, Sep 29, 2014 at 11:00 AM, Neha Narkhede > wrote: > > > Thanks for making a pass of the open issues, Jun. I agree that it's not > > wort

Re: [DISCUSS] 0.8.2 release branch, "unofficial" release candidates(s), 0.8.1.2 release

Thanks for making a pass of the open issues, Jun. I agree that it's not worth blocking 0.8.2 more and we can push auto preferred replica election to 0.8.3. I'm a +1 on cutting the branch. On Sun, Sep 28, 2014 at 6:03 PM, Jun Rao wrote: > Hi, everyone, > > I made another pass of the blockers for

Re: Review Request 26107: Patch for KAFKA-1577

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26107/#review54755 --- Ship it! Ship It! - Neha Narkhede On Sept. 26, 2014, 10:41 p.m

[jira] [Updated] (KAFKA-1618) Exception thrown when running console producer with no port number for the broker

[ https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1618: - Resolution: Fixed Reviewer: Neha Narkhede (was: Joe Stein) Status: Resolved (was

[jira] [Commented] (KAFKA-1618) Exception thrown when running console producer with no port number for the broker

[ https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14150114#comment-14150114 ] Neha Narkhede commented on KAFKA-1618: -- +1 on your latest patch! > Exception

[jira] [Commented] (KAFKA-1647) Replication offset checkpoints (high water marks) can be lost on hard kills and restarts

[ https://issues.apache.org/jira/browse/KAFKA-1647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14150021#comment-14150021 ] Neha Narkhede commented on KAFKA-1647: -- [~jjkoshy] Makes sense, thanks for

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

[ https://issues.apache.org/jira/browse/KAFKA-1586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1586. -- Resolution: Won't Fix > support sticky partitioning in the new

[jira] [Commented] (KAFKA-1654) Provide a way to override server configuration from command line

[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1414#comment-1414 ] Neha Narkhede commented on KAFKA-1654: -- Yes, I think that's useful. Would

[jira] [Updated] (KAFKA-1654) Provide a way to override server configuration from command line

[ https://issues.apache.org/jira/browse/KAFKA-1654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1654: - Reviewer: Neha Narkhede > Provide a way to override server configuration from command l

[jira] [Commented] (KAFKA-1577) Exception in ConnectionQuotas while shutting down

[ https://issues.apache.org/jira/browse/KAFKA-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14149966#comment-14149966 ] Neha Narkhede commented on KAFKA-1577: -- [~jjkoshy], [~sriharsha] I remember I t

[jira] [Commented] (KAFKA-1577) Exception in ConnectionQuotas while shutting down

[ https://issues.apache.org/jira/browse/KAFKA-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14149871#comment-14149871 ] Neha Narkhede commented on KAFKA-1577: -- [~jjkoshy] I could also reproduce the

[jira] [Commented] (KAFKA-1652) NoSuchElementException on server shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14149783#comment-14149783 ] Neha Narkhede commented on KAFKA-1652: -- Thanks [~sriharsha]. Appreciate the fo

[jira] [Updated] (KAFKA-1591) Clean-up Unnecessary stack trace in error/warn logs

[ https://issues.apache.org/jira/browse/KAFKA-1591?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1591: - Reviewer: Jun Rao [~junrao], please feel free to reassign :) Going through JIRAs that have

[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=14148735#comment-14148735 ] Neha Narkhede commented on KAFKA-1586: -- +1 on not supporting sticky partitio

[jira] [Updated] (KAFKA-589) Clean shutdown after startup connection failure

[ https://issues.apache.org/jira/browse/KAFKA-589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-589: Assignee: Ewen Cheslack-Postava (was: Swapnil Ghike) > Clean shutdown after startup connect

[jira] [Commented] (KAFKA-589) Clean shutdown after startup connection failure

[ https://issues.apache.org/jira/browse/KAFKA-589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14148726#comment-14148726 ] Neha Narkhede commented on KAFKA-589: - Thanks for fixing a longstanding bug! +1 on

[jira] [Updated] (KAFKA-589) Clean shutdown after startup connection failure

[ https://issues.apache.org/jira/browse/KAFKA-589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-589: Resolution: Fixed Status: Resolved (was: Patch Available) Pushed to trunk > Clean shutd

[jira] [Commented] (KAFKA-1647) Replication offset checkpoints (high water marks) can be lost on hard kills and restarts

[ https://issues.apache.org/jira/browse/KAFKA-1647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14148702#comment-14148702 ] Neha Narkhede commented on KAFKA-1647: -- I see. So for this to lose all the data

[jira] [Updated] (KAFKA-1653) Duplicate broker ids allowed in replica assignment

[ https://issues.apache.org/jira/browse/KAFKA-1653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1653: - Labels: newbie (was: ) > Duplicate broker ids allowed in replica assignm

[jira] [Commented] (KAFKA-1652) NoSuchElementException on server shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1652?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14148698#comment-14148698 ] Neha Narkhede commented on KAFKA-1652: -- [~jjkoshy] I saw this on trunk a

[jira] [Resolved] (KAFKA-1652) NoSuchElementException on server shutdown

[ https://issues.apache.org/jira/browse/KAFKA-1652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1652. -- Resolution: Duplicate > NoSuchElementException on server shutd

[jira] [Reopened] (KAFKA-1577) Exception in ConnectionQuotas while shutting down

[ https://issues.apache.org/jira/browse/KAFKA-1577?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reopened KAFKA-1577: -- See KAFKA-1652 > Exception in ConnectionQuotas while shutting d

Re: Review Request 25886: KAFKA-1555: provide strong consistency with reasonable availability

ere. Could you please add a description? - Neha Narkhede On Sept. 25, 2014, 7:41 p.m., Gwen Shapira wrote: > > --- > This is an automatically generated e-mail. To reply, visit: > h

[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=14148557#comment-14148557 ] Neha Narkhede commented on KAFKA-1555: -- Followed the discussion and want to s

[jira] [Commented] (KAFKA-1647) Replication offset checkpoints (high water marks) can be lost on hard kills and restarts

[ https://issues.apache.org/jira/browse/KAFKA-1647?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14148301#comment-14148301 ] Neha Narkhede commented on KAFKA-1647: -- [~jjkoshy] Sounds like a problem. I ha

[jira] [Updated] (KAFKA-1647) Replication offset checkpoints (high water marks) can be lost on hard kills and restarts

[ https://issues.apache.org/jira/browse/KAFKA-1647?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1647: - Priority: Critical (was: Major) > Replication offset checkpoints (high water marks) can be l

[jira] [Updated] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist

[ https://issues.apache.org/jira/browse/KAFKA-404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-404: Assignee: Jonathan Creasy > When using chroot path, create chroot on startup if it doesn'

[jira] [Closed] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist

[ https://issues.apache.org/jira/browse/KAFKA-404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-404. --- > When using chroot path, create chroot on startup if it doesn'

[jira] [Updated] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist

[ https://issues.apache.org/jira/browse/KAFKA-404?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-404: Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the patches, pushed to

[jira] [Created] (KAFKA-1652) NoSuchElementException on server shutdown

Neha Narkhede created KAFKA-1652: Summary: NoSuchElementException on server shutdown Key: KAFKA-1652 URL: https://issues.apache.org/jira/browse/KAFKA-1652 Project: Kafka Issue Type: Bug

Re: Review Request 26019: Patch for KAFKA-404

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26019/#review54581 --- Ship it! Ship It! - Neha Narkhede On Sept. 25, 2014, 6:11 p.m

[jira] [Updated] (KAFKA-1651) Removed some extra whitespace in KafkaServer.scala

[ https://issues.apache.org/jira/browse/KAFKA-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1651: - Reviewer: Neha Narkhede > Removed some extra whitespace in KafkaServer.sc

[jira] [Commented] (KAFKA-1651) Removed some extra whitespace in KafkaServer.scala

[ https://issues.apache.org/jira/browse/KAFKA-1651?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14148174#comment-14148174 ] Neha Narkhede commented on KAFKA-1651: -- [~jcreasy] How did you come across t

Re: Review Request 26020: Patch for KAFKA-1651

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26020/#review54579 --- Ship it! Ship It! - Neha Narkhede On Sept. 25, 2014, 5:50 a.m

Re: Can Fetch Request cause delay of Produce Request?

"The server guarantees that on a single TCP connection, requests will be processed in the order they are sent and responses will return in that order as well" But to achieve proper functioning of the client, I need to allocate another tcp connection for listeners now? Yes. The easiest way to

[jira] [Commented] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist

[ https://issues.apache.org/jira/browse/KAFKA-404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14148140#comment-14148140 ] Neha Narkhede commented on KAFKA-404: - Your suggestion about consolidation is

Re: Review Request 26018: Patch for KAFKA-404

<https://reviews.apache.org/r/26018/#comment94745> Thanks for adding this test. It's probably worth consolidating some of our tests on server startup and shutdown. Can we rename ServerShutdownTest to ServerStartupAndShutdownTest and move this test there? - Neha Narkhede On Sept.

[jira] [Commented] (KAFKA-1618) Exception thrown when running console producer with no port number for the broker

[ https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14148024#comment-14148024 ] Neha Narkhede commented on KAFKA-1618: -- [~balaji.sesha...@dish.com] I ran

Re: KAFKA-404 and KAFKA-1651

We only appreciate new contributions and don't mind going through a contributor on boarding process. In fact, I'd encourage you to give feedback on how we could improve your experience as a contributor :-) We are trying to improve the turnaround time on patch reviews. Hopefully assigning a Reviewe

[jira] [Commented] (KAFKA-1367) Broker topic metadata not kept in sync with ZooKeeper

[ https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14147377#comment-14147377 ] Neha Narkhede commented on KAFKA-1367: -- bq. I definitely agree with Magnus Eden

[jira] [Updated] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1646: - Labels: newbie patch (was: patch) > Improve consumer read performance for Wind

[jira] [Updated] (KAFKA-1646) Improve consumer read performance for Windows

[ https://issues.apache.org/jira/browse/KAFKA-1646?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1646: - Assignee: (was: Jay Kreps) > Improve consumer read performance for Wind

[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=14147374#comment-14147374 ] Neha Narkhede commented on KAFKA-328: - Thanks for the patch, [~balaji.s

[jira] [Updated] (KAFKA-1648) Round robin consumer balance throws an NPE when there are no topics

[ https://issues.apache.org/jira/browse/KAFKA-1648?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1648: - Reviewer: Joel Koshy Assigning this to Joel for review as he probably has the most context on

[jira] [Commented] (KAFKA-1634) Update protocol wiki to reflect the new offset management feature

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14147368#comment-14147368 ] Neha Narkhede commented on KAFKA-1634: -- How general is that use case and if it

[jira] [Commented] (KAFKA-1618) Exception thrown when running console producer with no port number for the broker

[ https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14147365#comment-14147365 ] Neha Narkhede commented on KAFKA-1618: -- Thanks for the patch, though I coul

[jira] [Commented] (KAFKA-404) When using chroot path, create chroot on startup if it doesn't exist

[ https://issues.apache.org/jira/browse/KAFKA-404?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14147362#comment-14147362 ] Neha Narkhede commented on KAFKA-404: - Thanks for the latest patch. I think there

[jira] [Commented] (KAFKA-1611) Improve system test configuration

[ https://issues.apache.org/jira/browse/KAFKA-1611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14147335#comment-14147335 ] Neha Narkhede commented on KAFKA-1611: -- Thanks [~gwenshap] > Improve syst

[jira] [Closed] (KAFKA-1611) Improve system test configuration

[ https://issues.apache.org/jira/browse/KAFKA-1611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1611. > Improve system test configuration > - > >

[jira] [Closed] (KAFKA-1649) Protocol documentation does not indicate that ReplicaNotAvailable can be ignored

[ https://issues.apache.org/jira/browse/KAFKA-1649?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1649. > Protocol documentation does not indicate that ReplicaNotAvailable can be > i

[jira] [Updated] (KAFKA-1645) some more jars in our src release

[ https://issues.apache.org/jira/browse/KAFKA-1645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1645: - Reviewer: Jun Rao > some more jars in our src rele

[jira] [Updated] (KAFKA-1019) kafka-preferred-replica-election.sh will fail without clear error message if /brokers/topics/[topic]/partitions does not exist

[ https://issues.apache.org/jira/browse/KAFKA-1019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1019: - Reviewer: Neha Narkhede > kafka-preferred-replica-election.sh will fail without clear er

[jira] [Commented] (KAFKA-1019) kafka-preferred-replica-election.sh will fail without clear error message if /brokers/topics/[topic]/partitions does not exist

[ https://issues.apache.org/jira/browse/KAFKA-1019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14147244#comment-14147244 ] Neha Narkhede commented on KAFKA-1019: -- Thanks for checking, [~sriharsha]. I wo

[jira] [Commented] (KAFKA-1618) Exception thrown when running console producer with no port number for the broker

[ https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14147241#comment-14147241 ] Neha Narkhede commented on KAFKA-1618: -- Thanks for the latest patch, [~balaji.s

Re: Review Request 25944: Patch for KAFKA-1013

single tool? We already have https://issues.apache.org/jira/browse/KAFKA-1476 filed to consolidate tools and it will be great to not create too many redundant tools. - Neha Narkhede On Sept. 23, 2014, 5:48 p.m., Mayuresh Gharat wrote

[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=14147189#comment-14147189 ] Neha Narkhede commented on KAFKA-1476: -- [~balaji.sesha...@dish.com] Wondering if

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

[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1555: - Reviewer: Jun Rao > provide strong consistency with reasonable availabil

[jira] [Commented] (KAFKA-1034) Improve partition reassignment to optimize writes to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-1034?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14143326#comment-14143326 ] Neha Narkhede commented on KAFKA-1034: -- We need to move to batch ZK writes whic

[jira] [Resolved] (KAFKA-1034) Improve partition reassignment to optimize writes to zookeeper

[ https://issues.apache.org/jira/browse/KAFKA-1034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1034. -- Resolution: Won't Fix > Improve partition reassignment to optimize writes to z

[jira] [Commented] (KAFKA-1558) AdminUtils.deleteTopic does not work

[ https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14142481#comment-14142481 ] Neha Narkhede commented on KAFKA-1558: -- This is great, [~sriharsha]. Thanks

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14142199#comment-14142199 ] Neha Narkhede commented on KAFKA-1282: -- Pushed the latest patch to t

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14142174#comment-14142174 ] Neha Narkhede commented on KAFKA-1282: -- +1 on your latest patch. I'm leanin

[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=14142171#comment-14142171 ] Neha Narkhede commented on KAFKA-328: - Ping [~balaji.sesha...@dish.com] > Wri

[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=14142170#comment-14142170 ] Neha Narkhede commented on KAFKA-1476: -- [~balaji.sesha...@dish.com],for #1

[jira] [Updated] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group

[ https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1637: - Labels: newbie (was: ) > SimpleConsumer.fetchOffset returns wrong error code when no off

[jira] [Updated] (KAFKA-1637) SimpleConsumer.fetchOffset returns wrong error code when no offset exists for topic/partition/consumer group

[ https://issues.apache.org/jira/browse/KAFKA-1637?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1637: - Assignee: (was: Neha Narkhede) > SimpleConsumer.fetchOffset returns wrong error code when

[jira] [Commented] (KAFKA-1618) Exception thrown when running console producer with no port number for the broker

[ https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14142168#comment-14142168 ] Neha Narkhede commented on KAFKA-1618: -- Thanks for the patch, [~balaji.s

[jira] [Reopened] (KAFKA-1634) Update protocol wiki to reflect the new offset management feature

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reopened KAFKA-1634: -- Assignee: Jun Rao (was: Joel Koshy) Reopening until we have filed a JIRA to fix the issue

[jira] [Commented] (KAFKA-1634) Update protocol wiki to reflect the new offset management feature

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14142161#comment-14142161 ] Neha Narkhede commented on KAFKA-1634: -- [~junrao], that explanation is actu

[jira] [Updated] (KAFKA-1054) Eliminate Compilation Warnings for 0.8 Final Release

[ https://issues.apache.org/jira/browse/KAFKA-1054?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1054: - Reviewer: Neha Narkhede > Eliminate Compilation Warnings for 0.8 Final Rele

[jira] [Commented] (KAFKA-1558) AdminUtils.deleteTopic does not work

[ https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14138979#comment-14138979 ] Neha Narkhede commented on KAFKA-1558: -- [~sriharsha] Delete topic shouldn&

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14138972#comment-14138972 ] Neha Narkhede commented on KAFKA-1282: -- Thanks for the updated patch. Overall, l

Re: [Java New Producer] CPU Usage Spike to 100% when network connection is lost

This seems like a problem. Please can you file a JIRA and attach the log4j output there? On Wed, Sep 17, 2014 at 2:14 PM, Bhavesh Mistry wrote: > Hi Kafka Dev team, > > I see my CPU spike to 100% when network connection is lost for while. It > seems network IO thread are very busy logging foll

[jira] [Updated] (KAFKA-1638) transient unit test failure UncleanLeaderElectionTest

[ https://issues.apache.org/jira/browse/KAFKA-1638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1638: - Labels: newbie++ (was: ) > transient unit test failure UncleanLeaderElectionT

[jira] [Commented] (KAFKA-1618) Exception thrown when running console producer with no port number for the broker

[ https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14138359#comment-14138359 ] Neha Narkhede commented on KAFKA-1618: -- Agree with [~gwenshap] that whichever wa

Re: kafka 0.8.1: Producer.send() can block forever when a broker is down

Make sense. Please file a JIRA and attach a patch there. It will be great to add a simple test case as well. Thanks, Neha On Wed, Sep 17, 2014 at 8:25 AM, Jonathan Weeks Gmail < jonathanbwe...@gmail.com> wrote: > > The issue is that even with one down broker, the rest of the cluster is > up, but

[jira] [Updated] (KAFKA-1490) remove gradlew initial setup output from source distribution

[ https://issues.apache.org/jira/browse/KAFKA-1490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1490: - Reviewer: Joe Stein > remove gradlew initial setup output from source distribut

[jira] [Resolved] (KAFKA-1597) New metrics: ResponseQueueSize and BeingSentResponses

[ https://issues.apache.org/jira/browse/KAFKA-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1597. -- Resolution: Fixed Pushed to trunk > New metrics: ResponseQueueSize and BeingSentRespon

[jira] [Updated] (KAFKA-1597) New metrics: ResponseQueueSize and BeingSentResponses

[ https://issues.apache.org/jira/browse/KAFKA-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1597: - Assignee: Alexis Midon > New metrics: ResponseQueueSize and BeingSentRespon

[jira] [Updated] (KAFKA-1597) New metrics: ResponseQueueSize and BeingSentResponses

[ https://issues.apache.org/jira/browse/KAFKA-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1597: - Reviewer: Neha Narkhede > New metrics: ResponseQueueSize and BeingSentRespon

[jira] [Commented] (KAFKA-1597) New metrics: ResponseQueueSize and BeingSentResponses

[ https://issues.apache.org/jira/browse/KAFKA-1597?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14134900#comment-14134900 ] Neha Narkhede commented on KAFKA-1597: -- +1. Thanks for the updated patch. &

[jira] [Commented] (KAFKA-1618) Exception thrown when running console producer with no port number for the broker

[ https://issues.apache.org/jira/browse/KAFKA-1618?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14134883#comment-14134883 ] Neha Narkhede commented on KAFKA-1618: -- [~gwenshap] The tools that ship with K

<    5   6   7   8   9   10   11   12   13   14   >