[jira] [Resolved] (KAFKA-7628) KafkaStream is not closing

[ https://issues.apache.org/jira/browse/KAFKA-7628?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ozgur resolved KAFKA-7628. -- Resolution: Fixed This issue caused by the another component of the application. Processor implementation comm

Re: [VOTE] 2.1.0 RC1

+1 (binding). I've verified the signature, and ran quickstart / unit test with scala 2.12 binary. On my local laptop the unit test did not fail though on Jenkins it seems indeed flaky. Guozhang On Fri, Nov 9, 2018 at 3:33 PM Dong Lin wrote: > Hello Kafka users, developers and client-developer

RE: Kafka Performance Producer - Extension

Hi Colin, Did u get a chance to review the document. -kaushik -Original Message- From: Srinivas, Kaushik (Nokia - IN/Bangalore) Sent: Friday, November 09, 2018 11:48 AM To: 'dev@kafka.apache.org' ; 'cmcc...@apache.org' Subject: RE: Kafka Performance Producer - Extension Attaching the

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

See Changes: [jason] KAFKA-7576; Fix shutdown of replica fetcher threads (#5875) -- [...truncated 2.59 MB...] kafka.utils.SchedulerTest > testRestart STARTED kafka.utils

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

See Changes: [wangguoz] HOTFIX: remove deprecated calls -- [...truncated 2.37 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullProducerRecordF

Jenkins build is back to normal : kafka-trunk-jdk11 #100

See

[jira] [Created] (KAFKA-7634) Punctuate not being called with merge() and/or outerJoin()

Eugen Feller created KAFKA-7634: --- Summary: Punctuate not being called with merge() and/or outerJoin() Key: KAFKA-7634 URL: https://issues.apache.org/jira/browse/KAFKA-7634 Project: Kafka Issue

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

See Changes: [wangguoz] MINOR: Code cleanup in StreamsResetter (#5891) [wangguoz] KAFKA-7584: StreamsConfig throws ClassCastException if [wangguoz] MINOR: improve Puncutation JavaDocs and add runtime argument c

Build failed in Jenkins: kafka-trunk-jdk11 #99

See Changes: [wangguoz] MINOR: Code cleanup in StreamsResetter (#5891) [wangguoz] KAFKA-7584: StreamsConfig throws ClassCastException if [wangguoz] MINOR: improve Puncutation JavaDocs and add runtime argument ch

[jira] [Created] (KAFKA-7633) Kafka Connect requires permission to create internal topics even if they exist

Arabelle Hou created KAFKA-7633: --- Summary: Kafka Connect requires permission to create internal topics even if they exist Key: KAFKA-7633 URL: https://issues.apache.org/jira/browse/KAFKA-7633 Project: K

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

See Changes: [lindong28] MINOR: Bump documentation version to 2.1 -- [...truncated 2.38 MB...] org.apache.kafka.streams.test.OutputVerifierTest > shouldNotAllowNullProduc

[jira] [Created] (KAFKA-7632) Add option to kafka broker config to adjust compression level for zstd

Dave Waters created KAFKA-7632: -- Summary: Add option to kafka broker config to adjust compression level for zstd Key: KAFKA-7632 URL: https://issues.apache.org/jira/browse/KAFKA-7632 Project: Kafka

Re: [VOTE] 2.1.0 RC1

Hi Dong, Thanks for running the release. I built binaries from the source, ran quickstart and tests on Ubuntu (with Java 8 & 9). I noticed two issues: * (minor) the documentation still mentions 2.0, and submitted a minor PR to update it. * the unit tes

Re: kafka.common.StateChangeFailedException: Failed to elect leader for partition XXX under strategy PreferredReplicaPartitionLeaderElectionStrategy

Adding Kafka Controller Log. [2018-11-15 11:19:23,985] ERROR [Controller id=4 epoch=8] Controller 4 epoch 8 failed to change state for partition XYXY-24 from OnlinePartition to OnlinePartition (state.change.logger) On Thu, Nov 15, 2018 at 5:12 PM SenthilKumar K wrote: > Hello Kafka Experts, >

kafka.common.StateChangeFailedException: Failed to elect leader for partition XXX under strategy PreferredReplicaPartitionLeaderElectionStrategy

Hello Kafka Experts, We are facing StateChange Failed Exception on one of the broker. Out of 4 brokers, 3 were running fine and only one broker is throwing state change error. I dont find any error on Zookeeper Logs related to this error. Kafka Version : kafka_2.11-1.1.0 Any input would

[jira] [Created] (KAFKA-7631) NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf

Andras Beni created KAFKA-7631: -- Summary: NullPointerException when SCRAM is allowed bu ScramLoginModule is not in broker's jaas.conf Key: KAFKA-7631 URL: https://issues.apache.org/jira/browse/KAFKA-7631

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

See Changes: [github] MINOR: Remove deprecated callers (#5911) -- [...truncated 713.62 KB...] kafka.api.AdminClientIntegrationTest > testMetadataRefresh STARTED kafka.ap