[jira] [Resolved] (KAFKA-1434) kafka.admin.TopicCommand missing --delete topic command

2015-01-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-1434. Resolution: Fixed Fix Version/s: 0.8.2 This issue is fixed in 0.8.2. Pl enable

Re: Review Request 27799: Patch for KAFKA-1760

2015-01-20 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27799/#review68693 ---

[jira] [Updated] (KAFKA-1239) New producer checklist

2015-01-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-1239: --- Affects Version/s: (was: 0.9.0) 0.8.2 New producer checklist

[jira] [Updated] (KAFKA-1109) Need to fix GC log configuration code, not able to override KAFKA_GC_LOG_OPTS

2015-01-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-1109: --- Attachment: KAFKA-1109.patch Need to fix GC log configuration code, not able to override

[jira] [Updated] (KAFKA-1109) Need to fix GC log configuration code, not able to override KAFKA_GC_LOG_OPTS

2015-01-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1109?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-1109: --- Assignee: Manikumar Reddy Status: Patch Available (was: Open) Need to fix GC log

[jira] [Updated] (KAFKA-1000) Inbuilt consumer offset management feature for kakfa

2015-01-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-1000: --- Fix Version/s: 0.8.2 Inbuilt consumer offset management feature for kakfa

Review Request 30073: Patch for KAFKA-1109

2015-01-20 Thread Manikumar Reddy O
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30073/ --- Review request for kafka. Bugs: KAFKA-1109

[jira] [Commented] (KAFKA-1109) Need to fix GC log configuration code, not able to override KAFKA_GC_LOG_OPTS

2015-01-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14283755#comment-14283755 ] Manikumar Reddy commented on KAFKA-1109: Created reviewboard

[jira] [Resolved] (KAFKA-1045) producer zk.connect config

2015-01-20 Thread Manikumar Reddy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-1045. Resolution: Fixed Fix Version/s: 0.8.2 Zookeeper configs are not required for new

[jira] [Resolved] (KAFKA-1337) Rationalize new producer configs

2015-01-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1337. Resolution: Fixed Fix Version/s: 0.8.2 The followup patch has been committed to 0.8.2. Resolving the

[jira] [Updated] (KAFKA-1885) Allow test methods in core to be individually run from outside of the IDE

2015-01-20 Thread jaikiran pai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jaikiran pai updated KAFKA-1885: Description: Gradle in combination with Java plugin allows test filtering which lets users run

Re: Review Request 30078: Patch for KAFKA-1885

2015-01-20 Thread Jaikiran Pai
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30078/ --- (Updated Jan. 20, 2015, 4:11 p.m.) Review request for kafka. Changes ---

Re: Review Request 30078: Patch for KAFKA-1885

2015-01-20 Thread Jaikiran Pai
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30078/ --- (Updated Jan. 20, 2015, 4:15 p.m.) Review request for kafka. Changes ---

Re: Review Request 27391: Fix KAFKA-1634

2015-01-20 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27391/#review68729 --- core/src/main/scala/kafka/server/KafkaApis.scala

[jira] [Commented] (KAFKA-1853) Unsuccessful suffix rename of expired LogSegment can leak open files and also leave the LogSegment in an invalid state

2015-01-20 Thread jaikiran pai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14283981#comment-14283981 ] jaikiran pai commented on KAFKA-1853: - Updated reviewboard

[jira] [Updated] (KAFKA-1885) Allow test methods in core to be individually run from outside of the IDE

2015-01-20 Thread jaikiran pai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jaikiran pai updated KAFKA-1885: Description: Gradle in combination with Java plugin allows test filtering which lets users run

Review Request 30078: Patch for KAFKA-1885

2015-01-20 Thread Jaikiran Pai
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30078/ --- Review request for kafka. Bugs: KAFKA-1885

[jira] [Updated] (KAFKA-1885) Allow test methods in core to be individually run from outside of the IDE

2015-01-20 Thread jaikiran pai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jaikiran pai updated KAFKA-1885: Status: Patch Available (was: Open) Allow test methods in core to be individually run from

[jira] [Commented] (KAFKA-1885) Allow test methods in core to be individually run from outside of the IDE

2015-01-20 Thread jaikiran pai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14283961#comment-14283961 ] jaikiran pai commented on KAFKA-1885: - Created reviewboard

[jira] [Updated] (KAFKA-1885) Allow test methods in core to be individually run from outside of the IDE

2015-01-20 Thread jaikiran pai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jaikiran pai updated KAFKA-1885: Attachment: KAFKA-1885.patch Allow test methods in core to be individually run from outside of the

Re: Review Request 29755: Patch for KAFKA-1853

2015-01-20 Thread Jaikiran Pai
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/29755/ --- (Updated Jan. 20, 2015, 4:35 p.m.) Review request for kafka. Bugs:

[jira] [Updated] (KAFKA-1853) Unsuccessful suffix rename of expired LogSegment can leak open files and also leave the LogSegment in an invalid state

2015-01-20 Thread jaikiran pai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] jaikiran pai updated KAFKA-1853: Attachment: KAFKA-1853_2015-01-20_22:04:29.patch Unsuccessful suffix rename of expired LogSegment

[jira] [Commented] (KAFKA-1853) Unsuccessful suffix rename of expired LogSegment can leak open files and also leave the LogSegment in an invalid state

2015-01-20 Thread jaikiran pai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14283989#comment-14283989 ] jaikiran pai commented on KAFKA-1853: - Hi [~jkreps], I've updated the patch to take

Re: Review Request 30063: Patch for KAFKA-1840

2015-01-20 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30063/#review68750 --- core/src/main/scala/kafka/tools/MirrorMaker.scala

Review Request 30083: Patch for KAFKA-1839

2015-01-20 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30083/ --- Review request for kafka. Bugs: KAFKA-1839

Re: Review Request 30083: Patch for KAFKA-1839

2015-01-20 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30083/ --- (Updated Jan. 20, 2015, 6:54 p.m.) Review request for kafka. Bugs:

[jira] [Created] (KAFKA-1885) Allow test methods in core to be individually run from outside of the IDE

2015-01-20 Thread jaikiran pai (JIRA)
jaikiran pai created KAFKA-1885: --- Summary: Allow test methods in core to be individually run from outside of the IDE Key: KAFKA-1885 URL: https://issues.apache.org/jira/browse/KAFKA-1885 Project: Kafka

Re: Review Request 27799: Patch for KAFKA-1760

2015-01-20 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27799/#review68699 ---

[jira] [Created] (KAFKA-1887) controller error message on shutting the last broker

2015-01-20 Thread Jun Rao (JIRA)
Jun Rao created KAFKA-1887: -- Summary: controller error message on shutting the last broker Key: KAFKA-1887 URL: https://issues.apache.org/jira/browse/KAFKA-1887 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-1823) transient unit test failure in PartitionAssignorTest

2015-01-20 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14284424#comment-14284424 ] Joel Koshy commented on KAFKA-1823: --- Committed to trunk. Thanks for the review.

Build failed in Jenkins: Kafka-trunk #375

2015-01-20 Thread Apache Jenkins Server
See https://builds.apache.org/job/Kafka-trunk/375/changes Changes: [jjkoshy] KAFKA-1823; Fix transient failure in PartitionAssignorTest; reviewed by Guozhang Wang and Neha Narkhede -- [...truncated 496 lines...] kafka.log.LogTest testAsyncDelete PASSED

[jira] [Created] (KAFKA-1886) SimpleConsumer swallowing ClosedByInterruptException

2015-01-20 Thread Aditya A Auradkar (JIRA)
Aditya A Auradkar created KAFKA-1886: Summary: SimpleConsumer swallowing ClosedByInterruptException Key: KAFKA-1886 URL: https://issues.apache.org/jira/browse/KAFKA-1886 Project: Kafka

[KIP-DISCUSSION] Mirror Maker Enhancement

2015-01-20 Thread Jiangjie Qin
Hi Kafka Devs, We are working on Kafka Mirror Maker enhancement. A KIP is posted to document and discuss on the followings: 1. KAFKA-1650: No Data loss mirror maker change 2. KAFKA-1839: To allow partition aware mirror. 3. KAFKA-1840: To allow message filtering/format conversion Feedbacks are

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

2015-01-20 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14284409#comment-14284409 ] Sriharsha Chintalapani commented on KAFKA-1596: --- [~nehanarkhede] [~guozhang]

[jira] [Commented] (KAFKA-1839) Adding an afterRebalance callback to the ConsumerRebalanceListener of ZookeeperConsumerConnector

2015-01-20 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14284449#comment-14284449 ] Jiangjie Qin commented on KAFKA-1839: - Updated reviewboard

[jira] [Updated] (KAFKA-1839) Adding an afterRebalance callback to the ConsumerRebalanceListener of ZookeeperConsumerConnector

2015-01-20 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1839: Attachment: KAFKA-1839_2015-01-20_13:28:25.patch Adding an afterRebalance callback to the

Re: Review Request 30083: Patch for KAFKA-1839

2015-01-20 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30083/ --- (Updated Jan. 20, 2015, 9:28 p.m.) Review request for kafka. Bugs:

[jira] [Created] (KAFKA-1888) Add a rolling upgrade system test

2015-01-20 Thread Gwen Shapira (JIRA)
Gwen Shapira created KAFKA-1888: --- Summary: Add a rolling upgrade system test Key: KAFKA-1888 URL: https://issues.apache.org/jira/browse/KAFKA-1888 Project: Kafka Issue Type: Improvement

[jira] [Updated] (KAFKA-1823) transient unit test failure in PartitionAssignorTest

2015-01-20 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joel Koshy updated KAFKA-1823: -- Resolution: Fixed Status: Resolved (was: Patch Available) transient unit test failure in

[jira] [Commented] (KAFKA-1886) SimpleConsumer swallowing ClosedByInterruptException

2015-01-20 Thread Aditya A Auradkar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14284961#comment-14284961 ] Aditya A Auradkar commented on KAFKA-1886: -- Did a good bit of poking around.

[jira] [Commented] (KAFKA-1728) update 082 docs

2015-01-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285029#comment-14285029 ] Jun Rao commented on KAFKA-1728: Thanks for the patch. +1 and committed to site. 1. Yes,

[jira] [Commented] (KAFKA-1830) Closing socket connection to /10.118.192.104. (kafka.network.Processor)

2015-01-20 Thread Mingjie Lai (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14284975#comment-14284975 ] Mingjie Lai commented on KAFKA-1830: [~guozhang] Can you tell me which JIRA or git

[jira] [Commented] (KAFKA-1856) Add PreCommit Patch Testing

2015-01-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285105#comment-14285105 ] Gwen Shapira commented on KAFKA-1856: - Non-binding +1 from me :) Looks good and I'm

[jira] [Commented] (KAFKA-1809) Refactor brokers to allow listening on multiple ports and IPs

2015-01-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14285116#comment-14285116 ] Gwen Shapira commented on KAFKA-1809: - Pinging [~junrao] for review :) I believe the

New consumer plans

2015-01-20 Thread Jay Kreps
There is a draft patch for the new consumer up on KAFKA-1760: https://issues.apache.org/jira/browse/KAFKA-1760 I chatted with Guozhang earlier today and here was our thought on how to proceed: 1. There are changes to NetworkClient and Sender that I'll describe below. These should be closely

[jira] [Commented] (KAFKA-1886) SimpleConsumer swallowing ClosedByInterruptException

2015-01-20 Thread Aditya A Auradkar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14284963#comment-14284963 ] Aditya A Auradkar commented on KAFKA-1886: -- If interested, I hacked an existing

[jira] [Resolved] (KAFKA-1674) auto.create.topics.enable docs are misleading

2015-01-20 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1674?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1674. Resolution: Duplicate This is fixed in KAFKA-1728. auto.create.topics.enable docs are misleading

Re: [KIP-DISCUSSION] Mirror Maker Enhancement

2015-01-20 Thread Gwen Shapira
Thanks for the detailed document, Jiangjie. Super helpful. Few questions: 1. You mention that A ConsumerRebalanceListener class is created and could be wired into ZookeeperConsumerConnector to avoid duplicate messages when consumer rebalance occurs in mirror maker. Is this something the user

[jira] [Resolved] (KAFKA-1294) Enable leadership balancing by default

2015-01-20 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani resolved KAFKA-1294. --- Resolution: Fixed Fix Version/s: 0.8.2 This is fixed in KAFKA-1305.

[jira] [Updated] (KAFKA-1840) Add a simple message handler in Mirror Maker

2015-01-20 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1840: Attachment: KAFKA-1840_2015-01-20_11:36:14.patch Add a simple message handler in Mirror Maker

[jira] [Commented] (KAFKA-1839) Adding an afterRebalance callback to the ConsumerRebalanceListener of ZookeeperConsumerConnector

2015-01-20 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14284298#comment-14284298 ] Jiangjie Qin commented on KAFKA-1839: - Updated reviewboard

[jira] [Updated] (KAFKA-1839) Adding an afterRebalance callback to the ConsumerRebalanceListener of ZookeeperConsumerConnector

2015-01-20 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1839: Assignee: Jiangjie Qin Status: Patch Available (was: Open) Adding an afterRebalance

[jira] [Updated] (KAFKA-1839) Adding an afterRebalance callback to the ConsumerRebalanceListener of ZookeeperConsumerConnector

2015-01-20 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated KAFKA-1839: Attachment: KAFKA-1839_2015-01-20_11:49:12.patch Adding an afterRebalance callback to the

Re: Review Request 30063: Patch for KAFKA-1840

2015-01-20 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30063/ --- (Updated Jan. 20, 2015, 7:36 p.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-1840) Add a simple message handler in Mirror Maker

2015-01-20 Thread Jiangjie Qin (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14284284#comment-14284284 ] Jiangjie Qin commented on KAFKA-1840: - Updated reviewboard

Re: Review Request 30083: Patch for KAFKA-1839

2015-01-20 Thread Jiangjie Qin
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30083/ --- (Updated Jan. 20, 2015, 7:49 p.m.) Review request for kafka. Bugs:

Review Request 30084: Patch for KAFKA-1866

2015-01-20 Thread Sriharsha Chintalapani
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30084/ --- Review request for kafka. Bugs: KAFKA-1866

[jira] [Updated] (KAFKA-1866) LogStartOffset gauge throws exceptions after log.delete()

2015-01-20 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1866: -- Status: Patch Available (was: Open) LogStartOffset gauge throws exceptions

[jira] [Commented] (KAFKA-1866) LogStartOffset gauge throws exceptions after log.delete()

2015-01-20 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14284310#comment-14284310 ] Sriharsha Chintalapani commented on KAFKA-1866: --- Created reviewboard

[jira] [Commented] (KAFKA-1866) LogStartOffset gauge throws exceptions after log.delete()

2015-01-20 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14284313#comment-14284313 ] Sriharsha Chintalapani commented on KAFKA-1866: --- The above patch tested by