[jira] [Created] (KAFKA-19546) Rebalance should be triggered if the subscription is changed during group protocol downgrade triggered by static member replacement

Dongnuo Lyu created KAFKA-19546: --- Summary: Rebalance should be triggered if the subscription is changed during group protocol downgrade triggered by static member replacement Key: KAFKA-19546 URL: https://issues.apa

[DISCUSS] KIP-1197: Introduce new method to improve the TopicBasedRemoteLogMetadataManager's initialization

Hi Everyone: Nice to meet you. I created one KIP to request your review. KIP-1197: Introduce new method to improve the TopicBasedRemoteLogMetadataManager's initialization

[jira] [Created] (KAFKA-19547) Kafka Sink Improvement: Add failOnError to Control Exception Behavior

Ejaskhan created KAFKA-19547: Summary: Kafka Sink Improvement: Add failOnError to Control Exception Behavior Key: KAFKA-19547 URL: https://issues.apache.org/jira/browse/KAFKA-19547 Project: Kafka

[jira] [Resolved] (KAFKA-19499) Correct the logger name in PersisterStateManager

[ https://issues.apache.org/jira/browse/KAFKA-19499?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19499. --- Fix Version/s: 4.2.0 Resolution: Fixed > Correct the logger name in PersisterStateMan

Re: 回复： [DISCUSS] KIP-1134: Virtual Clusters in Kafka

Hi Viktor, Thanks for the KIP. Personally, I like large KIPs to be published while there are still details to be worked out because it gives an opportunity to do the discussion in the community. I like the idea of being able to subdivide and virtualise clusters, and I agree that it would be goo

[jira] [Resolved] (KAFKA-19545) Remove MetadataVersionValidator

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

RE: [VOTE] KIP-1121: Compression acceleration in Kafka

Hello all, Voting is in progress for KIP-1121. This KIP introduces a simple framework that enables the use of alternative, faster implementations of the existing compression codecs (Gzip, Snappy, Zstandard and LZ4) in Kafka. https://cwiki.apache.org/confluence/x/Xgr0Ew Thanks -Ori