Re: Embedding zookeeper and kafka in java process.

> On 15 Jun 2016, at 21:56, Subhash Agrawal wrote: > > [2016-06-15 13:39:39,808] DEBUG [ZkClient-EventThread-24-localhost:2181] > [Channel manager on controller 0]: Controller 0 trying to connect to broker 0 > (kafka.controller.ControllerChannelManager) The controller isn't being able to con

Re: FYI - Apache ZooKeeper Backup, a Treatise

Great write-up, Jordan, thanks! Whether to backup zk data or not is possibly an open topic for this community, even though we have discussed it at times. My sense has been that precisely because of the issues you mention in your post, it is typically best to have a way to recreate its data upon

Re: FYI - Apache ZooKeeper Backup, a Treatise

f data that you have that necessitates a backup/restore. (If >> you're >>> not at liberty to share this, then I can understand that.) It might >>> inform if we have a motivating use case for backup/restore features >> within >>> ZooKeeper, such as so

Re: Use Kafka 0.9.0.1 or 0.10.0.0 with Zookeeper 3.5

Hi Luciano, I can't remember seeing a discussion in this community about 3.5. I suspect your real question is how to set it up to use TLS/SSL because everything else should remain the same. You should be able to run a Kafka cluster as is against a 3.5 ensemble, but you won't have a secure conne

Re: [ANNOUNCE] New Kafka Committer Ewen Cheslack-Postava

Congrats, Ewen! -Flavio > On 08 Dec 2015, at 20:49, Jarek Jarcec Cecho wrote: > > Congratulations! > > Jarcec > >> On Dec 8, 2015, at 8:37 PM, Neha Narkhede wrote: >> >> I am pleased to announce that the Apache Kafka PMC has voted to >> invite Ewen Cheslack-Postava as a committer and Ewen h

Re: Interacting with a secured Kafka cluster via GSS-API

Hi Dave, I apologize for the obvious question, but have you had a look at the documentation: http://kafka.apache.org/documentation.html#security It is possible that you're not aware that it is there, so I'm just confirming. But, if you did

Re: ZkSecurityMigrator incorrectly applies ACLs to entire ZooKeeper tree?

Hi Matthew, If you're sharing a ZK ensemble and you have a specific path for the Kafka znodes, then you need to use a chroot for this. Just pass it along with the connect string: http://zookeeper.apache.org/doc/r3.4.6/zookeeperProgrammers.html#ch_zkSessions

Re: ZkSecurityMigrator incorrectly applies ACLs to entire ZooKeeper tree?

hose specific paths to then just go and perform the operation on > all of / recursively anyway. > > Thanks, > Matt > > -Original Message- > From: Flavio Junqueira [mailto:f...@apache.org] > Sent: Wednesday, January 6, 2016 4:35 AM > To: dev@kafka.apache.org > Subj

Re: 0.9.0.1 RC1

I'm also getting test failures. Here are tests that failed for me and the jiras I could find reporting the corresponding issue: org.apache.kafka.common.network.SslTransportLayerTest > testInvalidEndpointIdentification - KAFKA-2850 kafka.api.QuotasTest > testThrottledProducerConsumer - KAFKA-2444

Re: [DISCUSS] Deprecating the old Scala producers for the next release

Ismael, I'm curious about why you want to deprecate one and not the other. You say that it is premature to deprecate the old scala consumers and I'm wondering about the reasoning behind it. -Flavio > On 22 Feb 2016, at 17:36, Ismael Juma wrote: > > Hi all, > > The new Java producer was intro

Re: [DISCUSS] Deprecating the old Scala producers for the next release

o > On 23 Feb 2016, at 17:28, Ismael Juma wrote: > > Hi Flavio, > > On Tue, Feb 23, 2016 at 9:23 AM, Flavio Junqueira wrote: > >> Ismael, I'm curious about why you want to deprecate one and not the other. >> You say that it is premature to deprecate the old s

Re: [VOTE] Release plan - Kafka 0.10.0

+1 (non-binding) One clarification: there are currently 11 issues marked as blockers, is that an accurate list? http://bit.ly/21YCthZ -Flavio > On 08 Mar 2016, at 06:12, Harsha wrote: > > > +1 > > Thanks, > Harsha > On Mon, Mar 7, 2016, at 09:49 PM, Jun Rao wrote: >> +1 >> >> Thanks, >>

Re: [DISCUSS] KIP-27 - Conditional Publish

I like this feature, it reminds me of conditional updates in zookeeper. I'm not sure if it'd be best to have some mechanism for fencing rather than a conditional write like you're proposing. The reason I'm saying this is that the conditional write applies to requests individually, while it sound

Re: [DISCUSS] KIP-27 - Conditional Publish

a >>>>>>>>>>>> *prefix* of messages will be committed (right?) -- which >>> seems >>>>> to >>>>>> be >>>>>>>>>>>> enough for many cases. I'll try and come up with a mo

Re: KIP Meeting Notes 08/11/2015

From other communities, there isn't really ownership over any part of the project, so anyone is free to review any patch. If you decide to review a patch and believe that a specific person should have a look to support your recommendation because that person has more experience, just ping the pe

Re: [DISCUSSION] Kafka 0.8.2.2 release?

It is pretty typical that Apache projects have a release manager for each release: http://www.apache.org/dev/release-publishing.html It doesn't have to be the same person every time, though, not even for the same branch. -Flavio > On 17 Au

Re: Kafka KIP meeting Aug. 18

Thanks for the notes, Jun. There was a mention of single-writer behavior, if I understood correctly, in the context of the new consumer, and I was wondering if that's specific to the new consumer work or if it's going to have any dependency or relation to KIP-27. -Flavio > On 18 Aug 2015, at 2

Re: [DISCUSS] KIP-78: Cluster Id

Thanks for the KIP, Ismael, looks great. I have just a couple of comments and questions: - I assume the znode containing the cluster id is persistent. Is there ever the need to delete that znode to force a new instance id, and if so, how is it expected to happen? I'm thinking about a scenario i

Re: Maybe 0.8.3 should really be 0.9.0?

Hi Gwen, What's the expected meaning of the individual digits of the version for this community? Could you give me some insight here? -Flavio > On 08 Sep 2015, at 18:19, Gwen Shapira wrote: > > Hi Kafka Fans, > > What do you think of making the next release (the one with security, new > cons

Re: Kafka License Detail

Sugumar, The short answer is yes to both your questions, but if you have any specific concern, I suggest you have a look at the Apache License under which Kafka is distributed: http://www.apache.org/licenses/LICENSE-2.0 -Flavio > On 07 Oct 2015,

Write access to Confluence wiki

Could anyone here please grant me write access to the Confluence wiki, please? I need to work on a KIP. Thanks! -Flavio

[DISCUSS] KIP-38: ZooKeeper Authentication

I've created the following KIP and I'd appreciate any comment on the proposal: https://cwiki.apache.org/confluence/display/KAFKA/KIP-38%3A+ZooKeeper+Authentication This is in progress and there is code for most

[VOTE] KIP-38: ZooKeeper authentication

Thanks everyone for the feedback so far. At this point, I'd like to start a vote for KIP-38. Summary: Add support for ZooKeeper authentication KIP page: https://cwiki.apache.org/confluence/display/KAFKA/KIP-38%3A+ZooKeeper+Authentication

Re: [DISCUSS] KIP-38: ZooKeeper Authentication

-Flavio > On 19 Oct 2015, at 18:20, Flavio Junqueira wrote: > > I've created the following KIP and I'd appreciate any comment on the proposal: > > https://cwiki.apache.org/confluence/display/KAFKA/KIP-38%3A+ZooKeeper+Authentication > > <https://cwiki.a

Re: [VOTE] KIP-38: ZooKeeper authentication

for Zookeeper >> - Removing the "world readable" assumption >> >> Thank you, >> Grant >> >> On Wed, Oct 21, 2015 at 10:23 AM, Onur Karaman < >> okara...@linkedin.com.invalid> wrote: >> >>> +1 >>> >>> On Wed, Oc

Re: [DISCUSS] KIP-38: ZooKeeper Authentication

2015 at 9:16 AM, Ismael Juma wrote: > >> On Wed, Oct 21, 2015 at 5:04 PM, Flavio Junqueira wrote: >> >>> Bringing the points Grant brought to this thread: >>> >>>> Is it worth mentioning the follow up steps that were discussed in the >> KIP >&

Re: [DISCUSS] KIP-38: ZooKeeper Authentication

nd that SSL is only available in the 3.5 branch of ZK. -Flavio > > Thanks > Parth > > > > On 10/21/15, 9:56 AM, "Flavio Junqueira" wrote: > >> >>> On 21 Oct 2015, at 17:47, Todd Palino wrote: >>> >>> There seems to be a bit of deta

Re: [DISCUSS] KIP-38: ZooKeeper Authentication

creator can modify the path. Other ZK clients authenticated with a >> different user can read, but not modify the path. Are you concerned about >> the reads or the writes to ZK? >> >> Thanks, >> >> Jun >> >> >> >> On Wed, Oct 21, 201

Re: [DISCUSS] KIP-38: ZooKeeper Authentication

Ok, thanks for the feedback, Todd. I have updated the KIP with some of the points discussed here. There is more to add based on these last comments, though. -Flavio > On 21 Oct 2015, at 23:43, Todd Palino wrote: > > On Wed, Oct 21, 2015 at 3:38 PM, Flavio Junqueira <mailto:f..

Re: [DISCUSS] KIP-38: ZooKeeper Authentication

Ok, thanks for spotting it. -Flavio > On 22 Oct 2015, at 05:54, Jun Rao wrote: > > It seems that in the secure -> unsecure plan, step 3 needs to be done > before step 2. > > Thanks, > > Jun > > On Wed, Oct 21, 2015 at 3:59 PM, Flavio Junqueira wrote: >

Re: [DISCUSS] KIP-38: ZooKeeper Authentication

iguration?* > Say you make a mistake in your JAAS login file. If "allowSaslFailedClients" is set to true, then your client would still connect (not authenticated) silently, and you may prefer to spot that problem right up front by having the server reject the connection. -Flavio >

Re: [VOTE] KIP-38: ZooKeeper authentication

With 4 binding votes and 9 non-binding votes, the KIP-38 proposal passes. Thanks everyone for voting and comments. -Flavio > On 22 Oct 2015, at 23:34, Jun Rao wrote: > > +1 > > Thanks, > > Jun > > On Wed, Oct 21, 2015 at 8:17 AM, Flavio Junqueira wrote: &g

Re: [VOTE] KIP-38: ZooKeeper authentication

:06, Flavio Junqueira wrote: > > With 4 binding votes and 9 non-binding votes, the KIP-38 proposal passes. > > Thanks everyone for voting and comments. > > -Flavio > >> On 22 Oct 2015, at 23:34, Jun Rao wrote: >> >> +1 >> >> Thanks, >> >

Re: No log appender for zookeeper in the log4j properties

Hi Raju, Thanks for reporting the issue. There are two parts to ZK: client and server. I think your comments refer to the server logs, but you may also care about the ZK client events. In any case, I had a look at the script and the log4j properties in the Apache Kafka code base, and it does lo

Re: [VOTE] 0.9.0.0 Candiate 1

-1 (non-binding) I'm getting an error with gradle when using the source artifact because it seems to be expecting a git repository here: line 68 of build.gradle: def repo = Grgit.open(project.file('.')) and I get this message: FAILURE: Build failed with an exception. *

Re: 0.9.0.0 RC4

+1 (non-binding). Built it, ran tests, ran the rat tool separately, checked license and notice, checked digests, ran a few local smoke tests including zk auth. Looks good! -Flavio > On 23 Nov 2015, at 19:11, Harsha wrote: > > +1 (binding). > > 1. Ran unit tests > 2. Ran SSL & SASL tests usin

Re: [DISCUSS] KIP-30 Allow for brokers to have plug-able consensus and meta data storage sub systems

I'm new to this community and I don't necessarily have all the background around the complaints on ZooKeeper, but I'd like to give my opinion, even if biased. To introduce myself in the case folks here don't know me, I'm one of the guys who developed ZooKeeper originally and designed the Zab pro

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15361236#comment-15361236 ] Flavio Junqueira commented on KAFKA-873: [~mtomcat_sslavic] could be more spec

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15361397#comment-15361397 ] Flavio Junqueira commented on KAFKA-873: I see what you're saying. That s

[jira] [Commented] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404245#comment-15404245 ] Flavio Junqueira commented on KAFKA-1211: - [~junrao] let me ask a

[jira] [Comment Edited] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15404245#comment-15404245 ] Flavio Junqueira edited comment on KAFKA-1211 at 8/2/16 4:1

[jira] [Commented] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15406063#comment-15406063 ] Flavio Junqueira commented on KAFKA-1211: - Thanks for the clarification, [~ju

[jira] [Commented] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410682#comment-15410682 ] Flavio Junqueira commented on KAFKA-1211: - [~junrao] I get (2), but (1) m

[jira] [Commented] (KAFKA-1211) Hold the produce request with ack > 1 in purgatory until replicas' HW has larger than the produce offset

[ https://issues.apache.org/jira/browse/KAFKA-1211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15410693#comment-15410693 ] Flavio Junqueira commented on KAFKA-1211: - [~junrao] I was reading point (a

[jira] [Commented] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15186928#comment-15186928 ] Flavio Junqueira commented on KAFKA-3173: - There is a race in the contro

[jira] [Commented] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15187230#comment-15187230 ] Flavio Junqueira commented on KAFKA-3173: - I actually can't reorder it

[jira] [Commented] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15189024#comment-15189024 ] Flavio Junqueira commented on KAFKA-3173: - I have investigated the two r

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3173: Attachment: KAFKA-3173-race-repo.patch > Error while moving some partitions

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3173: Attachment: (was: KAFKA-3173-race-repo.patch) > Error while moving some partitions

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3173: Attachment: KAFKA-3173-race-repro.patch > Error while moving some partitions

[jira] [Commented] (KAFKA-3215) controller may not be started when there are multiple ZK session expirations

[ https://issues.apache.org/jira/browse/KAFKA-3215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190794#comment-15190794 ] Flavio Junqueira commented on KAFKA-3215: - [~junrao] Let me see if I unders

[jira] [Assigned] (KAFKA-3215) controller may not be started when there are multiple ZK session expirations

[ https://issues.apache.org/jira/browse/KAFKA-3215?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira reassigned KAFKA-3215: --- Assignee: Flavio Junqueira > controller may not be started when there are multi

[jira] [Comment Edited] (KAFKA-3215) controller may not be started when there are multiple ZK session expirations

[ https://issues.apache.org/jira/browse/KAFKA-3215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190794#comment-15190794 ] Flavio Junqueira edited comment on KAFKA-3215 at 3/11/16 1:2

[jira] [Comment Edited] (KAFKA-3215) controller may not be started when there are multiple ZK session expirations

[ https://issues.apache.org/jira/browse/KAFKA-3215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15190794#comment-15190794 ] Flavio Junqueira edited comment on KAFKA-3215 at 3/11/16 4:3

[jira] [Commented] (KAFKA-3403) Upgrade ZkClient to 0.8

[ https://issues.apache.org/jira/browse/KAFKA-3403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15198173#comment-15198173 ] Flavio Junqueira commented on KAFKA-3403: - http://mvnrepository.com/artifact

[jira] [Commented] (KAFKA-3403) Upgrade ZkClient to 0.8

[ https://issues.apache.org/jira/browse/KAFKA-3403?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15198172#comment-15198172 ] Flavio Junqueira commented on KAFKA-3403: - [~granthenke] zkclient 0.8 is alr

[jira] [Commented] (KAFKA-3210) Using asynchronous calls through the raw ZK API in ZkUtils

[ https://issues.apache.org/jira/browse/KAFKA-3210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15206935#comment-15206935 ] Flavio Junqueira commented on KAFKA-3210: - [~granthenke] my main goal here i

[jira] [Commented] (KAFKA-3205) Error in I/O with host (java.io.EOFException) raised in producer

[ https://issues.apache.org/jira/browse/KAFKA-3205?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15220339#comment-15220339 ] Flavio Junqueira commented on KAFKA-3205: - [~bondj] I've commented on

[jira] [Commented] (KAFKA-3469) kafka-topics lock down znodes with user principal when zk security is enabled.

[ https://issues.apache.org/jira/browse/KAFKA-3469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15221262#comment-15221262 ] Flavio Junqueira commented on KAFKA-3469: - [~singhashish] I'm sorry, I m

[jira] [Commented] (KAFKA-3469) kafka-topics lock down znodes with user principal when zk security is enabled.

[ https://issues.apache.org/jira/browse/KAFKA-3469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15222336#comment-15222336 ] Flavio Junqueira commented on KAFKA-3469: - [~singhashish] right, you're

[jira] [Created] (KAFKA-3524) ConnectorTaskId should also also include cluster id

Flavio Junqueira created KAFKA-3524: --- Summary: ConnectorTaskId should also also include cluster id Key: KAFKA-3524 URL: https://issues.apache.org/jira/browse/KAFKA-3524 Project: Kafka

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15232535#comment-15232535 ] Flavio Junqueira commented on KAFKA-3042: - Here is what I've been abl

[jira] [Comment Edited] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15232535#comment-15232535 ] Flavio Junqueira edited comment on KAFKA-3042 at 4/9/16 1:0

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15233564#comment-15233564 ] Flavio Junqueira commented on KAFKA-3042: - [~delbaeth] thanks for all

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15236055#comment-15236055 ] Flavio Junqueira commented on KAFKA-3042: - Thanks for the logs. I still d

[jira] [Comment Edited] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15236055#comment-15236055 ] Flavio Junqueira edited comment on KAFKA-3042 at 4/11/16 9:5

[jira] [Resolved] (KAFKA-3205) Error in I/O with host (java.io.EOFException) raised in producer

[ https://issues.apache.org/jira/browse/KAFKA-3205?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira resolved KAFKA-3205. - Resolution: Won't Fix Reviewer: Flavio Junqueira Fix Version/s:

[jira] [Comment Edited] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15236055#comment-15236055 ] Flavio Junqueira edited comment on KAFKA-3042 at 4/12/16 2:5

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15237383#comment-15237383 ] Flavio Junqueira commented on KAFKA-3042: - I had a look at the zookeeper

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15237824#comment-15237824 ] Flavio Junqueira commented on KAFKA-3042: - hey [~wushujames] bq. you said

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15241314#comment-15241314 ] Flavio Junqueira commented on KAFKA-3042: - [~junrao] In this comment: h

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15245725#comment-15245725 ] Flavio Junqueira commented on KAFKA-3042: - I checked the broker change list

[jira] [Commented] (KAFKA-3042) updateIsr should stop after failed several times due to zkVersion issue

[ https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15247802#comment-15247802 ] Flavio Junqueira commented on KAFKA-3042: - [~junrao] It makes sense, thanks

[jira] [Commented] (KAFKA-3128) Add metrics for ZooKeeper events

[ https://issues.apache.org/jira/browse/KAFKA-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15254591#comment-15254591 ] Flavio Junqueira commented on KAFKA-3128: - [~junrao] Perhaps we can do more

[jira] [Created] (KAFKA-3640) Reduce the latency of topic metadata requests

Flavio Junqueira created KAFKA-3640: --- Summary: Reduce the latency of topic metadata requests Key: KAFKA-3640 URL: https://issues.apache.org/jira/browse/KAFKA-3640 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272070#comment-15272070 ] Flavio Junqueira commented on KAFKA-3173: - [~junrao] True, {{onControllerFail

[jira] [Updated] (KAFKA-3173) Error while moving some partitions to OnlinePartition state

[ https://issues.apache.org/jira/browse/KAFKA-3173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3173: Status: Open (was: Patch Available) > Error while moving some partitions

[jira] [Commented] (KAFKA-3525) max.reserved.broker.id off-by-one error

[ https://issues.apache.org/jira/browse/KAFKA-3525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272234#comment-15272234 ] Flavio Junqueira commented on KAFKA-3525: - I'm a bit confused by what t

[jira] [Created] (KAFKA-3660) Log exception message in ControllerBrokerRequestBatch

Flavio Junqueira created KAFKA-3660: --- Summary: Log exception message in ControllerBrokerRequestBatch Key: KAFKA-3660 URL: https://issues.apache.org/jira/browse/KAFKA-3660 Project: Kafka

[jira] [Commented] (KAFKA-3660) Log exception message in ControllerBrokerRequestBatch

[ https://issues.apache.org/jira/browse/KAFKA-3660?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15272265#comment-15272265 ] Flavio Junqueira commented on KAFKA-3660: - [~ijuma] could you have a look,

[jira] [Commented] (KAFKA-3525) max.reserved.broker.id off-by-one error

[ https://issues.apache.org/jira/browse/KAFKA-3525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15273215#comment-15273215 ] Flavio Junqueira commented on KAFKA-3525: - Got it, thank you both for

[jira] [Commented] (KAFKA-3686) Kafka producer is not fault tolerant

[ https://issues.apache.org/jira/browse/KAFKA-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15281490#comment-15281490 ] Flavio Junqueira commented on KAFKA-3686: - [~lethalman] thanks for bringing

[jira] [Commented] (KAFKA-3686) Kafka producer is not fault tolerant

[ https://issues.apache.org/jira/browse/KAFKA-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15281505#comment-15281505 ] Flavio Junqueira commented on KAFKA-3686: - [~lethalman] Jira is on lock

[jira] [Commented] (KAFKA-3686) Kafka producer is not fault tolerant

[ https://issues.apache.org/jira/browse/KAFKA-3686?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15281508#comment-15281508 ] Flavio Junqueira commented on KAFKA-3686: - (on behalf of [~lethalman]) [

[jira] [Created] (KAFKA-3709) Create project security page

Flavio Junqueira created KAFKA-3709: --- Summary: Create project security page Key: KAFKA-3709 URL: https://issues.apache.org/jira/browse/KAFKA-3709 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-2979) Enable authorizer and ACLs in ducktape tests

Flavio Junqueira created KAFKA-2979: --- Summary: Enable authorizer and ACLs in ducktape tests Key: KAFKA-2979 URL: https://issues.apache.org/jira/browse/KAFKA-2979 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-2997) Synchronous write to disk

[ https://issues.apache.org/jira/browse/KAFKA-2997?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15060260#comment-15060260 ] Flavio Junqueira commented on KAFKA-2997: - [~afirus] I'm not very sur

[jira] [Commented] (KAFKA-3038) Speeding up partition reassignment after broker failure

[ https://issues.apache.org/jira/browse/KAFKA-3038?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15085300#comment-15085300 ] Flavio Junqueira commented on KAFKA-3038: - You don't really need to b

[jira] [Created] (KAFKA-3069) Fix recursion in ZkSecurityMigrator

Flavio Junqueira created KAFKA-3069: --- Summary: Fix recursion in ZkSecurityMigrator Key: KAFKA-3069 URL: https://issues.apache.org/jira/browse/KAFKA-3069 Project: Kafka Issue Type: Bug

[jira] [Assigned] (KAFKA-3069) Fix recursion in ZkSecurityMigrator

[ https://issues.apache.org/jira/browse/KAFKA-3069?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira reassigned KAFKA-3069: --- Assignee: Flavio Junqueira > Fix recursion in ZkSecurityMigra

[jira] [Updated] (KAFKA-2260) Allow specifying expected offset on produce

[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-2260: Patch is stale, I'm uploading an updated version. > Allow specifying expected o

[jira] [Updated] (KAFKA-2260) Allow specifying expected offset on produce

[ https://issues.apache.org/jira/browse/KAFKA-2260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-2260: Attachment: KAFKA-2260.patch I understand we are doing patchers through github push

[jira] [Commented] (KAFKA-3083) a soft failure in controller may leader a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15095920#comment-15095920 ] Flavio Junqueira commented on KAFKA-3083: - @mayuresh the fact that A kept g

[jira] [Comment Edited] (KAFKA-3083) a soft failure in controller may leader a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15095920#comment-15095920 ] Flavio Junqueira edited comment on KAFKA-3083 at 1/13/16 10:0

[jira] [Commented] (KAFKA-3083) a soft failure in controller may leader a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15097302#comment-15097302 ] Flavio Junqueira commented on KAFKA-3083: - It sounds like this comment

[jira] [Commented] (KAFKA-3083) a soft failure in controller may leader a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15097330#comment-15097330 ] Flavio Junqueira commented on KAFKA-3083: - One clarification, if broker A shr

[jira] [Created] (KAFKA-3107) Error when trying to shut down auto balancing scheduler of controller

Flavio Junqueira created KAFKA-3107: --- Summary: Error when trying to shut down auto balancing scheduler of controller Key: KAFKA-3107 URL: https://issues.apache.org/jira/browse/KAFKA-3107 Project

[jira] [Commented] (KAFKA-3083) a soft failure in controller may leader a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15101993#comment-15101993 ] Flavio Junqueira commented on KAFKA-3083: - Hey [~mgharat], Best practice wit

[jira] [Updated] (KAFKA-3083) a soft failure in controller may leave a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3083: Summary: a soft failure in controller may leave a topic partition in an inconsistent state

[jira] [Commented] (KAFKA-3083) a soft failure in controller may leave a topic partition in an inconsistent state

[ https://issues.apache.org/jira/browse/KAFKA-3083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15105587#comment-15105587 ] Flavio Junqueira commented on KAFKA-3083: - [~junrao] bq. does controller A

  1   2   3   >