RE: Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk)

2015-11-05 Thread Matthew Bruce
Hi Grant, Creating a patch for this issue actually wasn't a whole lot of work. I've uploaded one to the JIRA ticket. Thanks, Matt -Original Message- From: Matthew Bruce Sent: Thursday, November 5, 2015 3:52 PM To: 'dev@kafka.apache.org' <dev@kafka.apache.org> Subject: RE: Repli

RE: Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk)

2015-11-05 Thread Matthew Bruce
out KIP-35 and participate in the discussion/design here: https://cwiki.apache.org/confluence/display/KAFKA/KIP-35+-+Retrieving+protocol+version Thanks, Grant On Thu, Nov 5, 2015 at 2:18 PM, Matthew Bruce <mbr...@blackberry.com> wrote: > Hello Kafka Devs, > > I've been test

RE: Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk)

2015-11-05 Thread Matthew Bruce
, Matthew Bruce <mbr...@blackberry.com> wrote: > Hi Grant, > > Yes, I have read and followed the Upgrade documentation and I have set > inter.broker.protocol.version=0.8.2.X and it does not resolve the > issue - based on the part of the code it's occurring in, it uses the 'latest'

RE: Replication Broken between Kafka 0.8.2.1 and 0.9 (trunk)

2015-11-05 Thread Matthew Bruce
to be sure of the background. Are you interested in opening a jira and contributing a patch? If not would you be interested in testing a patch if I provided one? Thank you, Grant On Thu, Nov 5, 2015 at 2:31 PM, Matthew Bruce <mbr...@blackberry.com> wrote: > Hi Grant, > > Yes, I have re

RE: ZkSecurityMigrator incorrectly applies ACLs to entire ZooKeeper tree?

2016-01-06 Thread Matthew Bruce
an unauthorized user will be able to delete child nodes under the sub-tree root: http://zookeeper.apache.org/doc/r3.4.6/zookeeperProgrammers.html#sc_ACLPermissions <http://zookeeper.apache.org/doc/r3.4.6/zookeeperProgrammers.html#sc_ACLPermissions> -Flavio > On 05 Jan 2016, at

ZkSecurityMigrator incorrectly applies ACLs to entire ZooKeeper tree?

2016-01-05 Thread Matthew Bruce
;.format(path)) zkUtils.makeSurePersistentPathExists(path) } setAclsRecursively("/") . . . Am I missing something here, or should the setAclsRecursively call be moved into the loop and be called against each specific path? Thanks, Matthew Bruce mbr...@blackbery.com

[jira] [Updated] (KAFKA-2818) Clean up Controller Object on forced Resignation

2015-11-12 Thread Matthew Bruce (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew Bruce updated KAFKA-2818: - Attachment: KAFKA-2818.patch > Clean up Controller Object on forced Resignat

[jira] [Created] (KAFKA-2818) Clean up Controller Object on forced Resignation

2015-11-12 Thread Matthew Bruce (JIRA)
Matthew Bruce created KAFKA-2818: Summary: Clean up Controller Object on forced Resignation Key: KAFKA-2818 URL: https://issues.apache.org/jira/browse/KAFKA-2818 Project: Kafka Issue Type

[jira] [Updated] (KAFKA-2818) Clean up Controller Object on forced Resignation

2015-11-12 Thread Matthew Bruce (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew Bruce updated KAFKA-2818: - Status: Patch Available (was: Open) diff --git a/core/src/main/scala/kafka/controller

[jira] [Updated] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

2015-11-05 Thread Matthew Bruce (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew Bruce updated KAFKA-2756: - Affects Version/s: 0.9.0.0 Status: Patch Available (was: Open) diff --git

[jira] [Updated] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

2015-11-05 Thread Matthew Bruce (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew Bruce updated KAFKA-2756: - Attachment: KAFKA-2756.patch > Replication Broken between Kafka 0.8.2.1 and

[jira] [Created] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocl version

2015-11-05 Thread Matthew Bruce (JIRA)
Matthew Bruce created KAFKA-2756: Summary: Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocl version Key: KAFKA-2756 URL: https://issues.apache.org/jira/browse/KAFKA-2756

[jira] [Updated] (KAFKA-2756) Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong protocol version

2015-11-05 Thread Matthew Bruce (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2756?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthew Bruce updated KAFKA-2756: - Summary: Replication Broken between Kafka 0.8.2.1 and 0.9 - NetworkClient.java uses wrong

[jira] [Commented] (KAFKA-2818) Clean up Controller Object on forced Resignation

2016-02-26 Thread Matthew Bruce (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15169173#comment-15169173 ] Matthew Bruce commented on KAFKA-2818: -- [~fpj] You would definitely know that code better than me