Re: [DISCUSS] Apache Kafka 3.4.0 release

Hey everyone, Rejoice (or not) for we are now past code freeze for the 3.4 release! This means you should not be merging any new code to the 3.4 branch unless/until it's been approved as a blocker. For now feel free to also merge things like flaky test fixes and docs PRs that don't touch any

Jenkins build is unstable: Kafka » Kafka Branch Builder » trunk #1423

See

Jenkins build is still unstable: Kafka » Kafka Branch Builder » 3.4 #7

See

[jira] [Resolved] (KAFKA-14286) Time based cluster metadata snapshots

[ https://issues.apache.org/jira/browse/KAFKA-14286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] José Armando García Sancio resolved KAFKA-14286. Resolution: Fixed > Time based cluster metadata snapshots >

[jira] [Created] (KAFKA-14460) In-memory store iterators can return results with null values

A. Sophie Blee-Goldman created KAFKA-14460: -- Summary: In-memory store iterators can return results with null values Key: KAFKA-14460 URL: https://issues.apache.org/jira/browse/KAFKA-14460

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1422

See Changes: -- [...truncated 434216 lines...] [2022-12-10T02:58:51.534Z] > Task :connect:json:testJar [2022-12-10T02:58:51.534Z] > Task :connect:json:testSrcJar

[jira] [Created] (KAFKA-14459) Document how to use and close a 'Statistics' in the example RocksDBConfigSetter

A. Sophie Blee-Goldman created KAFKA-14459: -- Summary: Document how to use and close a 'Statistics' in the example RocksDBConfigSetter Key: KAFKA-14459 URL:

[jira] [Resolved] (KAFKA-14454) KTableKTableForeignKeyInnerJoinCustomPartitionerIntegrationTest#shouldThrowIllegalArgumentExceptionWhenCustomPartionerReturnsMultiplePartitions passes when run individu

[ https://issues.apache.org/jira/browse/KAFKA-14454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman resolved KAFKA-14454. Resolution: Fixed >

[jira] [Created] (KAFKA-14458) RPC Handler to ZkBrokers from KRaft Controller

Akhilesh Chaganti created KAFKA-14458: - Summary: RPC Handler to ZkBrokers from KRaft Controller Key: KAFKA-14458 URL: https://issues.apache.org/jira/browse/KAFKA-14458 Project: Kafka

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.3 #133

See Changes: -- [...truncated 421414 lines...] [2022-12-10T00:41:28.038Z] KafkaZkClientTest > testChroot(boolean) > kafka.zk.KafkaZkClientTest.testChroot(boolean)[1] PASSED

[jira] [Created] (KAFKA-14457) Inconsistent in quorum controller fenced broker metric

José Armando García Sancio created KAFKA-14457: -- Summary: Inconsistent in quorum controller fenced broker metric Key: KAFKA-14457 URL: https://issues.apache.org/jira/browse/KAFKA-14457

Build failed in Jenkins: Kafka » Kafka Branch Builder » trunk #1421

See Changes: -- [...truncated 520083 lines...] [2022-12-09T23:41:08.174Z] > Task :server-common:compileTestJava UP-TO-DATE [2022-12-09T23:41:08.174Z] > Task

Re: [Streams] GlobalStateManagerImpl#restoreState locally restores previously deleted records

Does the KeySerde that you provided to your store encrypt the keys? I've never done so myself, but I've seen others report similar behavior (the store iterator shows the correct values but store.get('foo') returns null) in the Confluent Community slack. Here's a relevant message: > "From the

Jenkins build is unstable: Kafka » Kafka Branch Builder » 3.4 #6

See

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.2 #94

See Changes: -- [...truncated 226182 lines...] [2022-12-09T22:04:03.393Z] 1 warning [2022-12-09T22:04:04.383Z] [2022-12-09T22:04:04.383Z] > Task

Build failed in Jenkins: Kafka » Kafka Branch Builder » 3.1 #138

See Changes: -- [...truncated 367212 lines...] [2022-12-09T21:51:37.326Z] You can use '--warning-mode all' to show the individual deprecation warnings and determine if they

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #1420

See

Re: [DISCUSS] KIP-875: First-class offsets support in Kafka Connect

Hi Yash, The idea with the boolean is to just signify that a connector has overridden this method, which allows us to issue a definitive response in the REST API when servicing offset alter/reset requests (described more in detail here:

Re: [VOTE] KIP-837 Allow MultiCasting a Result Record.

Hey Matthias, Actually I had shared the PR link for any potential issues that might have gone missing. I guess it didn't come out that way in my response. Apologies for that! I am more than happy to incorporate any feedback/changes or address any concerns that are still present around this at

Re: [VOTE] KIP-837 Allow MultiCasting a Result Record.

It is what it is. we did have internal discussions on this We sometimes have the case that a KIP need adjustment as stuff is discovered during coding. And having a discussion on the PR about it is fine. -- However, before the PR gets merge, the KIP change should be announced to verify that

Jenkins build is still unstable: Kafka » Kafka Branch Builder » trunk #1419

See

Re: [DISCUSS] Apache Kafka 3.4.0 release

Hey Sophie I was wondering whether we should try to get the ARM build working again so that we can perform release qualification of 3.4.x on ARM as well (which was disabled in https://github.com/apache/kafka/pull/12380)? I would be happy to pick up the work if someone can point me to the history

[jira] [Resolved] (KAFKA-14413) Separate MirrorMaker configurations for each connector

[ https://issues.apache.org/jira/browse/KAFKA-14413?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chris Egerton resolved KAFKA-14413. --- Fix Version/s: 3.4.0 Resolution: Done > Separate MirrorMaker configurations for each

[jira] [Reopened] (KAFKA-14391) Add ConsumerGroupHeartbeat API

[ https://issues.apache.org/jira/browse/KAFKA-14391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot reopened KAFKA-14391: - > Add ConsumerGroupHeartbeat API > -- > > Key:

[jira] [Resolved] (KAFKA-14425) The Kafka protocol should support nullable structs

[ https://issues.apache.org/jira/browse/KAFKA-14425?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14425. - Fix Version/s: 3.5.0 Resolution: Fixed > The Kafka protocol should support nullable

[jira] [Resolved] (KAFKA-14391) Add ConsumerGroupHeartbeat API

[ https://issues.apache.org/jira/browse/KAFKA-14391?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Jacot resolved KAFKA-14391. - Fix Version/s: 3.5.0 Resolution: Fixed > Add ConsumerGroupHeartbeat API >