[jira] [Resolved] (KAFKA-16272) Update connect_distributed_test.py to support KIP-848’s group protocol config

[ https://issues.apache.org/jira/browse/KAFKA-16272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kirk True resolved KAFKA-16272. --- Resolution: Fixed > Update connect_distributed_test.py to support KIP-848’s group protocol config >

[jira] [Resolved] (KAFKA-17603) KRaftMigrationDriverTest testNoDualWriteBeforeMigration became flaky

[ https://issues.apache.org/jira/browse/KAFKA-17603?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-17603. --- Resolution: Not A Problem The test case is removed in trunk. We can reopen again if it's flaky in 3.

Re: [VOTE] KIP-1092: Extend Consumer#close with an option to leave the group or not

+1 (binding) nit: in the "Migration Plan" ``` consumer.close(CloseOption.timeout(Duration.ofSeconds(30)) .withGroupMembershipOperation(GroupMembershipOperation.DEFAULT)); ``` The sample above can likely be simplified, right? ``` consumer.close(CloseOption.timeout(Duration.ofSeconds(30))); `

[jira] [Resolved] (KAFKA-17529) Remove blacklist from MM2

[ https://issues.apache.org/jira/browse/KAFKA-17529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17529. Fix Version/s: 4.0.0 Resolution: Fixed > Remove blacklist from MM2 > --

[jira] [Resolved] (KAFKA-17695) cleanup org.apache.kafka.common.test.TestUtils

[ https://issues.apache.org/jira/browse/KAFKA-17695?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17695. Fix Version/s: 4.0.0 Resolution: Fixed > cleanup org.apache.kafka.common.test.TestU

[VOTE] KIP-1092: Extend Consumer#close with an option to leave the group or not

Hi everyone, Based on our discussion regarding KIP-1092 , I believe this KIP is now ready for a vote. Sincerely, TengYao

[jira] [Created] (KAFKA-17707) Remove zk from BaseConsumerTest

PoAn Yang created KAFKA-17707: - Summary: Remove zk from BaseConsumerTest Key: KAFKA-17707 URL: https://issues.apache.org/jira/browse/KAFKA-17707 Project: Kafka Issue Type: Sub-task Re

[jira] [Resolved] (KAFKA-12895) KIP-751: Drop support for Scala 2.12 in Kafka 4.0 (deprecate in 3.0)

[ https://issues.apache.org/jira/browse/KAFKA-12895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-12895. Resolution: Fixed > KIP-751: Drop support for Scala 2.12 in Kafka 4.0 (deprecate in 3.0) >

[jira] [Created] (KAFKA-17709) remove retry_zinc

Chia-Ping Tsai created KAFKA-17709: -- Summary: remove retry_zinc Key: KAFKA-17709 URL: https://issues.apache.org/jira/browse/KAFKA-17709 Project: Kafka Issue Type: Improvement Rep

[jira] [Resolved] (KAFKA-17415) Avoid overflow of expiried timestamp

[ https://issues.apache.org/jira/browse/KAFKA-17415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17415. Resolution: Fixed > Avoid overflow of expiried timestamp > ---

Re: [DISCUSS] KIP-1058: Txn consumer exerts pressure on remote storage when reading non-txn topic

Hi Christo, Thanks for the review! Adding the new API `nextRemoteLogSegmentMetadataWithTxnIndex` in RLMM helps to reduce the complexity of linear search. With this API, we have to: 1. Maintain one more skip-list [1] for each of the epochs in the partition in RLMM that might increase the memo

[jira] [Created] (KAFKA-17710) Rework UniformHeterogeneousAssignor to improve performance

Sean Quah created KAFKA-17710: - Summary: Rework UniformHeterogeneousAssignor to improve performance Key: KAFKA-17710 URL: https://issues.apache.org/jira/browse/KAFKA-17710 Project: Kafka Issue Ty

Jenkins build is still unstable: Kafka » Kafka PowerPC Daily » test-powerpc #79

See

[jira] [Created] (KAFKA-17708) Fix thread leak: controller-3000-ThrottledChannelReaper-ControllerMutation

Chia-Ping Tsai created KAFKA-17708: -- Summary: Fix thread leak: controller-3000-ThrottledChannelReaper-ControllerMutation Key: KAFKA-17708 URL: https://issues.apache.org/jira/browse/KAFKA-17708 Projec

[jira] [Resolved] (KAFKA-17692) Remove KafkaServer references in streams tests

[ https://issues.apache.org/jira/browse/KAFKA-17692?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-17692. Fix Version/s: 4.0.0 Resolution: Fixed > Remove KafkaServer references in streams t