Re: Review Request 27799: Patch for KAFKA-1760

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27799/#review68693 --- clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.

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

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

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

[ 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-1337) Rationalize new producer configs

[ https://issues.apache.org/jira/browse/KAFKA-1337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy updated KAFKA-1337: --- Affects Version/s: 0.8.2 > Rationalize new producer configs >

[jira] [Resolved] (KAFKA-1124) Sending to a new topic (with auto.create.topics.enable) returns ERROR

[ https://issues.apache.org/jira/browse/KAFKA-1124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar Reddy resolved KAFKA-1124. Resolution: Fixed Fix Version/s: 0.8.2 This got fixed in new producer. > Sending to

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

[ https://issues.apache.org/jira/browse/KAFKA-1109?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14283755#comment-14283755 ] Manikumar Reddy commented on KAFKA-1109: Created reviewboard https://reviews.apach

Review Request 30073: Patch for KAFKA-1109

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30073/ --- Review request for kafka. Bugs: KAFKA-1109 https://issues.apache.org/jira/b

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

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

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

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

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

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

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

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

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

[ 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] [Created] (KAFKA-1885) Allow test methods in "core" to be individually run from outside of the IDE

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: Kafk

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

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

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

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

Review Request 30078: Patch for KAFKA-1885

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30078/ --- Review request for kafka. Bugs: KAFKA-1885 https://issues.apache.org/jira/b

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

[ https://issues.apache.org/jira/browse/KAFKA-1885?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14283961#comment-14283961 ] jaikiran pai commented on KAFKA-1885: - Created reviewboard https://reviews.apache.org/

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

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

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

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

Re: Review Request 30078: Patch for KAFKA-1885

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

--- 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 29755: Patch for KAFKA-1853

--- 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: KAFKA-1853

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

[ 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

Re: Review Request 27391: Fix KAFKA-1634

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

[ https://issues.apache.org/jira/browse/KAFKA-1853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14283981#comment-14283981 ] jaikiran pai commented on KAFKA-1853: - Updated reviewboard https://reviews.apache.org/

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

[ https://issues.apache.org/jira/browse/KAFKA-1853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14283989#comment-14283989 ] jaikiran pai commented on KAFKA-1853: - Hi [~jkreps], I've updated the patch to take in

Re: Review Request 27799: Patch for KAFKA-1760

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/27799/#review68699 --- clients/src/main/java/org/apache/kafka/clients/consumer/internals/H

Re: Review Request 30063: Patch for KAFKA-1840

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

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30083/ --- Review request for kafka. Bugs: KAFKA-1839 https://issues.apache.org/jira/b

Re: Review Request 30083: Patch for KAFKA-1839

--- 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: KAFKA-1839

Re: Review Request 30063: Patch for KAFKA-1840

--- 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: KAFKA-1840

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

[ https://issues.apache.org/jira/browse/KAFKA-1840?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284284#comment-14284284 ] Jiangjie Qin commented on KAFKA-1840: - Updated reviewboard https://reviews.apache.org/

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

[ 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] [Updated] (KAFKA-1839) Adding an afterRebalance callback to the ConsumerRebalanceListener of ZookeeperConsumerConnector

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

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

[ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284298#comment-14284298 ] Jiangjie Qin commented on KAFKA-1839: - Updated reviewboard https://reviews.apache.org/

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

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

Re: Review Request 30083: Patch for KAFKA-1839

--- 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: KAFKA-1839

Review Request 30084: Patch for KAFKA-1866

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/30084/ --- Review request for kafka. Bugs: KAFKA-1866 https://issues.apache.org/jira/b

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

[ https://issues.apache.org/jira/browse/KAFKA-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1866: -- Attachment: KAFKA-1866.patch > LogStartOffset gauge throws exceptions after log.

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284313#comment-14284313 ] Sriharsha Chintalapani commented on KAFKA-1866: --- The above patch tested by r

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

[ https://issues.apache.org/jira/browse/KAFKA-1866?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284310#comment-14284310 ] Sriharsha Chintalapani commented on KAFKA-1866: --- Created reviewboard https:/

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

[ 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] [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=14284409#comment-14284409 ] Sriharsha Chintalapani commented on KAFKA-1596: --- [~nehanarkhede] [~guozhang]

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

Aditya A Auradkar created KAFKA-1886: Summary: SimpleConsumer swallowing ClosedByInterruptException Key: KAFKA-1886 URL: https://issues.apache.org/jira/browse/KAFKA-1886 Project: Kafka Is

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-1823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284424#comment-14284424 ] Joel Koshy commented on KAFKA-1823: --- Committed to trunk. Thanks for the review. > trans

Re: Review Request 30083: Patch for KAFKA-1839

--- 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: KAFKA-1839

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

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

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

[ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284449#comment-14284449 ] Jiangjie Qin commented on KAFKA-1839: - Updated reviewboard https://reviews.apache.org/

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

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-1887) controller error message on shutting the last broker

[ https://issues.apache.org/jira/browse/KAFKA-1887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284502#comment-14284502 ] Jun Rao commented on KAFKA-1887: When shutting down the broker, we unregister the broker f

Build failed in Jenkins: Kafka-trunk #375

See Changes: [jjkoshy] KAFKA-1823; Fix transient failure in PartitionAssignorTest; reviewed by Guozhang Wang and Neha Narkhede -- [...truncated 496 lines...] kafka.log.LogTest > testAsyncDelete PASSE

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

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

[KIP-DISCUSSION] Mirror Maker Enhancement

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 wel

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

[ https://issues.apache.org/jira/browse/KAFKA-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284961#comment-14284961 ] Aditya A Auradkar commented on KAFKA-1886: -- Did a good bit of poking around. Basi

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

[ https://issues.apache.org/jira/browse/KAFKA-1886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284963#comment-14284963 ] Aditya A Auradkar commented on KAFKA-1886: -- If interested, I hacked an existing t

New consumer plans

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 rev

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

[ https://issues.apache.org/jira/browse/KAFKA-1830?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14284975#comment-14284975 ] Mingjie Lai commented on KAFKA-1830: [~guozhang] Can you tell me which JIRA or git com

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

[ https://issues.apache.org/jira/browse/KAFKA-1728?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14285029#comment-14285029 ] Jun Rao commented on KAFKA-1728: Thanks for the patch. +1 and committed to site. 1. Yes,

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

[ 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

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 n

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

[ https://issues.apache.org/jira/browse/KAFKA-1856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14285105#comment-14285105 ] Gwen Shapira commented on KAFKA-1856: - Non-binding +1 from me :) Looks good and I'm ex

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

[ https://issues.apache.org/jira/browse/KAFKA-1809?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14285116#comment-14285116 ] Gwen Shapira commented on KAFKA-1809: - Pinging [~junrao] for review :) I believe the

[jira] [Assigned] (KAFKA-853) Allow OffsetFetchRequest to initialize offsets

[ https://issues.apache.org/jira/browse/KAFKA-853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Balaji Seshadri reassigned KAFKA-853: - Assignee: Balaji Seshadri > Allow OffsetFetchRequest to initialize offsets > -

[jira] [Commented] (KAFKA-853) Allow OffsetFetchRequest to initialize offsets

[ https://issues.apache.org/jira/browse/KAFKA-853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14285162#comment-14285162 ] Mayuresh Gharat commented on KAFKA-853: --- Hi Balaji Seshadri, I am trying to understa

[jira] [Commented] (KAFKA-853) Allow OffsetFetchRequest to initialize offsets

[ https://issues.apache.org/jira/browse/KAFKA-853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14285163#comment-14285163 ] Balaji Seshadri commented on KAFKA-853: --- [~mgharat] i need to analyze more before i a