[jira] [Resolved] (KAFKA-19522) LastKnownLeader should only be elected if it is unfenced

[ https://issues.apache.org/jira/browse/KAFKA-19522?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TengYao Chi resolved KAFKA-19522. - Fix Version/s: 4.2.0 Resolution: Fixed > LastKnownLeader should only be elected if it is

Re: [VOTE] 4.1.0 RC0

Hi TengYao, This bug looks potentially annoying, so yes you can apply it to 4.1. Thanks, Mickael On Sun, Jul 20, 2025 at 3:11 AM TengYao Chi wrote: > > Hi Mickael > > Thank you for releasing version 4.1. > I would like to include KAFKA-19522. This ticket fixes the bug that allows > a replica to

[jira] [Created] (KAFKA-19524) connect-plugin-path crashes with UnsupportedOperationException on plugins without ServiceLoader manifests

Sanskar Jhajharia created KAFKA-19524: - Summary: connect-plugin-path crashes with UnsupportedOperationException on plugins without ServiceLoader manifests Key: KAFKA-19524 URL: https://issues.apache.org/jira/b

Re: [VOTE] 4.1.0 RC0

Hi Mickael I have just merged the patch to 4.1 Thanks, TengYao Mickael Maison 於 2025年7月20日 週日 下午4:53寫道： > Hi TengYao, > > This bug looks potentially annoying, so yes you can apply it to 4.1. > > Thanks, > Mickael > > On Sun, Jul 20, 2025 at 3:11 AM TengYao Chi wrote: > > > > Hi Mickael > > >

Re: [DISCUSS] KIP-1172: Improve EndToEndLatency tool

When representing the value size in the header, do you think it’s better to use the name ‘record-header-value-size’ or keep it as ‘record-header-size’? `record-header-size` would be better for consistency. Junwang Guo 於 2025年7月18日 週五 上午11:07寫道： > Hi Chia-Ping, > > Thanks for your discussion. >

Re: [DISCUSS] KIP-1187: Support to retrieve remote log size via DescribeLogDirs RPC

Hi Kamal, Thanks for the feedback. It’s helpful to understand the overlapping parts between local and remote logs. Regarding `onlyLocalLogSize`, does it refer to local log size minus overlapping retention part? If so, I prefer to set the field when IncludeRemoteInfo is true. Renamed the `RemoteP

Re: [DISCUSS] KIP-1195: cleanup deprecated exceptions in org.apache.kafka.streams.errors.*

hi Rajani I think the section "Deprecated Methods for Removal:" could be removed from this KIP, since they are already deprecated, as Matthias mentioned. Best, Chia-Ping On 2025/07/18 05:52:53 Rajani Karuturi wrote: > Updated KIP to reflect deprecation in 4.2 and removal in the next major > rel

Re: [VOTE] KIP-1193: Deprecate MX4j support

+1 (binding) Thanks, PoAn > On Jul 19, 2025, at 6:28 AM, Kirk True wrote: > > +1 (non-binding) > > Thanks Fede! > > On Fri, Jul 18, 2025, at 1:38 PM, Marouan REJEB wrote: >> Thanks Federico, >> >> +1 (non binding) >> >> Best Regards, >> Marouan >> >> >> On Fri, Jul 18, 2025 at 5:53 PM Ten

[jira] [Created] (KAFKA-19525) Refactor TopicBasedRemoteLogMetadataManager to remove unused code

Kamal Chandraprakash created KAFKA-19525: Summary: Refactor TopicBasedRemoteLogMetadataManager to remove unused code Key: KAFKA-19525 URL: https://issues.apache.org/jira/browse/KAFKA-19525 Pro

Re: [DISCUSS] KIP-1123: Rack-aware partitioning for Kafka Producer

Hi, Thanks for the KIP. One question I have is why two configs are needed instead of a single config? KIP-392 specifies a single client side config. It would be good to be consistent across the clients. Ismael On Fri, Dec 20, 2024 at 3:37 AM Ivan Yurchenko wrote: > Hello all, > > I'd like to p

[jira] [Created] (KAFKA-19526) Enable to use DescribeTopicPartitionsRequest with topic id

Chia-Ping Tsai created KAFKA-19526: -- Summary: Enable to use DescribeTopicPartitionsRequest with topic id Key: KAFKA-19526 URL: https://issues.apache.org/jira/browse/KAFKA-19526 Project: Kafka

Re: [DISCUSS] KIP-1187: Support to retrieve remote log size via DescribeLogDirs RPC

Hi PoAn, > Regarding `onlyLocalLogSize`, does it refer to local log size minus overlapping retention part? Yes, correct. https://sourcegraph.com/github.com/apache/kafka/-/blob/storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java?L2005 Thanks, Kamal On Mon, Jul 21, 2025 a

Re: [VOTE] KIP-1193: Deprecate MX4j support

+1 (non-binding) Best Regards, Jiunn-Yang > PoAn Yang 於 2025年7月21日 上午8:08 寫道： > > +1 (binding) > > Thanks, > PoAn > >> On Jul 19, 2025, at 6:28 AM, Kirk True wrote: >> >> +1 (non-binding) >> >> Thanks Fede! >> >> On Fri, Jul 18, 2025, at 1:38 PM, Marouan REJEB wrote: >>> Thanks Federico,

Re: [DISCUSS] KIP-1195: cleanup deprecated exceptions in org.apache.kafka.streams.errors.*

Hi Matthias and Chia-Ping I updated the KIP and removed references of deprecated methods. It only talks about BrokerNotFoundException now. Can you please review one more time? https://cwiki.apache.org/confluence/display/KAFKA/KIP-1195%3A+deprecate+and+remove+org.apache.kafka.streams.errors.BrokerNo

Re: [DISCUSS] KIP-1187: Support to retrieve remote log size via DescribeLogDirs RPC

hi PoAn chia_00: should `setIncludeRemoteInfo(boolean)` be renamed to ` includeRemoteInfo(boolean)`? chia_01: the `PartitionSize` does not include the `RemoteLogSize`, right? chia_02: Should we add similar fields for `TotalBytes` and `UsableBytes`? Best, Chia-Ping ally heev 於 2025年7月17日 週四

[jira] [Created] (KAFKA-19527) improve the docs of LogDirDescription for remote stroage

Chia-Ping Tsai created KAFKA-19527: -- Summary: improve the docs of LogDirDescription for remote stroage Key: KAFKA-19527 URL: https://issues.apache.org/jira/browse/KAFKA-19527 Project: Kafka