Build failed in Jenkins: kafka-2.3-jdk8 #46

See Changes: [cmccabe] KAFKA-8499: ensure java is in PATH for ducker system tests (#6898) [cshapi] MINOR: Lower producer throughput in flaky upgrade system test [cshapi] MINOR: Fix race condition on shutdown of

Build failed in Jenkins: kafka-1.0-jdk7 #272

See Changes: [jason] MINOR: Lower producer throughput in flaky upgrade system test [jason] MINOR: Fix race condition on shutdown of verifiable producer -- [...truncated

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

See Changes: [cshapi] MINOR: Lower producer throughput in flaky upgrade system test [cshapi] MINOR: Fix race condition on shutdown of verifiable producer --

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

See Changes: [jason] MINOR: Lower producer throughput in flaky upgrade system test [jason] MINOR: Fix race condition on shutdown of verifiable producer -- [...truncated

Build failed in Jenkins: kafka-2.0-jdk8 #274

See Changes: [jason] MINOR: Lower producer throughput in flaky upgrade system test [jason] MINOR: Fix race condition on shutdown of verifiable producer -- [...truncated

Jenkins build is back to normal : kafka-1.1-jdk7 #266

See

[jira] [Created] (KAFKA-8513) Add kafka-streams-application-reset.bat for Windows platform

Kengo Seki created KAFKA-8513: - Summary: Add kafka-streams-application-reset.bat for Windows platform Key: KAFKA-8513 URL: https://issues.apache.org/jira/browse/KAFKA-8513 Project: Kafka Issue

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

See Changes: [bbejeck] KAFKA-8331: stream static membership system test (#6877) [cmccabe] KAFKA-8499: ensure java is in PATH for ducker system tests (#6898) --

Jenkins build is back to normal : kafka-2.2-jdk8 #133

See

Re: [DISCUSS] KIP-467: Augment ProduceResponse error messaging

Bump up this thread again for whoever's interested. On Sat, May 11, 2019 at 12:34 PM Guozhang Wang wrote: > Hello everyone, > > I'd like to start a discussion thread on this newly created KIP to improve > error communication and handling for producer response: > > >

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

See Changes: [cshapi] KAFKA-8003; Fix flaky testFencingOnTransactionExpiration -- [...truncated 2.50 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

[jira] [Created] (KAFKA-8512) Looking into the Future: Assignor Version

Guozhang Wang created KAFKA-8512: Summary: Looking into the Future: Assignor Version Key: KAFKA-8512 URL: https://issues.apache.org/jira/browse/KAFKA-8512 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-8511) Looking into the Future: Heartbeat Communicated Protocol

Guozhang Wang created KAFKA-8511: Summary: Looking into the Future: Heartbeat Communicated Protocol Key: KAFKA-8511 URL: https://issues.apache.org/jira/browse/KAFKA-8511 Project: Kafka Issue

[jira] [Created] (KAFKA-8510) Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness

Guozhang Wang created KAFKA-8510: Summary: Update StreamsPartitionAssignor to use the built-in owned partitions to achieve stickiness Key: KAFKA-8510 URL: https://issues.apache.org/jira/browse/KAFKA-8510

Re: JIRA Contributor permissions

Vikash, Thanks for your interest in Apache Kafka. You're all set now. -Bill On Fri, Jun 7, 2019 at 12:45 PM Vikash Kumar wrote: > Sorry I forgot to mention my user ID. > > My User ID : krvikash > > On Fri, Jun 7, 2019 at 10:12 PM Vikash Kumar > wrote: > > > Hi, > > > > I want to start

[jira] [Resolved] (KAFKA-8331) Add system test for enabling static membership on KStream

[ https://issues.apache.org/jira/browse/KAFKA-8331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bill Bejeck resolved KAFKA-8331. Resolution: Fixed > Add system test for enabling static membership on KStream >

Re: [DISCUSS] KIP-471: Expose RocksDB Metrics in Kafka Streams

Hi Sophie This will be a good change, I have been thinking about proposing something similar or even passing the properties per store. RocksDB should probably know how much memory was reserved but maybe does not expose it. We are limiting it already as you suggested but this is a rather crude

Re: [DISCUSS] KIP-471: Expose RocksDB Metrics in Kafka Streams

Hi Patrik, As of 2.3 you will be able to use the RocksDBConfigSetter to effectively bound the total memory used by RocksDB for a single app instance. You should already be able to limit the memory used per rocksdb store, though as you mention there can be a lot of them. I'm not sure you can

[jira] [Created] (KAFKA-8509) Add downgrade system tests

Jason Gustafson created KAFKA-8509: -- Summary: Add downgrade system tests Key: KAFKA-8509 URL: https://issues.apache.org/jira/browse/KAFKA-8509 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-8508) saslClient failed to initialize properly: it's null.

Caroline Liu created KAFKA-8508: --- Summary: saslClient failed to initialize properly: it's null. Key: KAFKA-8508 URL: https://issues.apache.org/jira/browse/KAFKA-8508 Project: Kafka Issue Type:

[jira] [Created] (KAFKA-8507) Support --bootstrap-server in all command line tools

Jason Gustafson created KAFKA-8507: -- Summary: Support --bootstrap-server in all command line tools Key: KAFKA-8507 URL: https://issues.apache.org/jira/browse/KAFKA-8507 Project: Kafka Issue

Re: JIRA Contributor permissions

Sorry I forgot to mention my user ID. My User ID : krvikash On Fri, Jun 7, 2019 at 10:12 PM Vikash Kumar wrote: > Hi, > > I want to start contributing to Apache Kafka.Can you please add me into > JIRA contributor list? > > Thanks, > Vikash >

JIRA Contributor permissions

Hi, I want to start contributing to Apache Kafka.Can you please add me into JIRA contributor list? Thanks, Vikash

Jenkins build is back to normal : kafka-trunk-jdk8 #3709

See

[jira] [Created] (KAFKA-8506) Kafka Consumer broker never stops on connection failure

Gaurav created KAFKA-8506: - Summary: Kafka Consumer broker never stops on connection failure Key: KAFKA-8506 URL: https://issues.apache.org/jira/browse/KAFKA-8506 Project: Kafka Issue Type: Bug

Re: Contributor permissions

Hi Carlos, Thanks again for your interest in Apache Kafka. I've added you as a contributor so you can now self-assign tickets. -Bill On Fri, Jun 7, 2019 at 6:14 AM Carlos Manuel Duclos-Vergara < carlos.duc...@schibsted.com> wrote: > Hi, > Yes, I read the guidelines. I forgot to mention the

[jira] [Created] (KAFKA-8505) Limit the maximum number of connections per ip client ID

Igor Soarez created KAFKA-8505: -- Summary: Limit the maximum number of connections per ip client ID Key: KAFKA-8505 URL: https://issues.apache.org/jira/browse/KAFKA-8505 Project: Kafka Issue

Re: [VOTE] KIP-476: Add Java AdminClient interface

+1 non-binding We've run into issues trying to decorate the AdminClient due it being an abstract class. Will be nice to have consistency with Producer/Consumer as well. On Tue, 2019-06-04 at 17:17 +0100, Andy Coates wrote: Hi folks As there's been no chatter on this KIP I'm assuming it's

Jenkins build is back to normal : kafka-2.3-jdk8 #44

See

Re: [VOTE] KIP-474: To deprecate WindowStore#put(key, value)

Thanks to everyone who have voted! I'm closing this vote thread with a final count: binding +1: 2 (Matthias, Guozhang) non-binding +1: 2 (Boyang, Dongjin) Thanks & Regards Omkar Mestry On Tue, Jun 4, 2019 at 3:05 AM Guozhang Wang wrote: > +1 (binding). > > On Sat, Jun 1, 2019 at 3:19 PM

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

See Changes: [jason] KAFKA-8384; Leader election command integration tests (#6880) [manikumar] KAFKA-8461: Wait for follower to join the ISR in -- [...truncated 2.41

Re: Contributor permissions

Hi, Yes, I read the guidelines. I forgot to mention the JIRA ID. I already pushed a PR from my fork. My Jira-ID is carlos.duclos. Regards On Fri, 7 Jun 2019 at 12:03, Bruno Cadonna wrote: > Hi Carlos, > > It's great that you want to contribute to Apache Kafka. > > Have you already read the

Re: Contributor permissions

Hi Carlos, It's great that you want to contribute to Apache Kafka. Have you already read the instructions on how to contribute to Kafka? https://cwiki.apache.org/confluence/display/KAFKA/Contributing+Code+Changes https://kafka.apache.org/contributing.html To assign Jira tickets to yourself,

Re: Contributor permissions

Hi, I think for the first JIRA ticket you have to request to be added as the assignee in a new thread. Afterwards you can assign them yourself and keep working. On Fri, Jun 7, 2019 at 12:28 PM Carlos Manuel Duclos-Vergara < carlos.duc...@schibsted.com> wrote: > Hi, > > I'd like to start working

[jira] [Created] (KAFKA-8504) Suppressed do not emit with TimeWindows

Simone created KAFKA-8504: - Summary: Suppressed do not emit with TimeWindows Key: KAFKA-8504 URL: https://issues.apache.org/jira/browse/KAFKA-8504 Project: Kafka Issue Type: Bug

Re: [DISCUSS] KIP-471: Expose RocksDB Metrics in Kafka Streams

Hi Thanks Bruno for the KIP, this is a very good idea. I have one question, are there metrics available for the memory consumption of RocksDB? As they are running outside the JVM we have run into issues because they were using all the other memory. And with multiple streams applications on the

RE: kafka connect stops consuming data when kafka broker goes down

Hi Paul, We tried patching out kafka connect as well referencing the PR which you had shared. But no improvement in our case. Have updated more details in the blocker issue which I have created for the same. https://issues.apache.org/jira/browse/KAFKA-8485 But the issue seems to be coming from

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

See Changes: [jason] MINOR: Remove redundant semicolons in `KafkaApis` imports (#6889) [wangguoz] MINOR: Fixed compiler warnings in LogManagerTest (#6897) --

Contributor permissions

Hi, I'd like to start working on some of the newbie tasks (I got permission from my employer to use up to 10% of my time on this project). I have already found a couple of tasks that I'd like to work on, so I'd like to be able to assign those tasks to me. What is the procedure? Regards --

[jira] [Resolved] (KAFKA-8461) Flakey test UncleanLeaderElectionTest#testUncleanLeaderElectionDisabledByTopicOverride

[ https://issues.apache.org/jira/browse/KAFKA-8461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Manikumar resolved KAFKA-8461. -- Resolution: Fixed Fix Version/s: 2.4.0 Issue resolved by pull request 6887

[jira] [Created] (KAFKA-8503) AdminClient should ignore retries config if a custom timeout is provided

Jason Gustafson created KAFKA-8503: -- Summary: AdminClient should ignore retries config if a custom timeout is provided Key: KAFKA-8503 URL: https://issues.apache.org/jira/browse/KAFKA-8503 Project:

[jira] [Created] (KAFKA-8502) Flakey test AdminClientIntegrationTest#testElectUncleanLeadersForAllPartitions

Boyang Chen created KAFKA-8502: -- Summary: Flakey test AdminClientIntegrationTest#testElectUncleanLeadersForAllPartitions Key: KAFKA-8502 URL: https://issues.apache.org/jira/browse/KAFKA-8502 Project: