[jira] [Commented] (KAFKA-2893) Add Negative Partition Seek Check

[ https://issues.apache.org/jira/browse/KAFKA-2893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15037651#comment-15037651 ] jin xing commented on KAFKA-2893: - I can reproduce this; when we call consumer.seek(partit

[jira] [Assigned] (KAFKA-2870) Support configuring operationRetryTimeout of underlying ZkClient through ZkUtils constructor

[ https://issues.apache.org/jira/browse/KAFKA-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jakub Nowak reassigned KAFKA-2870: -- Assignee: Jakub Nowak > Support configuring operationRetryTimeout of underlying ZkClient throug

[GitHub] kafka pull request: KAFKA-2870: add optional operationRetryTimeout...

GitHub user Mszak opened a pull request: https://github.com/apache/kafka/pull/624 KAFKA-2870: add optional operationRetryTimeout parameter to apply method in ZKUtils. You can merge this pull request into a Git repository by running: $ git pull https://github.com/Mszak/kafka k

[jira] [Commented] (KAFKA-2870) Support configuring operationRetryTimeout of underlying ZkClient through ZkUtils constructor

[ https://issues.apache.org/jira/browse/KAFKA-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15037752#comment-15037752 ] ASF GitHub Bot commented on KAFKA-2870: --- GitHub user Mszak opened a pull request:

[jira] [Updated] (KAFKA-2870) Support configuring operationRetryTimeout of underlying ZkClient through ZkUtils constructor

[ https://issues.apache.org/jira/browse/KAFKA-2870?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jakub Nowak updated KAFKA-2870: --- Status: Patch Available (was: Open) > Support configuring operationRetryTimeout of underlying ZkClien

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

I’m on an extended vacation but "a native consensus implementation in Kafka" is one of my favorite topics so I’m compelled to chime in :) I have actually been thinking along the same lines that Jay is saying after reading the Raft paper - a couple of us at LinkedIn have had casual discussions about

[GitHub] kafka pull request: Add Rolling Upgrade Notes to Security Docs

GitHub user benstopford opened a pull request: https://github.com/apache/kafka/pull/625 Add Rolling Upgrade Notes to Security Docs And added info about the krb5.conf file as we don't appear to mention that in the current docs You can merge this pull request into a Git repository by

[GitHub] kafka pull request: MINOR: Manually ported changes in 8c3c9548b636...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/620 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

[ https://issues.apache.org/jira/browse/KAFKA-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15038059#comment-15038059 ] Guozhang Wang commented on KAFKA-2933: -- Another example: https://builds.apache.org/j

[jira] [Commented] (KAFKA-2718) Reuse of temporary directories leading to transient unit test failures

[ https://issues.apache.org/jira/browse/KAFKA-2718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15038061#comment-15038061 ] Guozhang Wang commented on KAFKA-2718: -- Another example: https://builds.apache.org/j

[jira] [Created] (KAFKA-2943) Transient Failure in kafka.producer.SyncProducerTest.testReachableServer

Guozhang Wang created KAFKA-2943: Summary: Transient Failure in kafka.producer.SyncProducerTest.testReachableServer Key: KAFKA-2943 URL: https://issues.apache.org/jira/browse/KAFKA-2943 Project: Kafka

[GitHub] kafka pull request: Minor: ConsoleConsumer - Fix number of process...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/617 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Created] (KAFKA-2944) NullPointerException in KafkaConfigStorage when config storage starts right before shutdown request

Ewen Cheslack-Postava created KAFKA-2944: Summary: NullPointerException in KafkaConfigStorage when config storage starts right before shutdown request Key: KAFKA-2944 URL: https://issues.apache.org/jira/br

Build failed in Jenkins: kafka_0.9.0_jdk7 #55

See Changes: [geoff] Manually ported changes in 8c3c9548b636cdf760d2537afe115942d13bc003 to [wangguoz] MINOR: ConsoleConsumer - Fix number of processed messages count -- Started by an SCM change

[jira] [Assigned] (KAFKA-1694) kafka command line and centralized operations

[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reassigned KAFKA-1694: -- Assignee: Grant Henke (was: Andrii Biletskyi) > kafka command line and centralized operations

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

This kind of discussion always puts me in mind of stories that start “So I wrote my own encryption. How hard can it be?” :) Joking aside, I do have a few thoughts on this. First I have to echo Joel’s perspective on Zookeeper. Honestly, it is one of the few applications we can forget about, so I ha

Build failed in Jenkins: kafka-trunk-jdk8 #201

See Changes: [wangguoz] MINOR: ConsoleConsumer - Fix number of processed messages count -- [...truncated 1427 lines...] kafka.log.LogTest > testTruncateTo PASSED kafka.log.LogTest > testCleanSh

[GitHub] kafka pull request: KAFKA-2825: Add controller failover to existin...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/618 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (KAFKA-2825) Add controller failover to existing replication tests

[ https://issues.apache.org/jira/browse/KAFKA-2825?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15038285#comment-15038285 ] ASF GitHub Bot commented on KAFKA-2825: --- Github user asfgit closed the pull request

[jira] [Updated] (KAFKA-2839) Kafka connect log test failing

[ https://issues.apache.org/jira/browse/KAFKA-2839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2839: - Assignee: jin xing > Kafka connect log test failing > -- > >

[jira] [Updated] (KAFKA-2839) Kafka connect log test failing

[ https://issues.apache.org/jira/browse/KAFKA-2839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2839: - Reviewer: Gwen Shapira > Kafka connect log test failing > -- > >

[jira] [Updated] (KAFKA-2875) Class path contains multiple SLF4J bindings warnings when using scripts under bin

[ https://issues.apache.org/jira/browse/KAFKA-2875?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2875: - Reviewer: Ismael Juma > Class path contains multiple SLF4J bindings warnings when using scripts un

[GitHub] kafka pull request: KAFKA-2718: Add logging to investigate intermi...

Github user rajinisivaram closed the pull request at: https://github.com/apache/kafka/pull/613 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature i

[jira] [Commented] (KAFKA-2718) Reuse of temporary directories leading to transient unit test failures

[ https://issues.apache.org/jira/browse/KAFKA-2718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15038298#comment-15038298 ] ASF GitHub Bot commented on KAFKA-2718: --- Github user rajinisivaram closed the pull r

[jira] [Updated] (KAFKA-2825) Add controller failover to existing replication tests

[ https://issues.apache.org/jira/browse/KAFKA-2825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-2825: - Resolution: Fixed Reviewer: Geoff Anderson (was: Gwen Shapira) Fix Version/s: 0.9.

[GitHub] kafka pull request: KAFKA-2942: inadvertent auto-commit when pre-f...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/623 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (KAFKA-2942) Inadvertent auto-commit when pre-fetching can cause message loss

[ https://issues.apache.org/jira/browse/KAFKA-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15038335#comment-15038335 ] ASF GitHub Bot commented on KAFKA-2942: --- Github user asfgit closed the pull request

[jira] [Resolved] (KAFKA-2942) Inadvertent auto-commit when pre-fetching can cause message loss

[ https://issues.apache.org/jira/browse/KAFKA-2942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2942. -- Resolution: Fixed Fix Version/s: 0.9.0.1 Issue resolved by pull request 623 [https://gith

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

Hey Joel, I agree this isn't the most pressing thing for the project (i.e. we shouldn't start now), but I think that is a separate question for which direction we would head in. I think whether it is "worth doing" kind of depends on what you optimize for. If you consider just the problem of "gett

Jenkins build is back to normal : kafka-trunk-jdk7 #872

See

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

Hey Todd, I actually agree on both counts. I would summarize the first comment as "Zookeeper is not hard to operationalize if you are Todd Palino"--also in that category of things that are not hard: running 13 miles at 5:00 am. Basically I totally agree that ZK is now a solved problem at LinkedIn

[jira] [Updated] (KAFKA-2825) Add controller failover to existing replication tests

[ https://issues.apache.org/jira/browse/KAFKA-2825?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Anna Povzner updated KAFKA-2825: Reviewer: Guozhang Wang (was: Geoff Anderson) > Add controller failover to existing replication tes

[jira] [Commented] (KAFKA-2933) Failure in kafka.api.PlaintextConsumerTest.testMultiConsumerDefaultAssignment

[ https://issues.apache.org/jira/browse/KAFKA-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15038496#comment-15038496 ] Jason Gustafson commented on KAFKA-2933: [~guozhang] I've been unable to reproduce

Build failed in Jenkins: kafka-trunk-jdk7 #873

See Changes: [wangguoz] KAFKA-2825: Add controller failover to existing replication tests [wangguoz] KAFKA-2942: inadvertent auto-commit when pre-fetching can cause message -- [...truncated 140

[jira] [Resolved] (KAFKA-2908) Consumer Sporadically Stops Consuming From Partition After Server Restart

[ https://issues.apache.org/jira/browse/KAFKA-2908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ben Stopford resolved KAFKA-2908. - Resolution: Cannot Reproduce Haven't been able to reproduce this issue. I'll add a clause to the s

Jenkins build is back to normal : kafka_0.9.0_jdk7 #56

See

Build failed in Jenkins: kafka-trunk-jdk8 #202

See Changes: [wangguoz] KAFKA-2825: Add controller failover to existing replication tests [wangguoz] KAFKA-2942: inadvertent auto-commit when pre-fetching can cause message -- [...truncated 453

[jira] [Updated] (KAFKA-1694) kafka command line and centralized operations

[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-1694: --- Status: Open (was: Patch Available) > kafka command line and centralized operations > ---

[jira] [Work started] (KAFKA-1694) kafka command line and centralized operations

[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-1694 started by Grant Henke. -- > kafka command line and centralized operations > ---

[jira] [Updated] (KAFKA-2228) Delete me

[ https://issues.apache.org/jira/browse/KAFKA-2228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2228: --- Issue Type: Improvement (was: Sub-task) Parent: (was: KAFKA-1694) > Delete me > -

[jira] [Updated] (KAFKA-2227) Delete me

[ https://issues.apache.org/jira/browse/KAFKA-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2227: --- Issue Type: Improvement (was: Sub-task) Parent: (was: KAFKA-1694) > Delete me > -

[jira] [Updated] (KAFKA-1694) KIP-4: Command line and centralized operations

[ https://issues.apache.org/jira/browse/KAFKA-1694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-1694: --- Summary: KIP-4: Command line and centralized operations (was: kafka command line and centralized oper

[jira] [Created] (KAFKA-2945) CreateTopic - Protocol and Server Side Implimentation

Grant Henke created KAFKA-2945: -- Summary: CreateTopic - Protocol and Server Side Implimentation Key: KAFKA-2945 URL: https://issues.apache.org/jira/browse/KAFKA-2945 Project: Kafka Issue Type: S

[jira] [Updated] (KAFKA-2945) CreateTopic - protocol and server side implementation

[ https://issues.apache.org/jira/browse/KAFKA-2945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2945: --- Summary: CreateTopic - protocol and server side implementation (was: CreateTopic - Protocol and Serve

[jira] [Created] (KAFKA-2946) DeleteTopic - protocol and server side implementation

Grant Henke created KAFKA-2946: -- Summary: DeleteTopic - protocol and server side implementation Key: KAFKA-2946 URL: https://issues.apache.org/jira/browse/KAFKA-2946 Project: Kafka Issue Type: S

[jira] [Assigned] (KAFKA-2946) DeleteTopic - protocol and server side implementation

[ https://issues.apache.org/jira/browse/KAFKA-2946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke reassigned KAFKA-2946: -- Assignee: Grant Henke > DeleteTopic - protocol and server side implementation > ---

[jira] [Created] (KAFKA-2947) AlterTopic - protocol and server side implementation

Grant Henke created KAFKA-2947: -- Summary: AlterTopic - protocol and server side implementation Key: KAFKA-2947 URL: https://issues.apache.org/jira/browse/KAFKA-2947 Project: Kafka Issue Type: Su

[jira] [Updated] (KAFKA-2229) Phase 1: Requests and KafkaApis

[ https://issues.apache.org/jira/browse/KAFKA-2229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2229: --- Issue Type: Improvement (was: Sub-task) Parent: (was: KAFKA-1694) > Phase 1: Requests and

[jira] [Resolved] (KAFKA-2891) Gaps in messages delivered by new consumer after Kafka restart

[ https://issues.apache.org/jira/browse/KAFKA-2891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rajini Sivaram resolved KAFKA-2891. --- Resolution: Fixed This was fixed by setting min.insync.replicas=2 correctly in the tests. Clos

[jira] [Updated] (KAFKA-2229) Phase 1: Requests and KafkaApis

[ https://issues.apache.org/jira/browse/KAFKA-2229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2229: --- Resolution: Duplicate Assignee: Grant Henke (was: Andrii Biletskyi) Status: Resolved (w

[jira] [Updated] (KAFKA-1772) Add an Admin message type for request response

[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-1772: --- Issue Type: Improvement (was: Sub-task) Parent: (was: KAFKA-1694) > Add an Admin message

[jira] [Resolved] (KAFKA-1772) Add an Admin message type for request response

[ https://issues.apache.org/jira/browse/KAFKA-1772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke resolved KAFKA-1772. Resolution: Won't Fix > Add an Admin message type for request response > ---

[jira] [Updated] (KAFKA-1778) Create new re-elect controller admin function

[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-1778: --- Issue Type: New Feature (was: Sub-task) Parent: (was: KAFKA-1694) > Create new re-elect c

[jira] [Commented] (KAFKA-1778) Create new re-elect controller admin function

[ https://issues.apache.org/jira/browse/KAFKA-1778?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15038651#comment-15038651 ] Grant Henke commented on KAFKA-1778: I broke this into its own task since it's indepen

[jira] [Commented] (KAFKA-2905) System test for rolling upgrade to enable ZooKeeper ACLs with SASL

[ https://issues.apache.org/jira/browse/KAFKA-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15039567#comment-15039567 ] ASF GitHub Bot commented on KAFKA-2905: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: KAFKA-2905: System test for rolling upgrade to...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/598 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Resolved] (KAFKA-2905) System test for rolling upgrade to enable ZooKeeper ACLs with SASL

[ https://issues.apache.org/jira/browse/KAFKA-2905?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang resolved KAFKA-2905. -- Resolution: Fixed Fix Version/s: 0.9.1.0 > System test for rolling upgrade to enable ZooK

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

Come on, Jay. Anyone can get up in the morning and run if they have the willpower :) Granted I do have some bias here, since we have tooling in place that makes deployments and monitoring easier. But even at that, I would not say Zookeeper is difficult to run or monitor. I’m not denying that there

[GitHub] kafka pull request: KAFKA-2945: CreateTopic - protocol and server ...

GitHub user granthenke opened a pull request: https://github.com/apache/kafka/pull/626 KAFKA-2945: CreateTopic - protocol and server side implementation You can merge this pull request into a Git repository by running: $ git pull https://github.com/granthenke/kafka create-wire

[jira] [Commented] (KAFKA-2945) CreateTopic - protocol and server side implementation

[ https://issues.apache.org/jira/browse/KAFKA-2945?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15039619#comment-15039619 ] ASF GitHub Bot commented on KAFKA-2945: --- GitHub user granthenke opened a pull reques

[jira] [Updated] (KAFKA-2945) CreateTopic - protocol and server side implementation

[ https://issues.apache.org/jira/browse/KAFKA-2945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2945: --- Status: Patch Available (was: Open) > CreateTopic - protocol and server side implementation > ---

Jenkins build is back to normal : kafka-trunk-jdk7 #874

See

Build failed in Jenkins: kafka-trunk-jdk8 #203

See Changes: [wangguoz] KAFKA-2905: System test for rolling upgrade to enable ZooKeeper ACLs -- [...truncated 4535 lines...] org.apache.kafka.connect.json.JsonConverterTest > timeToJson PASSED o

[GitHub] kafka pull request: KAFKA-2931: add system test for consumer rolli...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/619 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is enabl

[jira] [Commented] (KAFKA-2931) Consumer rolling upgrade test case

[ https://issues.apache.org/jira/browse/KAFKA-2931?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15039764#comment-15039764 ] ASF GitHub Bot commented on KAFKA-2931: --- Github user asfgit closed the pull request

Build failed in Jenkins: kafka-trunk-jdk7 #875

See Changes: [wangguoz] KAFKA-2931: add system test for consumer rolling upgrades -- [...truncated 1834 lines...] kafka.admin.AddPartitionsTest > testTopicDoesNotExist PASSED kafka.admin.AddPar

[GitHub] kafka pull request: 0.9.0

GitHub user chamberlain1990 opened a pull request: https://github.com/apache/kafka/pull/627 0.9.0 You can merge this pull request into a Git repository by running: $ git pull https://github.com/apache/kafka 0.9.0 Alternatively you can review and apply these changes as the pat

Build failed in Jenkins: kafka-trunk-jdk8 #204

See Changes: [wangguoz] KAFKA-2931: add system test for consumer rolling upgrades -- [...truncated 6670 lines...] org.apache.kafka.connect.json.JsonConverterTest > timeToJson PASSED org.apache.k