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

gautham varada created KAFKA-1633: - Summary: Data loss if broker is killed Key: KAFKA-1633 URL: https://issues.apache.org/jira/browse/KAFKA-1633 Project: Kafka Issue Type: Bug

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

[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] [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] [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-tabpanelfocusedCommentId=14133261#comment-14133261 ] Neha Narkhede commented on KAFKA-1057: -- [~sriharsha] The example used by [~maasg]

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

[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

[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

[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

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

[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] [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] [Commented] (KAFKA-1002) Delete aliveLeaders field from LeaderAndIsrRequest

[ https://issues.apache.org/jira/browse/KAFKA-1002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=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] [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-tabpanelfocusedCommentId=14133272#comment-14133272 ] BalajiSeshadri commented on KAFKA-1618: --- [~nehanarkhede] thanks a lot for review

[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

[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-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-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-tabpanelfocusedCommentId=14133275#comment-14133275 ] Neha Narkhede commented on KAFKA-1313: -- [~guozhang], [~charmalloc], Doing this

[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] [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-tabpanelfocusedCommentId=14133278#comment-14133278 ] Jun Rao commented on KAFKA-1633: What's the producer ack you used in your test? In

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

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

[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 --- Key:

[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

[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

[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

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

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

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

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 wangg...@gmail.com 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

[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-tabpanelfocusedCommentId=14133314#comment-14133314 ] Jun Rao commented on KAFKA-1632: If there is no new message, the iterator on KafkaStream

[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

[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] [Commented] (KAFKA-1558) AdminUtils.deleteTopic does not work

[ https://issues.apache.org/jira/browse/KAFKA-1558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14133329#comment-14133329 ] Jun Rao commented on KAFKA-1558: Sriharsha, It would be useful to test if delete topic

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

[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-tabpanelfocusedCommentId=1414#comment-1414 ] Neha Narkhede commented on KAFKA-1610: -- Great catch, [~guozhang]. Thanks for

[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-tabpanelfocusedCommentId=14133345#comment-14133345 ] aarti gupta commented on KAFKA-1632: Agreed, so to process a single message, one would

[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-tabpanelfocusedCommentId=14133349#comment-14133349 ] Jagbir commented on KAFKA-1382: --- Not sure if this is related. We applied the final patch on

[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-tabpanelfocusedCommentId=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-tabpanelfocusedCommentId=14133383#comment-14133383 ] Sriharsha Chintalapani commented on KAFKA-1382: --- [~jhooda] can you share

[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-tabpanelfocusedCommentId=14133446#comment-14133446 ] Jagbir commented on KAFKA-1382: --- Hi Sriharsha, This is what I did prompt git clone

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

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 wangg...@gmail.com wrote: The semantic of the

[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

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

[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-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] [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-tabpanelfocusedCommentId=14133493#comment-14133493 ] Neha Narkhede commented on KAFKA-1596: -- [~jjkoshy], [~pachalko] Bump. Same question

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

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] [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-tabpanelfocusedCommentId=14133495#comment-14133495 ] Neha Narkhede commented on KAFKA-1447: -- [~rudolf.sima], It would help immensely if

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

[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-tabpanelfocusedCommentId=14133498#comment-14133498 ] Neha Narkhede commented on KAFKA-1374: -- Bump. This is marked for 0.8.2. Feel free to

[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-tabpanelfocusedCommentId=14133506#comment-14133506 ] Neha Narkhede commented on KAFKA-1612: -- [~gian] The current API was designed to

[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-1611) Improve system test configuration

[ https://issues.apache.org/jira/browse/KAFKA-1611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14133510#comment-14133510 ] Neha Narkhede commented on KAFKA-1611: -- [~gwenshap] Thanks for the patch and

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

[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

[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

[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

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

[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-tabpanelfocusedCommentId=14133526#comment-14133526 ] Neha Narkhede commented on KAFKA-1025: -- [~charmalloc], [~jbrosenb...@gmail.com], The

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

[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: - Resolution: Fixed Status: Resolved (was: Patch Available) Using batch message in sync

[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-tabpanelfocusedCommentId=14133542#comment-14133542 ] Neha Narkhede commented on KAFKA-1496: -- +1. Pushed to trunk Using batch message in

[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-tabpanelfocusedCommentId=14133547#comment-14133547 ] Jun Rao commented on KAFKA-934: --- Gwen, Yes, we probably need to make a decision on whether

[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-tabpanelfocusedCommentId=14133550#comment-14133550 ] Jun Rao commented on KAFKA-1362: The maven issue should be fixed in kafka-1502. Publish

[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] [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] [Commented] (KAFKA-1600) Controller failover not working correctly.

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

[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] [Commented] (KAFKA-1499) Broker-side compression configuration

[ https://issues.apache.org/jira/browse/KAFKA-1499?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14133555#comment-14133555 ] Neha Narkhede commented on KAFKA-1499: -- [~jjkoshy] Any chance you can take a quick

[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-tabpanelfocusedCommentId=14133558#comment-14133558 ] Neha Narkhede commented on KAFKA-1123: -- Bump [~kszafran]. Are you going to get a

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