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

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

[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 for this, f

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

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

[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't have expect

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

[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 this call pr

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

[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 trunk? > Transie

[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 needs to firs

[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) in yo

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

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

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

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

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

[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]) [~fpj] yes

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

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

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

[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, pls? >

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

[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 this issue i

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

[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, {{onControllerFailover}

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

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

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

[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: https://iss

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

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

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

[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: (was: 0

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

[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 don’t have

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

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

[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 able to find out

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

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

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

[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 the pull req

[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 is to h

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

[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/com.1

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

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

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

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

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

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

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

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

[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 like that,

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

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

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

[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 to me if you'v

[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: {noformat} $G

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

[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're right t

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

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

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

[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) > Add met

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

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

[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 that if ZkC

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

[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, it ha

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

[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 with ZK i

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

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

[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 from [~junr

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

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

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

[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 offset on produc

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

[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] [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 batch with mul

[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 sure of what you

[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-2951) Additional authorization test cases

[ https://issues.apache.org/jira/browse/KAFKA-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15044830#comment-15044830 ] Flavio Junqueira commented on KAFKA-2951: - [~ijuma] thanks for the feedback, I hav

[jira] [Updated] (KAFKA-2951) Additional authorization test cases

[ https://issues.apache.org/jira/browse/KAFKA-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-2951: Description: There are a few test cases that are worth adding. I've run them manually, but

[jira] [Updated] (KAFKA-2951) Additional authorization test cases

[ https://issues.apache.org/jira/browse/KAFKA-2951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-2951: Summary: Additional authorization test cases (was: Add test cases to EndToEndAuthorizationT

[jira] [Commented] (KAFKA-2910) Failure in kafka.api.SslEndToEndAuthorizationTest.testNoGroupAcl

[ https://issues.apache.org/jira/browse/KAFKA-2910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15044814#comment-15044814 ] Flavio Junqueira commented on KAFKA-2910: - Based on this WARN: {noformat} [2015-1

[jira] [Updated] (KAFKA-2952) Add ducktape test for secure->unsecure ZK migration

[ https://issues.apache.org/jira/browse/KAFKA-2952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flavio Junqueira updated KAFKA-2952: Description: We have test cases for the unsecure -> secure path, but not the other way aroun

  1   2   >