[jira] [Resolved] (KAFKA-1606) Reference to old zk.connect vs broker.list found in docs under Produce APIs

[ https://issues.apache.org/jira/browse/KAFKA-1606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1606. Resolution: Fixed Assignee: Jun Rao Thanks for pointing this out. Fixed the website. > Reference to o

[jira] [Updated] (KAFKA-1123) Broker IPv6 addresses parsed incorrectly

[ https://issues.apache.org/jira/browse/KAFKA-1123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1123: - Reviewer: Jun Rao > Broker IPv6 addresses parsed incorrectly > ---

[jira] [Commented] (KAFKA-1123) Broker IPv6 addresses parsed incorrectly

[ https://issues.apache.org/jira/browse/KAFKA-1123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133558#comment-14133558 ] Neha Narkhede commented on KAFKA-1123: -- Bump [~kszafran]. Are you going to get a chan

[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=14133555#comment-14133555 ] Neha Narkhede commented on KAFKA-1499: -- [~jjkoshy] Any chance you can take a quick lo

[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 ] Neha Narkhede updated KAFKA-1070: - Assignee: Sriharsha Chintalapani (was: Jay Kreps) > Auto-assign node id > --- > >

[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 ] Neha Narkhede updated KAFKA-1070: - Reviewer: Neha Narkhede > Auto-assign node id > --- > > Key: KAFKA

[jira] [Updated] (KAFKA-1548) Refactor the "replica_id" in requests

[ https://issues.apache.org/jira/browse/KAFKA-1548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1548: - Reviewer: Neha Narkhede > Refactor the "replica_id" in requests >

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

[ https://issues.apache.org/jira/browse/KAFKA-1600?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133551#comment-14133551 ] Neha Narkhede commented on KAFKA-1600: -- Marking this as a blocker for 0.8.2 since it

[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: - Priority: Blocker (was: Major) > Controller failover not working correctly. > ---

[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: - Assignee: (was: Neha Narkhede) > Controller failover not working correctly. >

[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: - Fix Version/s: 0.8.2 > Controller failover not working correctly. > --

[jira] [Commented] (KAFKA-1362) Publish sources and javadoc jars

[ https://issues.apache.org/jira/browse/KAFKA-1362?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133550#comment-14133550 ] Jun Rao commented on KAFKA-1362: The maven issue should be fixed in kafka-1502. > Publish

[jira] [Commented] (KAFKA-934) kafka hadoop consumer and producer use older 0.19.2 hadoop api's

[ https://issues.apache.org/jira/browse/KAFKA-934?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133547#comment-14133547 ] Jun Rao commented on KAFKA-934: --- Gwen, Yes, we probably need to make a decision on whether t

[jira] [Commented] (KAFKA-1496) Using batch message in sync producer only sends the first message if we use a Scala Stream as the argument

[ https://issues.apache.org/jira/browse/KAFKA-1496?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133542#comment-14133542 ] Neha Narkhede commented on KAFKA-1496: -- +1. Pushed to trunk > Using batch message in

[jira] [Updated] (KAFKA-1496) Using batch message in sync producer only sends the first message if we use a Scala Stream as the argument

[ https://issues.apache.org/jira/browse/KAFKA-1496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1496: - Resolution: Fixed Status: Resolved (was: Patch Available) > Using batch message in sync p

[jira] [Updated] (KAFKA-1496) Using batch message in sync producer only sends the first message if we use a Scala Stream as the argument

[ https://issues.apache.org/jira/browse/KAFKA-1496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1496: - Reviewer: Neha Narkhede > Using batch message in sync producer only sends the first message if we

[jira] [Updated] (KAFKA-1496) Using batch message in sync producer only sends the first message if we use a Scala Stream as the argument

[ https://issues.apache.org/jira/browse/KAFKA-1496?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1496: - Assignee: Guan Liao (was: Jun Rao) > Using batch message in sync producer only sends the first me

[jira] [Updated] (KAFKA-1613) Improve system test documentation

[ https://issues.apache.org/jira/browse/KAFKA-1613?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1613: - Labels: newbie (was: ) > Improve system test documentation > - >

[jira] [Commented] (KAFKA-1025) Producer.send should provide recoverability info on failiure

[ https://issues.apache.org/jira/browse/KAFKA-1025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133526#comment-14133526 ] Neha Narkhede commented on KAFKA-1025: -- [~charmalloc], [~jbrosenb...@gmail.com], The

[jira] [Updated] (KAFKA-847) kafka appender layout does not work for kafka 0.7.1

[ https://issues.apache.org/jira/browse/KAFKA-847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-847: Resolution: Fixed Assignee: Peter Pham (was: Jun Rao) Status: Resolved (was: Patch Ava

[jira] [Updated] (KAFKA-847) kafka appender layout does not work for kafka 0.7.1

[ https://issues.apache.org/jira/browse/KAFKA-847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-847: Reviewer: Neha Narkhede > kafka appender layout does not work for kafka 0.7.1 > -

[jira] [Updated] (KAFKA-1614) Partition log directory name and segments information exposed via JMX

[ https://issues.apache.org/jira/browse/KAFKA-1614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1614: - Reviewer: Jay Kreps > Partition log directory name and segments information exposed via JMX >

[jira] [Updated] (KAFKA-1614) Partition log directory name and segments information exposed via JMX

[ https://issues.apache.org/jira/browse/KAFKA-1614?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1614: - Assignee: Alexander Demidko (was: Jay Kreps) > Partition log directory name and segments informat

[jira] [Updated] (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 updated KAFKA-1611: - Resolution: Fixed Status: Resolved (was: Patch Available) > Improve system test configura

[jira] [Updated] (KAFKA-1615) Generating group ID in ZookeeperConsumerConnector shouldn't require local hostname to resolve

[ https://issues.apache.org/jira/browse/KAFKA-1615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1615: - Labels: newbie usability (was: ) > Generating group ID in ZookeeperConsumerConnector shouldn't re

[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=14133520#comment-14133520 ] Neha Narkhede commented on KAFKA-1611: -- +1 on your patch. Pushed to trunk > Improve

Re: Review Request 25044: KAFKA-1611 - Improve system test configuration

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25044/#review53301 --- Ship it! Ship It! - Neha Narkhede On Aug. 26, 2014, 12:04 a.m.,

[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=14133510#comment-14133510 ] Neha Narkhede commented on KAFKA-1611: -- [~gwenshap] Thanks for the patch and apologiz

[jira] [Updated] (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 updated KAFKA-1611: - Reviewer: Neha Narkhede > Improve system test configuration > - >

[jira] [Commented] (KAFKA-1612) Consumer offsets auto-commit before processing finishes

[ https://issues.apache.org/jira/browse/KAFKA-1612?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133506#comment-14133506 ] Neha Narkhede commented on KAFKA-1612: -- [~gian] The current API was designed to assum

[jira] [Commented] (KAFKA-1374) LogCleaner (compaction) does not support compressed topics

[ https://issues.apache.org/jira/browse/KAFKA-1374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133498#comment-14133498 ] Neha Narkhede commented on KAFKA-1374: -- Bump. This is marked for 0.8.2. Feel free to

Re: (New) reviewer field in Kafka jiras

Thanks Joel! This is super helpful for distributing the outstanding reviews amongst all committers and also useful for keeping track of the review todo list per committer. I'd encourage all active committers to sign up for patch review as that is one of the most important responsibilities of a comm

[jira] [Commented] (KAFKA-1447) Controlled shutdown deadlock when trying to send state updates

[ https://issues.apache.org/jira/browse/KAFKA-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133495#comment-14133495 ] Neha Narkhede commented on KAFKA-1447: -- [~rudolf.sima], It would help immensely if yo

Re: Review Request 25136: Patch for KAFKA-1610

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/25136/#review53292 --- core/src/main/scala/kafka/server/KafkaApis.scala

[jira] [Updated] (KAFKA-1447) Controlled shutdown deadlock when trying to send state updates

[ https://issues.apache.org/jira/browse/KAFKA-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1447: - Labels: newbie++ (was: ) > Controlled shutdown deadlock when trying to send state updates > -

[jira] [Updated] (KAFKA-1447) Controlled shutdown deadlock when trying to send state updates

[ https://issues.apache.org/jira/browse/KAFKA-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1447: - Assignee: (was: Neha Narkhede) > Controlled shutdown deadlock when trying to send state update

[jira] [Updated] (KAFKA-1447) Controlled shutdown deadlock when trying to send state updates

[ https://issues.apache.org/jira/browse/KAFKA-1447?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1447: - Priority: Critical (was: Major) > Controlled shutdown deadlock when trying to send state updates

[jira] [Commented] (KAFKA-1596) Exception in KafkaScheduler while shutting down

[ https://issues.apache.org/jira/browse/KAFKA-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133493#comment-14133493 ] Neha Narkhede commented on KAFKA-1596: -- [~jjkoshy], [~pachalko] Bump. Same question a

[jira] [Updated] (KAFKA-1554) Corrupt index found on clean startup

[ https://issues.apache.org/jira/browse/KAFKA-1554?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1554: - Fix Version/s: 0.9.0 > Corrupt index found on clean startup >

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

Neha Narkhede created KAFKA-1634: Summary: Update protocol wiki to reflect the new offset management feature Key: KAFKA-1634 URL: https://issues.apache.org/jira/browse/KAFKA-1634 Project: Kafka

[jira] [Updated] (KAFKA-1583) Kafka API Refactoring

[ https://issues.apache.org/jira/browse/KAFKA-1583?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1583: - Reviewer: Jun Rao > Kafka API Refactoring > - > > Key: KAFKA-1

[jira] [Updated] (KAFKA-1622) project shouldn't require signing to build

[ https://issues.apache.org/jira/browse/KAFKA-1622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1622: - Labels: build newbie packaging (was: newbie) > project shouldn't require signing to build > -

Re: Offset Request with timestamp

I added this question to the FAQ as it frequently comes up - https://cwiki.apache.org/confluence/display/KAFKA/FAQ#FAQ-HowdoIaccuratelygetoffsetsofmessagesforacertaintimestampusingOffsetFetchRequest ? On Tue, Sep 2, 2014 at 1:48 PM, Guozhang Wang wrote: > The semantic of the offset API is to "r

[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=14133468#comment-14133468 ] Neha Narkhede commented on KAFKA-1558: -- I'll add one more :) After the controller bro

[jira] [Commented] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133446#comment-14133446 ] Jagbir commented on KAFKA-1382: --- Hi Sriharsha, This is what I did prompt> git clone http:/

[jira] [Comment Edited] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133383#comment-14133383 ] Sriharsha Chintalapani edited comment on KAFKA-1382 at 9/14/14 9:11 PM:

[jira] [Commented] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133383#comment-14133383 ] Sriharsha Chintalapani commented on KAFKA-1382: --- [~jhooda] can you share ho

[jira] [Commented] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133349#comment-14133349 ] Jagbir commented on KAFKA-1382: --- Not sure if this is related. We applied the final patch on

[jira] [Commented] (KAFKA-1632) No such method error on KafkaStream.head

[ https://issues.apache.org/jira/browse/KAFKA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133345#comment-14133345 ] aarti gupta commented on KAFKA-1632: Agreed, so to process a single message, one would

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=1414#comment-1414 ] Neha Narkhede commented on KAFKA-1610: -- Great catch, [~guozhang]. Thanks for submitti

[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=1413#comment-1413 ] Sriharsha Chintalapani commented on KAFKA-1558: --- Thanks [~junrao] will test

[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=14133329#comment-14133329 ] Jun Rao commented on KAFKA-1558: Sriharsha, It would be useful to test if "delete topic"

[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: Neha Narkhede > Local modifications to collections generated from mapValues will be lost

[jira] [Updated] (KAFKA-1369) snappy version update 1.1.x

[ https://issues.apache.org/jira/browse/KAFKA-1369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1369: --- Resolution: Fixed Fix Version/s: 0.8.2 Assignee: Roger Hoover Status: Resolved (was

[jira] [Commented] (KAFKA-1632) No such method error on KafkaStream.head

[ https://issues.apache.org/jira/browse/KAFKA-1632?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133314#comment-14133314 ] Jun Rao commented on KAFKA-1632: If there is no new message, the iterator on KafkaStream b

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

Thanks a lot for going through the unresolved tickets, Guozhang! On Thu, Sep 4, 2014 at 8:19 AM, Guozhang Wang wrote: > Just made a pass over the unresolved tickets tagged for 0.8.2, I think many > of them can be pushed to 0.8.3 / 0.9. > > > On Wed, Sep 3, 2014 at 8:05 PM, Jonathan Weeks > wrot

[jira] [Commented] (KAFKA-1623) kafka is sometimes slow to accept connections

[ https://issues.apache.org/jira/browse/KAFKA-1623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133305#comment-14133305 ] Neha Narkhede commented on KAFKA-1623: -- [~hzshlomi], [~guozhang], One thing that migh

Re: （info）how kafka delete the specific topic data

We are working on an admin tool to delete an existing topic in trunk. Thanks, Jun On Sat, Sep 13, 2014 at 1:22 AM, Jacky.J.Wang (mis.cnxa01.Newegg) 43048 < jacky.j.w...@newegg.com.invalid> wrote: > Hello kafka > > I truncate data of kafka as follow > > 1：stop kafka service > 2：delete zookeeper

[jira] [Commented] (KAFKA-1438) Migrate kafka client tools

[ https://issues.apache.org/jira/browse/KAFKA-1438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133296#comment-14133296 ] Jun Rao commented on KAFKA-1438: The followup patch has been committed as part of kafka-14

[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 ] Jun Rao updated KAFKA-1419: --- Resolution: Fixed Status: Resolved (was: Patch Available) Thanks for the delta patch. Committed to tr

[jira] [Resolved] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest

[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani resolved KAFKA-1482. --- Resolution: Cannot Reproduce ran full tests in a loop of 100 and also single D

[jira] [Updated] (KAFKA-1482) Transient test failures for kafka.admin.DeleteTopicTest

[ https://issues.apache.org/jira/browse/KAFKA-1482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1482: -- Attachment: kafka_tests.log kafka_delete_topic_test.log > Transi

[jira] [Updated] (KAFKA-1624) building on JDK 8 fails

[ https://issues.apache.org/jira/browse/KAFKA-1624?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1624: - Labels: newbie (was: ) > building on JDK 8 fails > --- > > Ke

[jira] [Updated] (KAFKA-1619) perf dir can be removed

[ https://issues.apache.org/jira/browse/KAFKA-1619?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1619: --- Resolution: Fixed Fix Version/s: 0.8.2 Status: Resolved (was: Patch Available) Thanks for t

Re: Review Request 25236: Patch for KAFKA-1619

> On Sept. 1, 2014, 7:56 p.m., Guozhang Wang wrote: > > Shall we remove the whole perf directory as well? Perf is not part of the git repo. It's probably created by the gradle script, which is fixed now. - Jun --- This is an automatica

[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: Reviewer: Neha Narkhede > When using chroot path, create chroot on startup if it doesn't exist >

[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=14133282#comment-14133282 ] Neha Narkhede commented on KAFKA-1420: -- [~junrao], please feel free to reassign for r

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

[ https://issues.apache.org/jira/browse/KAFKA-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-1499: --- Reviewer: Joel Koshy > Broker-side compression configuration > ---

[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 ] Neha Narkhede updated KAFKA-1420: - Reviewer: Jun Rao Assignee: Jonathan Natkins (was: Jun Rao) > Replace AdminUtils.createOrUpda

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

[ https://issues.apache.org/jira/browse/KAFKA-1476?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1476: - Reviewer: Neha Narkhede > Get a list of consumer groups > - > >

[jira] [Updated] (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:all-tabpanel ] Neha Narkhede updated KAFKA-328: Reviewer: Neha Narkhede > Write unit test for kafka server startup and shutdown API > --

[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=14133279#comment-14133279 ] Neha Narkhede commented on KAFKA-328: - [~balaji.sesha...@dish.com] Thanks for looking i

[jira] [Commented] (KAFKA-1633) Data loss if broker is killed

[ https://issues.apache.org/jira/browse/KAFKA-1633?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133278#comment-14133278 ] Jun Rao commented on KAFKA-1633: What's the producer ack you used in your test? In general

[jira] [Updated] (KAFKA-1313) Support adding replicas to existing topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1313: - Fix Version/s: (was: 0.8.2) 0.9.0 > Support adding replicas to existing top

[jira] [Reopened] (KAFKA-1313) Support adding replicas to existing topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede reopened KAFKA-1313: -- > Support adding replicas to existing topic partitions > ---

[jira] [Updated] (KAFKA-1313) Support adding replicas to existing topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1313: - Labels: newbie++ (was: ) > Support adding replicas to existing topic partitions > ---

[jira] [Commented] (KAFKA-1313) Support adding replicas to existing topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-1313?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133275#comment-14133275 ] Neha Narkhede commented on KAFKA-1313: -- [~guozhang], [~charmalloc], Doing this throug

[jira] [Updated] (KAFKA-313) Add JSON output and looping options to ConsumerOffsetChecker

[ https://issues.apache.org/jira/browse/KAFKA-313?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-313: Labels: newbie patch (was: patch) > Add JSON output and looping options to ConsumerOffsetChecker > -

[jira] [Updated] (KAFKA-1324) Debian packaging

[ https://issues.apache.org/jira/browse/KAFKA-1324?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1324: - Labels: deb debian fpm newbie packaging (was: deb debian fpm packaging) > Debian packaging >

[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 ] Abhishek Sharma updated KAFKA-1591: --- Attachment: Jira-1591- Complete Changes Patch.patch Complete Changes patch - as per Guozhang l

[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=14133272#comment-14133272 ] BalajiSeshadri commented on KAFKA-1618: --- [~nehanarkhede] thanks a lot for review com

[jira] [Commented] (KAFKA-1002) Delete aliveLeaders field from LeaderAndIsrRequest

[ https://issues.apache.org/jira/browse/KAFKA-1002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133271#comment-14133271 ] Neha Narkhede commented on KAFKA-1002: -- [~guozhang] We have renamed it appropriately

[jira] [Closed] (KAFKA-1002) Delete aliveLeaders field from LeaderAndIsrRequest

[ https://issues.apache.org/jira/browse/KAFKA-1002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1002. > Delete aliveLeaders field from LeaderAndIsrRequest > -

[jira] [Resolved] (KAFKA-1002) Delete aliveLeaders field from LeaderAndIsrRequest

[ https://issues.apache.org/jira/browse/KAFKA-1002?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1002. -- Resolution: Fixed > Delete aliveLeaders field from LeaderAndIsrRequest > ---

[jira] [Updated] (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 updated KAFKA-1034: - Labels: newbie++ (was: ) > Improve partition reassignment to optimize writes to zookeeper > -

[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=14133269#comment-14133269 ] Neha Narkhede commented on KAFKA-1034: -- [~guozhang], I don't quite remember. Probably

[jira] [Updated] (KAFKA-1545) java.net.InetAddress.getLocalHost in KafkaHealthcheck.register may fail on some irregular hostnames

[ https://issues.apache.org/jira/browse/KAFKA-1545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1545: - Labels: newbie (was: ) > java.net.InetAddress.getLocalHost in KafkaHealthcheck.register may fail

[jira] [Updated] (KAFKA-1043) Time-consuming FetchRequest could block other request in the response queue

[ https://issues.apache.org/jira/browse/KAFKA-1043?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1043: - Labels: newbie++ (was: ) > Time-consuming FetchRequest could block other request in the response

[jira] [Updated] (KAFKA-1108) when controlled shutdown attempt fails, the reason is not always logged

[ https://issues.apache.org/jira/browse/KAFKA-1108?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1108: - Labels: newbie (was: ) > when controlled shutdown attempt fails, the reason is not always logged

[jira] [Updated] (KAFKA-1147) Consumer socket timeout should be greater than fetch max wait

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

[jira] [Updated] (KAFKA-1147) Consumer socket timeout should be greater than fetch max wait

[ https://issues.apache.org/jira/browse/KAFKA-1147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1147: - Status: Patch Available (was: Open) > Consumer socket timeout should be greater than fetch max wa

[jira] [Updated] (KAFKA-1147) Consumer socket timeout should be greater than fetch max wait

[ https://issues.apache.org/jira/browse/KAFKA-1147?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1147: - Reviewer: Neha Narkhede > Consumer socket timeout should be greater than fetch max wait >

Re: Review Request 16092: Patch for KAFKA-1147

> On Dec. 10, 2013, 4:14 p.m., Jun Rao wrote: > > It seems that in the consumer, we have a separate request timeout and > > socket timeout. The producer only has a request timeout now. Perhaps we > > should add the socket timeout in the producer too? > > Guozhang Wang wrote: > Currently re

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

[ https://issues.apache.org/jira/browse/KAFKA-1057?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14133261#comment-14133261 ] Neha Narkhede commented on KAFKA-1057: -- [~sriharsha] The example used by [~maasg] abo

[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: - Assignee: (was: Neha Narkhede) > Trim whitespaces from user specified configs > --

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

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1282: - Assignee: nicu marasoiu (was: Neha Narkhede) > Disconnect idle socket connection in Selector > --

[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=14133259#comment-14133259 ] Neha Narkhede commented on KAFKA-1282: -- Thanks for the patch, [~nmarasoi]! Looks good

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

[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1282: - Reviewer: Neha Narkhede > Disconnect idle socket connection in Selector >

[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=14133254#comment-14133254 ] Neha Narkhede commented on KAFKA-1618: -- [~balaji.sesha...@dish.com] To answer your qu