[jira] [Resolved] (KAFKA-1707) ConsumerOffsetChecker shows none partitions assigned

[ https://issues.apache.org/jira/browse/KAFKA-1707?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1707. -- Resolution: Won't Fix This is a known issue but there are a few things to check. Did yo

Re: [DISCUSS] Release 0.8.2-beta before 0.8.2?

2. Do people want to include any JIRAs (other than the ones mentioned above) in 0.8.2-beta? If so, it will be great to know now so it will allow us to move forward with the beta release quickly. Thanks, Neha On Wed, Oct 15, 2014 at 4:46 PM, Neha Narkhede wrote: > Hi, > > We have

[jira] [Updated] (KAFKA-1506) Cancel "kafka-reassign-partitions" Job

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

[jira] [Updated] (KAFKA-1506) Cancel "kafka-reassign-partitions" Job

[ https://issues.apache.org/jira/browse/KAFKA-1506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1506: - Labels: newbie++ (was: ) > Cancel "kafka-reassign-partiti

[DISCUSS] Release 0.8.2-beta before 0.8.2?

Hi, We have accumulated an impressive list of pretty major features in 0.8.2 - Delete topic Automated leader rebalancing Controlled shutdown Offset management Parallel recovery min.isr and clean leader election In the past, what has worked for major feature releases is a beta release prior to a f

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14172968#comment-14172968 ] Neha Narkhede commented on KAFKA-1637: -- [~ewencp] Your latest patch looks good.

Re: Review Request 26663: Patch for KAFKA-979

one enabling it to understand the implications. > I personally think the final option that causes the average time to be > config.segmentMs is most intuitive, but as long as the effect is clearly > documented they are all effectively equivalent assuming uniform sampling. > > Neha

Re: Review Request 26663: Patch for KAFKA-979

> On Oct. 15, 2014, 4:19 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/log/Log.scala, line 515 > > > > > > Thinking about this a bit more: do you think it would be safer to > > interpret jitter as an additive

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14172372#comment-14172372 ] Neha Narkhede commented on KAFKA-1637: -- Wups. Didn't mean to push the patch

Re: Review Request 26710: Patch for KAFKA-1637

> On Oct. 15, 2014, 5:22 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/server/KafkaApis.scala, line 510 > > > > > > There is an issue here. The replica manager only contains information > > about partitions th

Re: Review Request 26710: Patch for KAFKA-1637

tps://reviews.apache.org/r/26710/#comment97084> I think it's better to use the metadata cache here. - Neha Narkhede On Oct. 14, 2014, 10:04 p.m., Ewen Cheslack-Postava wrote: > > --- > This is an automatically generated e-m

[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: - Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the patch. Pushed

[jira] [Updated] (KAFKA-1698) Validator.ensureValid() only validates default config value

[ https://issues.apache.org/jira/browse/KAFKA-1698?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1698: - Reviewer: Jun Rao > Validator.ensureValid() only validates default config va

Re: Review Request 26710: Patch for KAFKA-1637

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26710/#review56655 --- Ship it! Ship It! - Neha Narkhede On Oct. 14, 2014, 10:04 p.m

[jira] [Updated] (KAFKA-979) Add jitter for time based rolling

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

Re: Review Request 26663: Patch for KAFKA-979

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26663/#review56650 --- Ship it! Ship It! - Neha Narkhede On Oct. 14, 2014, 10:33 p.m

Re: Review Request 26663: Patch for KAFKA-979

to > > recompute a random jitter for each new rolled segment. What do you think? > > Neha Narkhede wrote: > Only one segment should ever roll at one time in a log. So this should > suffice right? > > Joel Koshy wrote: > Yes, but there could be one segment each

[jira] [Updated] (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:all-tabpanel ] Neha Narkhede updated KAFKA-1481: - Reviewer: Jun Rao > Stop using dashes AND underscores as separators in MBean na

[jira] [Updated] (KAFKA-560) Garbage Collect obsolete topics

[ https://issues.apache.org/jira/browse/KAFKA-560?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-560: Reviewer: Neha Narkhede > Garbage Collect obsolete top

[jira] [Updated] (KAFKA-566) Add last modified time to the TopicMetadataRequest

[ https://issues.apache.org/jira/browse/KAFKA-566?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-566: Reviewer: Neha Narkhede > Add last modified time to the TopicMetadataRequ

[jira] [Commented] (KAFKA-566) Add last modified time to the TopicMetadataRequest

[ https://issues.apache.org/jira/browse/KAFKA-566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14171531#comment-14171531 ] Neha Narkhede commented on KAFKA-566: - [~sriharsha] Thanks for taking this on. &

Re: Review Request 26663: Patch for KAFKA-979

to > > recompute a random jitter for each new rolled segment. What do you think? > > Neha Narkhede wrote: > Only one segment should ever roll at one time in a log. So this should > suffice right? > > Joel Koshy wrote: > Yes, but there could be one segment each

Re: Review Request 26663: Patch for KAFKA-979

> On Oct. 14, 2014, 6:27 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/log/Log.scala, line 515 > > > > > > Although this should work I'm wondering if it would be better to > > recompute a random jitter for eac

[jira] [Updated] (KAFKA-1634) Improve semantics of timestamp in OffsetCommitRequests and update documentation

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1634: - Assignee: Guozhang Wang (was: Joel Koshy) > Improve semantics of timestamp

Re: Review Request 26663: Patch for KAFKA-979

(segmentJitterMs, segmentMs) - Neha Narkhede On Oct. 13, 2014, 11:16 p.m., Ewen Cheslack-Postava wrote: > > --- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache

[jira] [Updated] (KAFKA-1703) The bat script failed to start on windows

[ https://issues.apache.org/jira/browse/KAFKA-1703?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1703: - Labels: newbie (was: ) > The bat script failed to start on wind

[jira] [Updated] (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:all-tabpanel ] Neha Narkhede updated KAFKA-1305: - Resolution: Fixed Status: Resolved (was: Patch Available) > Controller can hang

[jira] [Updated] (KAFKA-1196) java.lang.IllegalArgumentException Buffer.limit on FetchResponse.scala + 33

[ https://issues.apache.org/jira/browse/KAFKA-1196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1196: - Assignee: (was: Neha Narkhede) > java.lang.IllegalArgumentException Buffer.limit

[jira] [Updated] (KAFKA-1631) ReplicationFactor and under-replicated partitions incorrect during reassignment

[ https://issues.apache.org/jira/browse/KAFKA-1631?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1631: - Assignee: Ewen Cheslack-Postava > ReplicationFactor and under-replicated partitions incorr

[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=14169697#comment-14169697 ] Neha Narkhede commented on KAFKA-1305: -- [~sriharsha] Latest patch looks

Re: Review Request 26633: Patch for KAFKA-1305

<https://reviews.apache.org/r/26633/#comment96710> this looks good now. - Neha Narkhede On Oct. 13, 2014, 2:30 p.m., Sriharsha Chintalapani wrote: > > --- > This is an automatically generated e-mail. To reply,

[jira] [Commented] (KAFKA-1277) Keep the summery/description when updating the RB with kafka-patch-review

[ https://issues.apache.org/jira/browse/KAFKA-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14168849#comment-14168849 ] Neha Narkhede commented on KAFKA-1277: -- [~omkreddy] Tried your latest p

Re: Review Request 26564: Patch for KAFKA-1471

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26564/#review56369 --- Ship it! Ship It! - Neha Narkhede On Oct. 12, 2014, 11:02 p.m

Re: Review Request 26564: Patch for KAFKA-1471

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26564/#review56368 --- Ship it! Ship It! - Neha Narkhede On Oct. 12, 2014, 11:02 p.m

[jira] [Comment Edited] (KAFKA-1692) [Java New Producer] IO Thread Name Must include Client ID

[ https://issues.apache.org/jira/browse/KAFKA-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14168831#comment-14168831 ] Neha Narkhede edited comment on KAFKA-1692 at 10/12/14 11:0

[jira] [Updated] (KAFKA-1692) [Java New Producer] IO Thread Name Must include Client ID

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

Re: Review Request 26563: Patch for KAFKA-1692

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26563/#review56366 --- Ship it! Ship It! - Neha Narkhede On Oct. 10, 2014, 5:38 p.m

Re: Review Request 26564: Patch for KAFKA-1471

worth updating PerfConfig as well as MessageTest - Neha Narkhede On Oct. 10, 2014, 5:43 p.m., Ewen Cheslack-Postava wrote: > > --- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache

[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=14168819#comment-14168819 ] Neha Narkhede commented on KAFKA-1305: -- Increasing the queue size by a li

[jira] [Updated] (KAFKA-1680) JmxTool exits if no arguments are given

[ https://issues.apache.org/jira/browse/KAFKA-1680?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1680: - Labels: newbie (was: ) > JmxTool exits if no arguments are gi

[jira] [Updated] (KAFKA-1701) Improve controller and broker message handling.

[ https://issues.apache.org/jira/browse/KAFKA-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1701: - Reviewer: Neha Narkhede > Improve controller and broker message handl

[jira] [Commented] (KAFKA-1634) Improve semantics of timestamp in OffsetCommitRequests and update documentation

[ https://issues.apache.org/jira/browse/KAFKA-1634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14168802#comment-14168802 ] Neha Narkhede commented on KAFKA-1634: -- +1 to your suggestions above. Th

[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=14168692#comment-14168692 ] Neha Narkhede commented on KAFKA-1555: -- bq. My vote would be to update

[jira] [Updated] (KAFKA-559) Garbage collect old consumer metadata entries

[ https://issues.apache.org/jira/browse/KAFKA-559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-559: Reviewer: Neha Narkhede > Garbage collect old consumer metadata entr

[jira] [Updated] (KAFKA-559) Garbage collect old consumer metadata entries

[ https://issues.apache.org/jira/browse/KAFKA-559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-559: Labels: newbie project (was: project) > Garbage collect old consumer metadata entr

Re: Security JIRAS

I'd vote for accepting every major change with the relevant system tests. We didn't do this for major features in the past that lead to weak coverage and a great deal of work for someone else to add tests for features that were done in the past. I'm guilty of this myself :-( On Thu, Oct 9, 2014 at

[jira] [Comment Edited] (KAFKA-1697) remove code related to ack>1 on the broker

[ https://issues.apache.org/jira/browse/KAFKA-1697?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14166144#comment-14166144 ] Neha Narkhede edited comment on KAFKA-1697 at 10/10/14 4:1

Re: Review Request 26560: Patch for KAFKA-1305

tps://reviews.apache.org/r/26560/#comment96475> Weren't we going to make this unbounded? - Neha Narkhede On Oct. 10, 2014, 3:51 p.m., Sriharsha Chintalapani wrote: > > --- > This is an automatically generated e-mail. To r

[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=14167050#comment-14167050 ] Neha Narkhede commented on KAFKA-1305: -- [~junrao], [~sriharsha] What's the

Re: including KAFKA-1555 in 0.8.2?

+1. On Thu, Oct 9, 2014 at 6:41 PM, Jun Rao wrote: > Hi, Everyone, > > I just committed KAFKA-1555 (min.isr support) to trunk. I felt that it's > probably useful to include it in the 0.8.2 release. Any objections? > > Thanks, > > Jun >

[jira] [Updated] (KAFKA-1679) JmxTool outputs nothing if any mbean attributes can't be retrieved

[ https://issues.apache.org/jira/browse/KAFKA-1679?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1679: - Labels: newbie (was: ) > JmxTool outputs nothing if any mbean attributes can't be r

[jira] [Commented] (KAFKA-1678) add new options for reassign partition to better manager dead brokers

[ https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14166115#comment-14166115 ] Neha Narkhede commented on KAFKA-1678: -- I see your point. I agree that once we

[jira] [Commented] (KAFKA-1676) Ability to cancel replica reassignment in progress

[ https://issues.apache.org/jira/browse/KAFKA-1676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14166114#comment-14166114 ] Neha Narkhede commented on KAFKA-1676: -- [~rberdeen], This is simpler to do if i

[jira] [Updated] (KAFKA-1689) automatic migration of log dirs to new locations

[ https://issues.apache.org/jira/browse/KAFKA-1689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1689: - Labels: newbie++ (was: ) > automatic migration of log dirs to new locati

[jira] [Updated] (KAFKA-1692) [Java New Producer] IO Thread Name Must include Client ID

[ https://issues.apache.org/jira/browse/KAFKA-1692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1692: - Labels: newbie (was: ) > [Java New Producer] IO Thread Name Must include Client

Re: Review Request 26291: Patch for KAFKA-1648

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/26291/#review56036 --- Ship it! Ship It! - Neha Narkhede On Oct. 9, 2014, 6:56 p.m

Re: Review Request 26291: Patch for KAFKA-1648

> On Oct. 9, 2014, 6:21 p.m., Neha Narkhede wrote: > > Is this issue covered by a test case? Didn't see one with no topics for a > > wildcard consumer. Ignore that. I see that you modified the partition assignor. - Neha --

Re: Review Request 26291: Patch for KAFKA-1648

opics for a wildcard consumer. - Neha Narkhede On Oct. 9, 2014, 12:46 a.m., Mayuresh Gharat wrote: > > --- > This is an automatically generated e-mail. To reply, visit: > https://reviews.a

[jira] [Commented] (KAFKA-1681) Newly elected KafkaController might not start deletion of pending topics

[ https://issues.apache.org/jira/browse/KAFKA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14165428#comment-14165428 ] Neha Narkhede commented on KAFKA-1681: -- [~sriharsha], sorry for being unclea

[jira] [Commented] (KAFKA-1499) Broker-side compression configuration

[ https://issues.apache.org/jira/browse/KAFKA-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14165421#comment-14165421 ] Neha Narkhede commented on KAFKA-1499: -- bq. We instead have compression.type w

[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=14165410#comment-14165410 ] Neha Narkhede commented on KAFKA-1558: -- [~sriharsha] Those observations are r

[jira] [Commented] (KAFKA-1681) Newly elected KafkaController might not start deletion of pending topics

[ https://issues.apache.org/jira/browse/KAFKA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14165251#comment-14165251 ] Neha Narkhede commented on KAFKA-1681: -- [~sriharsha], adding that to the end of

[jira] [Updated] (KAFKA-1681) Newly elected KafkaController might not start deletion of pending topics

[ https://issues.apache.org/jira/browse/KAFKA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1681: - Reviewer: Neha Narkhede > Newly elected KafkaController might not start deletion of pend

[jira] [Updated] (KAFKA-1681) Newly elected KafkaController might not start deletion of pending topics

[ https://issues.apache.org/jira/browse/KAFKA-1681?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1681: - Fix Version/s: 0.8.2 > Newly elected KafkaController might not start deletion of pending top

[jira] [Reopened] (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 reopened KAFKA-1663: -- [~sriharsha], while talking to Jun, realized that there may have been a regression introduced by

[jira] [Updated] (KAFKA-1678) add new options for reassign partition to better manager dead brokers

[ https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1678: - Reviewer: Neha Narkhede > add new options for reassign partition to better manager dead brok

[jira] [Commented] (KAFKA-1678) add new options for reassign partition to better manager dead brokers

[ https://issues.apache.org/jira/browse/KAFKA-1678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14160783#comment-14160783 ] Neha Narkhede commented on KAFKA-1678: -- What is the purpose of replace replica

[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=14160772#comment-14160772 ] Neha Narkhede commented on KAFKA-1367: -- The ISR cache on the broker was added

Re: Review Request 26346: Patch for KAFKA-1670

> On Oct. 5, 2014, 11:35 p.m., Jun Rao wrote: > > core/src/test/scala/unit/kafka/log/LogTest.scala, lines 113-129 > > > > > > Appending 2GB of data in a unit test is probably too long. We can > > probably just manuall

[jira] [Updated] (KAFKA-1668) TopicCommand doesn't warn if --topic argument doesn't match any topics

[ https://issues.apache.org/jira/browse/KAFKA-1668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1668: - Reviewer: Jay Kreps [~jkreps] Feel free to reassign for review. > TopicCommand doesn't

[jira] [Resolved] (KAFKA-1385) mirrormaker hangs during shutdown if no topic is consumed

[ https://issues.apache.org/jira/browse/KAFKA-1385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1385. -- Resolution: Fixed Fixed by patch for KAFKA-1650 > mirrormaker hangs during shutdown if

[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=14159389#comment-14159389 ] Neha Narkhede commented on KAFKA-328: - [~balaji.sesha...@dish.com] I use Intelli

[jira] [Commented] (KAFKA-1631) ReplicationFactor and under-replicated partitions incorrect during reassignment

[ https://issues.apache.org/jira/browse/KAFKA-1631?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14159388#comment-14159388 ] Neha Narkhede commented on KAFKA-1631: -- The behavior of partition reassignment b

[jira] [Updated] (KAFKA-1610) Local modifications to collections generated from mapValues will be lost

[ https://issues.apache.org/jira/browse/KAFKA-1610?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1610: - Reviewer: (was: Neha Narkhede) Sorry, may not get a chance to get to this review in a timely

[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=14159379#comment-14159379 ] Neha Narkhede commented on KAFKA-1558: -- [~sriharsha] Now that KAFKA-1663 is pu

[jira] [Resolved] (KAFKA-1600) Controller failover not working correctly.

[ https://issues.apache.org/jira/browse/KAFKA-1600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1600. -- Resolution: Fixed Duplicate JIRA KAFKA-1600 is now resolved. > Controller failover not work

[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: - Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the patch! Pushed

[jira] [Updated] (KAFKA-1057) Trim whitespaces from user specified configs

[ https://issues.apache.org/jira/browse/KAFKA-1057?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1057: - Resolution: Fixed Fix Version/s: (was: 0.9.0) 0.8.3

Re: Review Request 26291: Patch for KAFKA-1648

/kafka/consumer/ZookeeperConsumerConnector.scala <https://reviews.apache.org/r/26291/#comment95823> Can this empty comment be removed? - Neha Narkhede On Oct. 2, 2014, 10:43 p.m., Mayuresh Gharat wrote: > > --- > This is a

Re: Review Request 26346: Patch for KAFKA-1670

/kafka/log/Log.scala <https://reviews.apache.org/r/26346/#comment95822> Could you please change the API docs to reflect this change? - Neha Narkhede On Oct. 4, 2014, 10:28 p.m., Sriharsha Chintalapani wrote: > > ---

[jira] [Updated] (KAFKA-1670) Corrupt log files for segment.bytes values close to Int.MaxInt

[ https://issues.apache.org/jira/browse/KAFKA-1670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1670: - Reviewer: Jun Rao > Corrupt log files for segment.bytes values close to Int.Max

[jira] [Updated] (KAFKA-1277) Keep the summery/description when updating the RB with kafka-patch-review

[ https://issues.apache.org/jira/browse/KAFKA-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1277: - Reviewer: Neha Narkhede > Keep the summery/description when updating the RB with kafka-pa

[jira] [Commented] (KAFKA-1277) Keep the summery/description when updating the RB with kafka-patch-review

[ https://issues.apache.org/jira/browse/KAFKA-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14159338#comment-14159338 ] Neha Narkhede commented on KAFKA-1277: -- [~omkreddy] I tried testing the patch,

[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=14158829#comment-14158829 ] Neha Narkhede commented on KAFKA-1305: -- [~sriharsha] Depends :) Basically

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14158828#comment-14158828 ] Neha Narkhede commented on KAFKA-1663: -- [~sriharsha] Awesome. I'll re

[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=14158797#comment-14158797 ] Neha Narkhede commented on KAFKA-1558: -- [~sriharsha] Yes. The preferred rep

[jira] [Updated] (KAFKA-1650) Mirror Maker could lose data on unclean shutdown.

[ https://issues.apache.org/jira/browse/KAFKA-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1650: - Reviewer: Joel Koshy [~jjkoshy] Feel free to reassign for review. > Mirror Maker could lose d

[jira] [Updated] (KAFKA-1669) Default rebalance retries and backoff should be higher

[ https://issues.apache.org/jira/browse/KAFKA-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1669: - Component/s: consumer > Default rebalance retries and backoff should be hig

[jira] [Updated] (KAFKA-1669) Default rebalance retries and backoff should be higher

[ https://issues.apache.org/jira/browse/KAFKA-1669?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1669: - Labels: newbie (was: ) > Default rebalance retries and backoff should be hig

[jira] [Updated] (KAFKA-1668) TopicCommand doesn't warn if --topic argument doesn't match any topics

[ https://issues.apache.org/jira/browse/KAFKA-1668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1668: - Component/s: tools > TopicCommand doesn't warn if --topic argument doesn't mat

[jira] [Updated] (KAFKA-1668) TopicCommand doesn't warn if --topic argument doesn't match any topics

[ https://issues.apache.org/jira/browse/KAFKA-1668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1668: - Priority: Minor (was: Major) > TopicCommand doesn't warn if --topic argument doesn

[jira] [Updated] (KAFKA-1668) TopicCommand doesn't warn if --topic argument doesn't match any topics

[ https://issues.apache.org/jira/browse/KAFKA-1668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1668: - Labels: newbie (was: ) > TopicCommand doesn't warn if --topic argument doesn't mat

[jira] [Updated] (KAFKA-1600) Controller failover not working correctly.

[ https://issues.apache.org/jira/browse/KAFKA-1600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1600: - Reviewer: Neha Narkhede > Controller failover not working correc

[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: - Reviewer: Neha Narkhede > Controller unable to shutdown after a soft fail

[jira] [Updated] (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 updated KAFKA-1634: - Reviewer: Neha Narkhede > Update protocol wiki to reflect the new offset management feat

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

[ https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1558: - Reviewer: Neha Narkhede > AdminUtils.deleteTopic does not w

[jira] [Updated] (KAFKA-1662) gradle release issue permgen space

[ https://issues.apache.org/jira/browse/KAFKA-1662?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1662: - Reviewer: Jun Rao > gradle release issue permgen sp

[jira] [Updated] (KAFKA-1493) Use a well-documented LZ4 compression format and remove redundant LZ4HC option

[ https://issues.apache.org/jira/browse/KAFKA-1493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1493: - Reviewer: Jun Rao > Use a well-documented LZ4 compression format and remove redundant LZ

[jira] [Updated] (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:all-tabpanel ] Neha Narkhede updated KAFKA-1305: - Reviewer: Jun Rao > Controller can hang on controlled shutdown with auto leader balance enab

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=14157214#comment-14157214 ] Neha Narkhede commented on KAFKA-1663: -- [~sriharsha] Thanks for reproducing

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