[jira] [Assigned] (KAFKA-4261) Provide debug option in vagrant-up.sh

[ https://issues.apache.org/jira/browse/KAFKA-4261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira reassigned KAFKA-4261: --- Assignee: Flavio Junqueira > Provide debug option in vagrant-up

[jira] [Created] (KAFKA-4261) Provide debug option in vagrant-up.sh

Flavio Junqueira created KAFKA-4261: --- Summary: Provide debug option in vagrant-up.sh Key: KAFKA-4261 URL: https://issues.apache.org/jira/browse/KAFKA-4261 Project: Kafka Issue Type

[jira] [Commented] (KAFKA-3985) Transient system test failure ZooKeeperSecurityUpgradeTest.test_zk_security_upgrade.security_protocol

[ https://issues.apache.org/jira/browse/KAFKA-3985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15549221#comment-15549221 ] Flavio Junqueira commented on KAFKA-3985: - I've created a pull request

[jira] [Assigned] (KAFKA-3985) Transient system test failure ZooKeeperSecurityUpgradeTest.test_zk_security_upgrade.security_protocol

[ https://issues.apache.org/jira/browse/KAFKA-3985?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira reassigned KAFKA-3985: --- Assignee: Flavio Junqueira > Transient system test fail

[jira] [Comment Edited] (KAFKA-3985) Transient system test failure ZooKeeperSecurityUpgradeTest.test_zk_security_upgrade.security_protocol

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

[jira] [Commented] (KAFKA-3985) Transient system test failure ZooKeeperSecurityUpgradeTest.test_zk_security_upgrade.security_protocol

[ https://issues.apache.org/jira/browse/KAFKA-3985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15548125#comment-15548125 ] Flavio Junqueira commented on KAFKA-3985: - [~rsivaram] .bq I wouldn&#x

[jira] [Commented] (KAFKA-3985) Transient system test failure ZooKeeperSecurityUpgradeTest.test_zk_security_upgrade.security_protocol

[ https://issues.apache.org/jira/browse/KAFKA-3985?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15545834#comment-15545834 ] Flavio Junqueira commented on KAFKA-3985: - We have been observing in our sy

[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=15536047#comment-15536047 ] Flavio Junqueira commented on KAFKA-873: One clarification here, isn't

[jira] [Commented] (KAFKA-4196) Transient test failure: DeleteConsumerGroupTest.testConsumptionOnRecreatedTopicAfterTopicWideDeleteInZK

[ https://issues.apache.org/jira/browse/KAFKA-4196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507443#comment-15507443 ] Flavio Junqueira commented on KAFKA-4196: - After a cursory look, it looks lik

[jira] [Commented] (KAFKA-4196) Transient test failure: DeleteConsumerGroupTest.testConsumptionOnRecreatedTopicAfterTopicWideDeleteInZK

[ https://issues.apache.org/jira/browse/KAFKA-4196?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15507287#comment-15507287 ] Flavio Junqueira commented on KAFKA-4196: - [~ijuma] is this from t

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

[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=15419984#comment-15419984 ] Flavio Junqueira commented on KAFKA-1211: - [~junrao] bq. the leader need

[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-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=15406063#comment-15406063 ] Flavio Junqueira commented on KAFKA-1211: - Thanks for the clarification, [~ju

[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=15404245#comment-15404245 ] Flavio Junqueira commented on KAFKA-1211: - [~junrao] let me ask a

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

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

[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] [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] [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=15281490#comment-15281490 ] Flavio Junqueira commented on KAFKA-3686: - [~lethalman] thanks for bringing

[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-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] [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-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] [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-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] [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-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] [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-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=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=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=15237383#comment-15237383 ] Flavio Junqueira commented on KAFKA-3042: - I had a look at the zookeeper

[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] [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/11/16 9: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=15236055#comment-15236055 ] Flavio Junqueira commented on KAFKA-3042: - Thanks for the logs. I still d

[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] [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=15232535#comment-15232535 ] Flavio Junqueira commented on KAFKA-3042: - Here is what I've been abl

[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-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] [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-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-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-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-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] [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] [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] [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] [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] [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] [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-repo.patch > Error while moving some partitions

[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] [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=15186928#comment-15186928 ] Flavio Junqueira commented on KAFKA-3173: - There is a race in the contro

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

[jira] [Created] (KAFKA-3305) JMX in AWS instance

Flavio Junqueira created KAFKA-3305: --- Summary: JMX in AWS instance Key: KAFKA-3305 URL: https://issues.apache.org/jira/browse/KAFKA-3305 Project: Kafka Issue Type: Improvement

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

[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=15158807#comment-15158807 ] Flavio Junqueira commented on KAFKA-3042: - bq. I think this is because the br

[jira] [Commented] (KAFKA-1382) Update zkVersion on partition state update failures

[ https://issues.apache.org/jira/browse/KAFKA-1382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15158799#comment-15158799 ] Flavio Junqueira commented on KAFKA-1382: - hi there, it isn't clear

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

[jira] [Commented] (KAFKA-3167) Use local to the workspace Gradle cache and recreate it on every build

[ https://issues.apache.org/jira/browse/KAFKA-3167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142761#comment-15142761 ] Flavio Junqueira commented on KAFKA-3167: - we currently have this: {nofo

[jira] [Updated] (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:all-tabpanel ] Flavio Junqueira updated KAFKA-3210: Description: We have observed a number of issues with the controller interaction with

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

[ https://issues.apache.org/jira/browse/KAFKA-2818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-2818: Assignee: Flavio Junqueira (was: Neha Narkhede) Status: Open (was: Patch Available

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

[ https://issues.apache.org/jira/browse/KAFKA-2818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15136147#comment-15136147 ] Flavio Junqueira commented on KAFKA-2818: - [~mbr...@blackberry.com] You'

[jira] [Commented] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

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

[jira] [Updated] (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:all-tabpanel ] Flavio Junqueira updated KAFKA-3210: Assignee: (was: Neha Narkhede) > Using asynchronous calls through the raw ZK API

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

Flavio Junqueira created KAFKA-3210: --- Summary: Using asynchronous calls through the raw ZK API in ZkUtils Key: KAFKA-3210 URL: https://issues.apache.org/jira/browse/KAFKA-3210 Project: Kafka

[jira] [Commented] (KAFKA-3197) Producer can send message out of order even when in flight request is set to 1.

[ https://issues.apache.org/jira/browse/KAFKA-3197?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15132571#comment-15132571 ] Flavio Junqueira commented on KAFKA-3197: - Treating it as a bug sounds right

[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: Description: We observed another instance of the problem reported in KAFKA-2300, but this

[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: Description: We observed another instance of the problem reported in KAFKA-2300, but this

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

Flavio Junqueira created KAFKA-3173: --- Summary: Error while moving some partitions to OnlinePartition state Key: KAFKA-3173 URL: https://issues.apache.org/jira/browse/KAFKA-3173 Project: Kafka

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

[ https://issues.apache.org/jira/browse/KAFKA-3128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-3128: Summary: Add metrics for ZooKeeper events (was: Add metric for ZooKeeper events) >

[jira] [Created] (KAFKA-3128) Add metric for ZooKeeper events

Flavio Junqueira created KAFKA-3128: --- Summary: Add metric for ZooKeeper events Key: KAFKA-3128 URL: https://issues.apache.org/jira/browse/KAFKA-3128 Project: Kafka Issue Type: Improvement

[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=15110748#comment-15110748 ] Flavio Junqueira commented on KAFKA-3083: - Sure, we need to transform

[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=15110680#comment-15110680 ] Flavio Junqueira commented on KAFKA-3083: - bq. 1) We need to use a multi-op

[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=15105762#comment-15105762 ] Flavio Junqueira commented on KAFKA-3083: - Another thing to mention is tha

[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=15105612#comment-15105612 ] Flavio Junqueira commented on KAFKA-3083: - [~mgharat] bq. I was just thinkin

[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=15105597#comment-15105597 ] Flavio Junqueira commented on KAFKA-3083: - [~junrao] bq. Even if it exists

[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

[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 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] [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=15097330#comment-15097330 ] Flavio Junqueira commented on KAFKA-3083: - One clarification, if broker A shr

[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] [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=15095920#comment-15095920 ] Flavio Junqueira commented on KAFKA-3083: - @mayuresh the fact that A kept g

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

  1   2   3   >