[jira] [Commented] (KAFKA-123) Rubygem gemspec doesn't build correctly

[ https://issues.apache.org/jira/browse/KAFKA-123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592352#comment-13592352 ] Colin B. commented on KAFKA-123: This was a duplicate of Kafka-135 and is already fixed.

Re: Flume-NG Kafka Channel

Jonathan, My understanding is that channel is a local concept in Flume. So, are you using a single local Kafka broker to build channel? Will it make more sense to build a Kafka sink in Fume? Thanks, Jun On Fri, Mar 1, 2013 at 10:56 PM, Jonathan Creasy j...@box.com wrote: I started hacking on

Re: Producer-side persistence and re-sending

Matan, Thanks for picking this up. Yes, this is likely a post 0.8 item and should go into trunk. Could you file a jira and post your initial design there for discussion? Jun On Sat, Mar 2, 2013 at 12:53 PM, matan ma...@cloudaloe.org wrote: Hi, I am designing a patch on top the 0.8 code

[jira] [Closed] (KAFKA-135) the ruby kafka gem is not functional

[ https://issues.apache.org/jira/browse/KAFKA-135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao closed KAFKA-135. - Assignee: Pierre-Yves Ritschard the ruby kafka gem is not functional

[jira] [Closed] (KAFKA-123) Rubygem gemspec doesn't build correctly

[ https://issues.apache.org/jira/browse/KAFKA-123?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao closed KAFKA-123. - Rubygem gemspec doesn't build correctly --- Key:

[jira] [Created] (KAFKA-781) Add option to the controlled shutdown tool to timeout after n secs

Neha Narkhede created KAFKA-781: --- Summary: Add option to the controlled shutdown tool to timeout after n secs Key: KAFKA-781 URL: https://issues.apache.org/jira/browse/KAFKA-781 Project: Kafka

[jira] [Commented] (KAFKA-97) SocketServer.scala refers to Handler-specific variables

[ https://issues.apache.org/jira/browse/KAFKA-97?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592405#comment-13592405 ] Colin B. commented on KAFKA-97: --- The code referenced no longer exists in 0.8. On quick

[jira] [Resolved] (KAFKA-97) SocketServer.scala refers to Handler-specific variables

[ https://issues.apache.org/jira/browse/KAFKA-97?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-97. -- Resolution: Not A Problem Fix Version/s: 0.8 SocketServer.scala refers to Handler-specific variables

[jira] [Created] (KAFKA-782) replicas not being displayed in TopicMetadataResponse when replica's Broker is shutdown

Chris Curtin created KAFKA-782: -- Summary: replicas not being displayed in TopicMetadataResponse when replica's Broker is shutdown Key: KAFKA-782 URL: https://issues.apache.org/jira/browse/KAFKA-782

[jira] [Work started] (KAFKA-97) SocketServer.scala refers to Handler-specific variables

[ https://issues.apache.org/jira/browse/KAFKA-97?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-97 started by Jun Rao. SocketServer.scala refers to Handler-specific variables ---

[jira] Subscription: outstanding kafka patches

Issue Subscription Filter: outstanding kafka patches (58 issues) The list of outstanding kafka patches Subscriber: kafka-mailing-list Key Summary KAFKA-779 Standardize Zk data structures for Re-assign partitions and Preferred replication election

[jira] [Created] (KAFKA-784) creating topic without partitions, deleting then creating with partition causes errors in 'kafka-list-topic'

Chris Curtin created KAFKA-784: -- Summary: creating topic without partitions, deleting then creating with partition causes errors in 'kafka-list-topic' Key: KAFKA-784 URL:

[jira] [Commented] (KAFKA-782) replicas not being displayed in TopicMetadataResponse when replica's Broker is shutdown

[ https://issues.apache.org/jira/browse/KAFKA-782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592565#comment-13592565 ] Chris Curtin commented on KAFKA-782: Confirmed same behavior with 0.8.0 HEAD as of

[jira] [Commented] (KAFKA-783) Preferred replica assignment on leader failure may not be correct

[ https://issues.apache.org/jira/browse/KAFKA-783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592566#comment-13592566 ] Chris Curtin commented on KAFKA-783: Confirmed same behavior on 0.8.0 HEAD as of

[jira] [Updated] (KAFKA-763) Add an option to replica from the largest offset during unclean leader election

[ https://issues.apache.org/jira/browse/KAFKA-763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-763: Labels: kafka-0.8 p2 (was: p2) Add an option to replica from the largest offset during

[jira] [Updated] (KAFKA-779) Standardize Zk data structures for Re-assign partitions and Preferred replication election

[ https://issues.apache.org/jira/browse/KAFKA-779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-779: Attachment: kafka-779-v2.patch Modified the description of the --path-to-json-file option required

[jira] [Created] (KAFKA-785) jsonFileOpt in PreferredReplicaLeaderElectionTool should not be required

Swapnil Ghike created KAFKA-785: --- Summary: jsonFileOpt in PreferredReplicaLeaderElectionTool should not be required Key: KAFKA-785 URL: https://issues.apache.org/jira/browse/KAFKA-785 Project: Kafka

[jira] [Assigned] (KAFKA-780) Reassign partitions tool produces NPE in shutdown handler

[ https://issues.apache.org/jira/browse/KAFKA-780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike reassigned KAFKA-780: --- Assignee: Sriram Subramanian Reassign partitions tool produces NPE in shutdown handler

[jira] [Resolved] (KAFKA-741) Improve log cleaning dedupe buffer efficiency

[ https://issues.apache.org/jira/browse/KAFKA-741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jay Kreps resolved KAFKA-741. - Resolution: Duplicate This issue is fixed in the patch for KAFKA-739. It removes the duplication using a

[jira] [Assigned] (KAFKA-785) jsonFileOpt in PreferredReplicaLeaderElectionTool should not be required

[ https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike reassigned KAFKA-785: --- Assignee: Swapnil Ghike (was: Sriram Subramanian) jsonFileOpt in

[jira] [Updated] (KAFKA-785) Resolve bugs in PreferredReplicaLeaderElection admin tool

[ https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-785: Summary: Resolve bugs in PreferredReplicaLeaderElection admin tool (was: jsonFileOpt in

[jira] [Updated] (KAFKA-785) Resolve bugs in PreferredReplicaLeaderElection admin tool

[ https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-785: Description: 1. Since we run the preferred replica election on all partitions if the jsonFile is

[jira] [Updated] (KAFKA-780) Reassign partitions tool produces NPE in shutdown handler

[ https://issues.apache.org/jira/browse/KAFKA-780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-780: Issue Type: Sub-task (was: Bug) Parent: KAFKA-785 Reassign partitions tool produces

[jira] [Updated] (KAFKA-785) Resolve bugs in PreferredReplicaLeaderElection admin tool

[ https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriram Subramanian updated KAFKA-785: - Attachment: KAFKA-785.patch 1. Made partition input file optional for

[jira] [Updated] (KAFKA-717) scala 2.10 build support

[ https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Darren Sargent updated KAFKA-717: - Attachment: kafka_scala_2.10.tar.gz scala 2.10 build support

[jira] [Commented] (KAFKA-717) scala 2.10 build support

[ https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592834#comment-13592834 ] Darren Sargent commented on KAFKA-717: -- I got Kafka 0.8 to compile and run with Scala

[jira] [Commented] (KAFKA-785) Resolve bugs in PreferredReplicaLeaderElection admin tool

[ https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592837#comment-13592837 ] Swapnil Ghike commented on KAFKA-785: - Can we use val jsonString = if

[jira] [Commented] (KAFKA-772) System Test Transient Failure on testcase_0122

[ https://issues.apache.org/jira/browse/KAFKA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592839#comment-13592839 ] Sriram Subramanian commented on KAFKA-772: -- I would like WARN to be actionable. Do

[jira] [Commented] (KAFKA-785) Resolve bugs in PreferredReplicaLeaderElection admin tool

[ https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592841#comment-13592841 ] Sriram Subramanian commented on KAFKA-785: -- It does not simplify anything though.

[jira] [Commented] (KAFKA-785) Resolve bugs in PreferredReplicaLeaderElection admin tool

[ https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592844#comment-13592844 ] Swapnil Ghike commented on KAFKA-785: - Well, you avoid a small jump in logic (jsonFile

[jira] [Commented] (KAFKA-717) scala 2.10 build support

[ https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592862#comment-13592862 ] Scott Carey commented on KAFKA-717: --- It appears that the changes are back-compatible with

[jira] [Created] (KAFKA-786) Use withRequiredArg while parsing jopt options in all tools

Swapnil Ghike created KAFKA-786: --- Summary: Use withRequiredArg while parsing jopt options in all tools Key: KAFKA-786 URL: https://issues.apache.org/jira/browse/KAFKA-786 Project: Kafka Issue

[jira] [Commented] (KAFKA-786) Use withRequiredArg while parsing jopt options in all tools

[ https://issues.apache.org/jira/browse/KAFKA-786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592863#comment-13592863 ] Swapnil Ghike commented on KAFKA-786: - Also note that withRequiredArg() does not check

[jira] [Comment Edited] (KAFKA-786) Use withRequiredArg while parsing jopt options in all tools

[ https://issues.apache.org/jira/browse/KAFKA-786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592863#comment-13592863 ] Swapnil Ghike edited comment on KAFKA-786 at 3/5/13 12:46 AM: --

[jira] [Assigned] (KAFKA-785) Resolve bugs in PreferredReplicaLeaderElection admin tool

[ https://issues.apache.org/jira/browse/KAFKA-785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike reassigned KAFKA-785: --- Assignee: Swapnil Ghike (was: Sriram Subramanian) Resolve bugs in

[jira] [Assigned] (KAFKA-786) Use withRequiredArg while parsing jopt options in all tools

[ https://issues.apache.org/jira/browse/KAFKA-786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike reassigned KAFKA-786: --- Assignee: Swapnil Ghike Use withRequiredArg while parsing jopt options in all tools

[jira] [Commented] (KAFKA-554) Move all per-topic configuration into ZK and add to the CreateTopicCommand

[ https://issues.apache.org/jira/browse/KAFKA-554?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592883#comment-13592883 ] Jay Kreps commented on KAFKA-554: - Yeah I thought about json vs properties. The advantage i

[jira] [Commented] (KAFKA-513) Add state change log to Kafka brokers

[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592884#comment-13592884 ] Neha Narkhede commented on KAFKA-513: - Thanks for the patch! This patch is great and is

[jira] [Updated] (KAFKA-778) Fix unclear exceptions when the producer detects 0 partitions for a topic

[ https://issues.apache.org/jira/browse/KAFKA-778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-778: Labels: kafka-0.8 (was: ) Fix unclear exceptions when the producer detects 0 partitions for a

[jira] [Commented] (KAFKA-717) scala 2.10 build support

[ https://issues.apache.org/jira/browse/KAFKA-717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13592900#comment-13592900 ] Scott Carey commented on KAFKA-717: --- I take that back, scala.annotation.StaticAnnotation

[jira] [Resolved] (KAFKA-772) System Test Transient Failure on testcase_0122

[ https://issues.apache.org/jira/browse/KAFKA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-772. --- Resolution: Fixed Fix Version/s: 0.8 Thanks for the patch. Committed to 0.8. System

[jira] [Updated] (KAFKA-732) MirrorMaker with shallow.iterator.enable=true produces unreadble messages

[ https://issues.apache.org/jira/browse/KAFKA-732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-732: -- Affects Version/s: 0.8 MirrorMaker with shallow.iterator.enable=true produces unreadble messages