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) -- [...truncate

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

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 sam

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

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

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

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 inst

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 MB..

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 Matth

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

See

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

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

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 JIR

[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

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

See

JIRA Contributor permissions

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

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

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

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 monito

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 too

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

[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

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

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

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: > > > https://cwiki.apache.org/conf

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

See

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) -- [...trunca

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

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

See

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 438.

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 922.

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

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 175.

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 ver