Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #417

See Changes: [github] KAFKA-12175 Migrate generator module to junit5 (#9926) [github] MINOR: Remind user index file is empty when dumping LogSegment index file (#9891)

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #435

See Changes: [github] KAFKA-12175 Migrate generator module to junit5 (#9926) [github] MINOR: Remind user index file is empty when dumping LogSegment index file (#9891)

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #387

See Changes: [github] KAFKA-12175 Migrate generator module to junit5 (#9926) [github] MINOR: Remind user index file is empty when dumping LogSegment index file (#9891)

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #434

See Changes: [github] KAFKA-12211: don't change perm for base/state dir when no persistent store (#9904) [github] KAFKA-10869: Gate topic IDs behind IBP 2.8 (KIP-516) (#9814)

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #416

See Changes: [github] KAFKA-10869: Gate topic IDs behind IBP 2.8 (KIP-516) (#9814) -- [...truncated 3.57 MB...] MockProcessorContextStateStoreTest > builder

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #386

See Changes: [github] KAFKA-10869: Gate topic IDs behind IBP 2.8 (KIP-516) (#9814) -- [...truncated 3.56 MB...] TopologyTestDriverEosTest >

[jira] [Created] (KAFKA-12229) Fix flaky MirrorSourceConnectorTest.testRefreshTopicPartitionsTopicOnTargetFirst test

Luke Chen created KAFKA-12229: - Summary: Fix flaky MirrorSourceConnectorTest.testRefreshTopicPartitionsTopicOnTargetFirst test Key: KAFKA-12229 URL: https://issues.apache.org/jira/browse/KAFKA-12229

Jenkins build is back to normal : Kafka » kafka-2.7-jdk8 #99

See

Re: [VOTE] KIP-659: Improve TimeWindowedDeserializer and TimeWindowedSerde to handle window size

Thanks for reviving this KIP, Leah. I agree that we should not extend the scope of this KIP to potentially deprecate/rename the `default.windowed.[key|value].serde.inner` configs. @Sophie: if you feel strong about it, let's do a separate KIP. +1 (binding) -Matthias On 1/19/21 3:00 PM, John

Re: We want to remove Zookeeper from our Kafka cluster which version to use?

Hi Manojbvn, Thanks for the question. It's good to know that people are enthusiastic about this work! We're hoping to have an alpha version of ZK-free operation in the next Apache Kafka release. The alpha version will not be suitable for production, and will not implement all Kafka

Jenkins build is back to normal : Kafka » kafka-trunk-jdk15 #433

See

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #385

See Changes: [github] KAFKA-12211: don't change perm for base/state dir when no persistent store (#9904) -- [...truncated 3.55 MB...]

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #415

See Changes: [github] KAFKA-12211: don't change perm for base/state dir when no persistent store (#9904) -- [...truncated 3.57 MB...] OutputVerifierTest >

[jira] [Resolved] (KAFKA-10869) Gate topic IDs behind IBP 2.8

[ https://issues.apache.org/jira/browse/KAFKA-10869?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Justine Olshan resolved KAFKA-10869. Resolution: Fixed > Gate topic IDs behind IBP 2.8 > - > >

Re: Kafka Advisory Topic

Hey Knowles, in Kafka people normally use admin clients to get those metadata. I'm not sure why you mentioned specifically that having a topic to manage these information is useful, but a good news is that in KIP-500

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #384

See Changes: [github] KAFKA-12210; AdminClient should use DescribeCluster API when available (KIP-700) (#9905) -- [...truncated 3.55 MB...]

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #414

See Changes: [github] KAFKA-12210; AdminClient should use DescribeCluster API when available (KIP-700) (#9905) -- [...truncated 3.57 MB...]

Kafka Advisory Topic

Good afternoon all, In our Kafka clusters we have a need to know when certain activities are performed, mainly topics being created, but brokers coming up/down is also useful. This would be akin to what ActiveMQ does via advisory messages ( https://activemq.apache.org/advisory-message). Since

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #432

See Changes: [github] HOTFIX: fix RocksDBMetricsTest (#9935) -- [...truncated 3.57 MB...] TopologyTestDriverEosTest > shouldReturnAllStores() PASSED

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #413

See Changes: [github] HOTFIX: fix RocksDBMetricsTest (#9935) -- [...truncated 3.57 MB...] OutputVerifierTest >

[jira] [Created] (KAFKA-12228) Invalid value javax.net.ssl.SSLHandshakeException: no cipher suites in common for configuration

Alexey Kashavkin created KAFKA-12228: Summary: Invalid value javax.net.ssl.SSLHandshakeException: no cipher suites in common for configuration Key: KAFKA-12228 URL:

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #383

See Changes: [github] HOTFIX: fix RocksDBMetricsTest (#9935) -- [...truncated 3.55 MB...] MockProcessorContextStateStoreTest > builder =

Build failed in Jenkins: Kafka » kafka-2.7-jdk8 #98

See Changes: [Chia-Ping Tsai] HOTFIX: fix RocksDBMetricsTest (#9935) -- [...truncated 3.44 MB...] org.apache.kafka.streams.test.OutputVerifierTest >

[DISCUSS] KIP-706: Add method "Producer#produce" to return CompletionStage instead of Future

Dear all, I'd like to start the discussion thread for KIP-706: https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=100829459 KIP-706 is proposing to introduce new API "CompletionStage produce(record)" to Producer. Kafka users can leverage CompletionStage to write asynchronous

[jira] [Resolved] (KAFKA-12210) AdminClient should use DescribeCluster API when available

[ https://issues.apache.org/jira/browse/KAFKA-12210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-12210. - Fix Version/s: 2.8.0 Resolution: Fixed > AdminClient should use DescribeCluster API when

[jira] [Created] (KAFKA-12227) Return CompletableFuture from KafkaProducer.send

Chia-Ping Tsai created KAFKA-12227: -- Summary: Return CompletableFuture from KafkaProducer.send Key: KAFKA-12227 URL: https://issues.apache.org/jira/browse/KAFKA-12227 Project: Kafka Issue

Build failed in Jenkins: Kafka » kafka-trunk-jdk8 #382

See Changes: [github] KAFKA-8460: produce records with current timestamp (#9877) -- [...truncated 3.56 MB...] MockProcessorContextStateStoreTest > builder =

Build failed in Jenkins: Kafka » kafka-trunk-jdk11 #412

See Changes: [github] KAFKA-8460: produce records with current timestamp (#9877) -- [...truncated 3.58 MB...] OutputVerifierTest >

Build failed in Jenkins: Kafka » kafka-trunk-jdk15 #431

See Changes: [github] KAFKA-8460: produce records with current timestamp (#9877) -- [...truncated 3.58 MB...] TestTopicsTest >