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

ternals/log/UnifiedLog.java?L2005 > > Thanks, > Kamal > > On Mon, Jul 21, 2025 at 7:37 AM PoAn Yang wrote: > >> Hi Kamal, >> >> Thanks for the feedback. It’s helpful to understand the overlapping >> parts between local and remote logs. >> >

Re: [VOTE] KIP-1195: deprecate and remove org.apache.kafka.streams.errors.BrokerNotFoundException

+1 (binding) Thanks > On Jul 23, 2025, at 9:44 PM, Chia-Ping Tsai wrote: > > +1 (binding) > > Rajani Karuturi 於 2025年7月23日 週三 下午9:13寫道： > >> Hi All, >> I would like to start a vote on KIP-1195: deprecate and remove >> org.apache.kafka.streams.errors.BrokerNotFoundException >> >> KIP Link: h

Re: [DISCUSS] KIP-1160: Enable returning supported features from a specific broker

he behavior in the future. > Perhaps we could use "arbitrary controller/broker" instead. > > chia_01: > > the returned type of `DescribeFeaturesOptions#nodeId` could be replaced by > `OptionalInt` > > Best, > Chia-Ping > > On 2025/04/15 14:01:18 PoAn

Re: [VOTE] KIP-1100: Rename org.apache.kafka.server:type=AssignmentsManager and org.apache.kafka.storage.internals.log.RemoteStorageThreadPool metrics

+1 (binding) > On Jul 22, 2025, at 4:54 PM, Omnia Ibrahim wrote: > > Thanks Jiunn-Yang for the KIP, really nice cleanup to keep thing consistent. > +1 binding > > Omnia > >> On 18 Jul 2025, at 12:18, 黃竣陽 wrote: >> >> Hello everyone, >> >> I would like to start a vote on KIP-1100 Rename >>

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

size can be of local-log when remote storage is enabled > on the topic? > > Thanks, > Kamal > > On Mon, Jun 16, 2025 at 8:03 PM PoAn Yang wrote: > >> Hi all, >> >> I would like to start a discussion thread about KIP-1187. >> >> Please take a look and feel free to share any thought. >> >> https://cwiki.apache.org/confluence/x/sYkhFg >> >> Thanks, >> PoAn

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

Re: Failed test ReplicaManagerTest.testMultipleRemoteFetchesInOneFetchRequest on trunk

Hi Kuvardin, The issue is tracked by https://issues.apache.org/jira/browse/KAFKA-19505 and will be resolved by https://github.com/apache/kafka/pull/20167. Thanks. Regards, PoAn > On Jul 17, 2025, at 4:04 AM, Evgeniy Kuvardin > wrote: > > HI > > I have failed the test on > trunk ReplicaManag

Re: [ANNOUNCE] New Kafka PMC member: Lucas Brutschy

Congratulations Lucas! > On Jul 15, 2025, at 9:44 AM, TengYao Chi wrote: > > Glad to hear that! > Congratulations Lucas! > > Cheers, > TengYao > > Kirk True 於 2025年7月15日 週二，上午8:53寫道： > >> Congratulations Lucas! Very well deserved! >> >> On Mon, Jul 14, 2025, at 3:00 PM, Matthias J. Sax wrote

Re: [ANNOUNCE] New Kafka Committer: Omnia Ibrahim

Congrats, Omnia! > On Jun 26, 2025, at 2:55 AM, Tom Bentley wrote: > > Congratulations! > > On Thu, 26 Jun 2025 at 05:48, Shubham Pandey wrote: > >> Congratulations omania >> >> On Wed, 25 Jun, 2025, 23:07 Viktor Somogyi-Vass, >> wrote: >> >>> Congrats Omnia! >>> >>> On Wed, Jun 25, 2025,

[VOTE] KIP-1160: Enable returning supported features from a specific broker

Hi all, I would like to start a vote on KIP-1160. Thank you. KIP: https://cwiki.apache.org/confluence/x/5gnXF Discussion thread: https://lists.apache.org/thread/mbjlgbv2q4x5ml7mx93ls77bg93wtrfy Regards, PoAn

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

Hi all, I would like to start a discussion thread about KIP-1187. Please take a look and feel free to share any thought. https://cwiki.apache.org/confluence/x/sYkhFg Thanks, PoAn

Re: [DISCUSS] KIP-1160: Enable returning supported features from a specific broker

Hi all, I would like to manually bump this thread. If there's no further feedback, I'll start the vote next Monday. Thanks, PoAn On 2025/04/15 14:01:18 PoAn Yang wrote: > Hi all, > > I would like to start a discussion thread on KIP-1160. > > It adds node id to De

Re: [ANNOUNCE] New Kafka PMC Member: José Armando García Sancio

Congratulations Jose! Regards, PoAn > On Jun 16, 2025, at 9:57 PM, Gaurav Narula wrote: > > Congrats José! > > Regards, > Gaurav > >> On 16 Jun 2025, at 14:50, Apoorv Mittal wrote: >> >> Congratulations Jose! >> >> Regards, >> Apoorv Mittal >> >> >> On Mon, Jun 16, 2025 at 2:46 PM TengYa

[jira] [Created] (KAFKA-19387) Support rack awareness in Range and Uniform assignors

PoAn Yang created KAFKA-19387: - Summary: Support rack awareness in Range and Uniform assignors Key: KAFKA-19387 URL: https://issues.apache.org/jira/browse/KAFKA-19387 Project: Kafka Issue Type

Re: [VOTE] KIP-1175: Fix the typo `PARTITIONER_ADPATIVE_PARTITIONING_ENABLE` in ProducerConfig

+1 (non-binding) Thanks for the KIP. Best, PoAn > On Jun 6, 2025, at 12:32 AM, Kuan-Po Tseng wrote: > > +1 (non-binding) > > On Fri, Jun 6, 2025 at 12:15 AM Lucas Brutschy > wrote: > >> +1 (binding) >> >> On Thu, Jun 5, 2025 at 6:06 PM TengYao Chi wrote: >>> >>> +1 (binding) >>> >>> Bes

[jira] [Created] (KAFKA-19360) Remove Admin#listClientMetricsResources and related metric

PoAn Yang created KAFKA-19360: - Summary: Remove Admin#listClientMetricsResources and related metric Key: KAFKA-19360 URL: https://issues.apache.org/jira/browse/KAFKA-19360 Project: Kafka Issue

Re: [VOTE] KIP-1142: Allow to list non-existent group which has dynamic config

Hi all, I updated the KIP to add Metrics Compatibility. Before 4.1, the metric records request ListClientMetricsResources. Above 4.1, we should also record it if the request version of ListConfigResources is 0. Thanks, PoAn > On Apr 29, 2025, at 11:48 PM, PoAn Yang wrote: > &g

Re: [DISCUSS] Apache Kafka 4.1.0 release

Hi Mickael, May I add KIP-1101 (https://cwiki.apache.org/confluence/x/FouMEw) and KIP-1142 (https://cwiki.apache.org/confluence/x/AAqWF) to release plan? These KIPs were accepted on April 17th and April 29th. I’m sorry for not adding them to the release plan when they were accepted. For KIP-1101

[jira] [Created] (KAFKA-19348) Move group metadata hash related functions to a class

PoAn Yang created KAFKA-19348: - Summary: Move group metadata hash related functions to a class Key: KAFKA-19348 URL: https://issues.apache.org/jira/browse/KAFKA-19348 Project: Kafka Issue Type

Re: [VOTE] KIP-1179: Introduce remote.log.manager.follower.thread.pool.size config

+1 (non-binding) Thanks, PoAn > On May 22, 2025, at 8:55 AM, 黃竣陽 wrote: > > Thanks for the KIP! > +1 (non-binding) > > Jiunn-Yang > >> Luke Chen 於 2025年5月22日 上午8:11 寫道： >> >> +1 binding from me. >> >> Thanks. >> Luke >> >> On Thu, May 22, 2025 at 12:54 AM Kamal Chandraprakash < >> kamal.c

Re: [VOTE] 3.9.1 RC2

Hi, I have done the following tests: - Built from 3.9.1-rc2 with OpenJDK-17 and OpenJDK-21. - Ran all unit and integration tests. - Verified basic produce/consume. - Ran KRaft with kafka_2.13-3.9.1.tgz +1 (non-binding) Thanks, PoAn > On May 18, 2025, at 1:04 PM, 黃竣陽 wrote: > > +1 (non-bindin

[jira] [Created] (KAFKA-19302) Move ReplicaState and Replica to server module

PoAn Yang created KAFKA-19302: - Summary: Move ReplicaState and Replica to server module Key: KAFKA-19302 URL: https://issues.apache.org/jira/browse/KAFKA-19302 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-19301) Move PartitionListener, AlterPartitionListener, DelayedOperations, AssignmentState, PartitionState, and PendingPartitionChange to server module

PoAn Yang created KAFKA-19301: - Summary: Move PartitionListener, AlterPartitionListener, DelayedOperations, AssignmentState, PartitionState, and PendingPartitionChange to server module Key: KAFKA-19301 URL: https

[jira] [Created] (KAFKA-19299) Fix flaky RemoteIndexCacheTest#testCacheEntryIsDeletedOnRemoval

PoAn Yang created KAFKA-19299: - Summary: Fix flaky RemoteIndexCacheTest#testCacheEntryIsDeletedOnRemoval Key: KAFKA-19299 URL: https://issues.apache.org/jira/browse/KAFKA-19299 Project: Kafka

Re: [DISCUSS] KIP-1180: Add a generic feature level metric

Hi Kevin, Thanks for the KIP. 4. How about using a new metric type to collect all feature metrics? So we don’t need to have different metric names in controller and broker. For example: * kafka.server:type=FeatureMetrics,name=FinalizedLevel,featureName=X * kafka.server:type=FeatureMetrics,name=Mi

Re: [VOTE] KIP-1130: Add metrics indicating the connection count exceeds

+1 (non-binding) Best, PoAn > On May 6, 2025, at 6:42 PM, 黃竣陽 wrote: > > +1 (non-binding) > > Best Regards, > Jiunn-Yang > >> Kuan Po Tseng 於 2025年5月6日 凌晨12:31 寫道： >> >> +1(non-binding), thanks for the KIP! >> >> Best, >> Kuan-Po Tseng >> >> On 2025/05/05 07:02:04 TengYao Chi wrote: >>> H

Re: [VOTE] KIP-1157: Enforce KafkaPrincipalSerde Implementation for KafkaPrincipalBuilder

+1 (non-binding) PoAn > On May 5, 2025, at 4:44 PM, Chia-Ping Tsai wrote: > > +1 (binding) > > On 2025/05/05 08:03:12 Johnny Wang wrote: >> Hi all, >> I would like to call a vote for KIP-1157. >> https://cwiki.apache.org/confluence/x/1gq9F >> >> This KIP proposes to enforce the implementation

Re: [DISCUSS] KIP-1157: Enforce KafkaPrincipalSerde Implementation for KafkaPrincipalBuilder

Hi Johnny, Thanks for the KIP. PoAn_0: Currently, the DefaultKafkaPrincipalBuilder extends both KafkaPrincipalBuilder and KafkaPrincipalSerde. After this KIP, will you change DefaultKafkaPrincipalBuilder to just implement KafkaPrincipalBuilder? If yes, you may need to include this on the KIP beca

[jira] [Resolved] (KAFKA-18760) Deprecate Optional and return String from public EndPoint#Listener

[ https://issues.apache.org/jira/browse/KAFKA-18760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-18760. --- Fix Version/s: 4.1.0 Resolution: Fixed > Deprecate Optional and return String from pub

Re: [VOTE] KIP-1142: Allow to list non-existent group which has dynamic config

ks, > Chia-Ping > > TengYao Chi 於 2025年4月23日 週三 下午8:06寫道： > >> Thanks for the KIP. >> +1 (binding) >> >> Best, >> TengYao >> >> On 2025/04/14 11:29:28 Andrew Schofield wrote: >>> Hi PoAn, >>> Thanks for the KIP. >>> &

Re: [VOTE] KIP-1140: Avoid to return null value in Map from public api of consumer

+1 (non-binding) Thanks, PoAn > On Apr 26, 2025, at 4:10 PM, Chia-Ping Tsai wrote: > > +1 (binding) > > 黃竣陽 於 2025年4月26日 週六 下午1:37寫道： > >> Hello all >> >> I would like to call a vote on KIP-1140: Avoid to return null value in Map >> from public api of consumer >> >> KIP: >>

[jira] [Created] (KAFKA-19197) Automatic generate metric list in document

PoAn Yang created KAFKA-19197: - Summary: Automatic generate metric list in document Key: KAFKA-19197 URL: https://issues.apache.org/jira/browse/KAFKA-19197 Project: Kafka Issue Type: Improvement

[jira] [Resolved] (KAFKA-19110) Add missing unit test for Streams-consumer integration

[ https://issues.apache.org/jira/browse/KAFKA-19110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-19110. --- Fix Version/s: 4.1.0 Resolution: Fixed > Add missing unit test for Streams-consu

Re: [VOTE] 3.9.1 RC1

Hi TengYao, I have done the following tests: - Built from 3.9.1-rc1 with OpenJDK-17 and OpenJDK-21. - Ran all unit and integration tests. - Verified basic produce/consume. - Validated the checksums and keys. - Ran KRaft with kafka_2.13-3.9.1.tgz Thanks, PoAn > On Apr 23, 2025, at 5:00 PM, TengY

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

Hi Ivan, Thanks for the KIP. The Jira link for this KIP is KAFKA-1. Could you update to a correct Jira number? Best, PoAn > On Mar 30, 2025, at 2:13 AM, Ivan Yurchenko wrote: > > Hi Federico, > > There's a sentence about reduced latency in the Motivation section. Do you > think that'd be eno

Re: [VOTE] KIP-1131: Improved controller-side monitoring of broker states

+1 (non-binding) Thanks, PoAn > On Apr 23, 2025, at 5:34 AM, Colin McCabe wrote: > > +1 (binding) > > thanks, > Colin > > On Tue, Apr 15, 2025, at 02:25, Federico Valeri wrote: >> +1 non binding >> >> Thanks >> >> On Tue, Mar 25, 2025 at 11:29 PM Kevin Wu wrote: >>> >>> Hello all, >>> >>

[jira] [Created] (KAFKA-19183) Move Pool and PoolTest to server module

PoAn Yang created KAFKA-19183: - Summary: Move Pool and PoolTest to server module Key: KAFKA-19183 URL: https://issues.apache.org/jira/browse/KAFKA-19183 Project: Kafka Issue Type: Sub-task

Re: [DISCUSS] KIP-1101: Trigger rebalance on rack topology changes

ected alternative section? It would be good to have a trace of it. > > Best, > David > > On Wed, Apr 16, 2025 at 4:23 AM PoAn Yang <mailto:yangp...@gmail.com>> wrote: > >> Hi Lucas, >> >> Thank you. Here is vote thread >> https://lists.apache.or

Re: [VOTE] KIP-1101: Trigger rebalance on rack topology changes

;>> Subject: Re: [VOTE] KIP-1101: Trigger rebalance on rack topology changes >>> >>> +1 (binding) >>> >>> On Tue, Dec 17, 2024 at 2:08 AM 郭骏旺 wrote: >>>> >>>> +1 （non-binding） >>>> >>>> On M

Re: [DISCUSS] KIP-1101: Trigger rebalance on rack topology changes

> Lucas > > On Thu, Apr 10, 2025 at 11:29 AM PoAn Yang <mailto:yangp...@gmail.com>> wrote: >> >> Hi David and Lucas, >> >> Thanks for the review and great suggestion. >> >> DJ01: Add the statement about rack-aware rebalance

[DISCUSS] KIP-1160: Enable returning supported features from a specific broker

Hi all, I would like to start a discussion thread on KIP-1160. It adds node id to DescribeFeaturesOptions, so Admin client and kafka-features have ability to retrieve features from a specific node. Please take a look and feel free to share any thought. https://cwiki.apache.org/confluence/x/5gnX

Re: [VOTE] KIP-1143: Deprecated Optional and return String from public Endpoint#listenerName

 PM, Federico Valeri wrote: > > +1 non binding > > Thanks > > On Fri, Apr 11, 2025 at 1:33 PM TengYao Chi wrote: >> >> Thanks for this great cleanup! >> +1 (binding) >> >> Best, >> TengYao >> >> On 2025/04/03 14:41:09 PoAn

Re: [DISCUSS] KIP-1142: Allow to list non-existent group which has dynamic config

gt; type is empty or includes different resource > types, it returns the error to user. > > It sounds good! > > PoAn Yang 於 2025年4月4日 週五 下午5:53寫道： > >> Hi Chia-Ping, >> >> chia_2: We can do the best to improve user experience. For v1 request, if >> th

Re: [ANNOUNCE] New committer: Apoorv Mittal

Congrats, Apoorv! > On Apr 11, 2025, at 2:15 AM, Randall Hauch wrote: > > Congrats, Apoorv! > > On Thu, Apr 10, 2025 at 11:30 AM Lianet M. wrote: > >> Congrats Apoorv! Well deserved! >> >> On Thu, Apr 10, 2025, 12:20 p.m. Andrew Schofield < >> andrew_schofield_j...@outlook.com> wrote: >> >>

Re: [VOTE] KIP-1148: Remove log.cleaner.enable configuration

Thanks for the KIP. +1 (non-binding) PoAn > On Apr 10, 2025, at 6:55 PM, 黃竣陽 wrote: > > Thanks for the KIP. > > +1 (non-binding), > >> Andrew Schofield 於 2025年4月10日 下午4:30 寫道： >> >> Thanks for the KIP. >> >> +1 (binding) >> >> Andrew >> >> From: Kuan Po Tseng >> Date: Thursday, 10 Apr

Re: [DISCUSS] KIP-1159: Large message reference based Serializer

Hi Omnia, Thanks for the KIP. It’s good to integrate blob store for large objects. PY_1: Does LargeMessageDeserializer need large.message.blob.store.blob.id_generator configuration? The blob id is encapsulated in Kafka event by LargeMessageSerializer. The LargeMessageDeserializer can get the id

Re: [DISCUSS] KIP-1101: Trigger rebalance on rack topology changes

rade, not all the coordinators will support the >> new way and groups may bounce between those coordinators as their >> underlying __consumer_offsets partitions are moved within the cluster >> (during the roll). This may trigger unnecessary rebalances. One way to >> avoi

[jira] [Created] (KAFKA-19113) Migrate DelegationTokenManager to server module

PoAn Yang created KAFKA-19113: - Summary: Migrate DelegationTokenManager to server module Key: KAFKA-19113 URL: https://issues.apache.org/jira/browse/KAFKA-19113 Project: Kafka Issue Type: Sub

Re: KIP-1155: Metadata Version Downgrades [DISCUSS]

Hi Colin, Thanks for the KIP. It’s good to give users more flexibility to downgrade metadata.version. PY1: Each feature has bootstrapMetadataVersion. For example, TV_2 is IBP_4_0_IV2. Assume that a cluster uses TV_2 and metadata.version 4.0-IV2. If a user downgrades metadata.version to 3.9-IV0

[VOTE] KIP-1142: Allow to list non-existent group which has dynamic config

Hi all, I would like to start a vote on KIP-1142. Thank you. KIP: https://cwiki.apache.org/confluence/x/AAqWF Discussion thread: https://lists.apache.org/thread/c3q584qtrodys2mkzdg0qxrktzbcjzmp Regards, PoAn

Re: [DISCUSS] KIP-1142: Allow to list non-existent group which has dynamic config

Hi all, If there is no further discussion, I will start vote thread for KIP-1142 tomorrow. Thanks, PoAn > On Mar 16, 2025, at 5:23 PM, PoAn Yang wrote: > > Hi Andrew, > > Thanks for the review. > > AS1: The kafka-client-metrics.sh —describe —name for a non-existent

[jira] [Created] (KAFKA-19067) AsyncKafkaConsumer may return stale fetch result after seek operation

PoAn Yang created KAFKA-19067: - Summary: AsyncKafkaConsumer may return stale fetch result after seek operation Key: KAFKA-19067 URL: https://issues.apache.org/jira/browse/KAFKA-19067 Project: Kafka

Re: kafka 4.0.0 running on java 11

Hi Max, Please check the Notable changes in 4.0.0 . The minimal Java version for Kafka Stream is 11. For brokers, connect, and tools, they require Java 17. You can also check KIP-750

[jira] [Created] (KAFKA-19032) Remove TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames

PoAn Yang created KAFKA-19032: - Summary: Remove TestInfoUtils.TestWithParameterizedQuorumAndGroupProtocolNames Key: KAFKA-19032 URL: https://issues.apache.org/jira/browse/KAFKA-19032 Project: Kafka

[jira] [Created] (KAFKA-19092) Flaky test QuorumControllerTest#testBalancePartitionLeaders

PoAn Yang created KAFKA-19092: - Summary: Flaky test QuorumControllerTest#testBalancePartitionLeaders Key: KAFKA-19092 URL: https://issues.apache.org/jira/browse/KAFKA-19092 Project: Kafka Issue

[jira] [Created] (KAFKA-19091) Flaky test DelayedFutureTest#testDelayedFuture

PoAn Yang created KAFKA-19091: - Summary: Flaky test DelayedFutureTest#testDelayedFuture Key: KAFKA-19091 URL: https://issues.apache.org/jira/browse/KAFKA-19091 Project: Kafka Issue Type: Test

[jira] [Created] (KAFKA-19090) Move DelayedFuture and DelayedFuturePurgatory to server module

PoAn Yang created KAFKA-19090: - Summary: Move DelayedFuture and DelayedFuturePurgatory to server module Key: KAFKA-19090 URL: https://issues.apache.org/jira/browse/KAFKA-19090 Project: Kafka

Re: [DISCUSS] KIP-1142: Allow to list non-existent group which has dynamic config

s are up-to-date. > > chia_3: > > `ListClientMetricsResourcesRequest` and `ListClientMetricsResourcesResponse` > are not public APIs, so it seems to me it is unnecessary to "deprecate" them > > chia_4: > > could you please add "empty means all sources

Re: [DISCUSS] KIP-1142: Allow to list non-existent group which has dynamic config

type is empty or includes different resource types, it returns the error to user. Thanks, PoAn > On Apr 4, 2025, at 4:00 PM, PoAn Yang wrote: > > Hi Andrew and Chia-Ping, > > Thanks for the review. > > AS5: My mistake. Remove the specific named entity. The “—describe

[VOTE] KIP-1143: Deprecated Optional and return String from public Endpoint#listenerName

Hi all, I would like to start a vote on KIP-1143. Thank you. KIP: https://cwiki.apache.org/confluence/x/LwqWF Discussion thread: https://lists.apache.org/thread/1967vwhhy34lcjmcd0lfk6p5k6chj8rq Regards, PoAn

[jira] [Resolved] (KAFKA-19067) AsyncKafkaConsumer may return stale fetch result after seek operation

[ https://issues.apache.org/jira/browse/KAFKA-19067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-19067. --- Resolution: Won't Fix > AsyncKafkaConsumer may return stale fetch result after seek o

Re: [VOTE] KIP-1133: AK Documentation and Website in Markdown

Thanks for the KIP. Look forward to using Hugo and markdown. +1 (non-binding) Best, PoAn > On Apr 2, 2025, at 3:01 PM, Bruno Cadonna wrote: > > Thanks a lot for the KIP! > > +1 (binding) > > Best, > Bruno > > On 02.04.25 02:57, Matthias J. Sax wrote: >> +1 (binding) >> On 3/27/25 2:39 AM, T

Re: [DISCUSS] KIP-1143: Deprecated Optional and return String from public Endpoint#listenerName

Hi Kirk and Chia-Ping, Thanks for the review. KT1: Update Motivation section to elaborate more on why we want to deprecated Optional function in common Endpoint. KT2: Like Chia-Ping mentioned, the only usage of common Endpoint in client module is Authorizer and the data is from server side, so

[jira] [Resolved] (KAFKA-16260) Deprecate window.size.ms and window.inner.serde.class in StreamsConfig

[ https://issues.apache.org/jira/browse/KAFKA-16260?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-16260. --- Resolution: Fixed > Deprecate window.size.ms and window.inner.serde.class in StreamsCon

Re: [DISCUSS] KIP-1104: Allow Foreign Key Extraction from Both Key and Value in KTable Joins

Hi Chu Cheng Li, In KIP-1104, there is deprecation plan for old join methods. However, in the PR #17756, it didn't mark these functions as deprecated. Do we still want to deprecate join methods? Or we can remove deprecation plan in the KIP. Thanks! Best Regards, PoAn On 2024/11/19 17:55:32 Chu

[jira] [Created] (KAFKA-19042) Move kafka.api test cases to client-integration-tests module

PoAn Yang created KAFKA-19042: - Summary: Move kafka.api test cases to client-integration-tests module Key: KAFKA-19042 URL: https://issues.apache.org/jira/browse/KAFKA-19042 Project: Kafka

[jira] [Created] (KAFKA-19036) Rewrite LogAppendTimeTest and move it to server module

PoAn Yang created KAFKA-19036: - Summary: Rewrite LogAppendTimeTest and move it to server module Key: KAFKA-19036 URL: https://issues.apache.org/jira/browse/KAFKA-19036 Project: Kafka Issue Type

Re: [DISCUSS] KIP-1101: Trigger rebalance on rack topology changes

shes, is it on every > heartbeat? > > Thanks, > Jeff > > On Wed, Mar 12, 2025 at 11:33 PM PoAn Yang wrote: > >> Hi David, >> >> Yes, I will continue working on this. >> >> DJ02: As Kirk noted earlier, since the topic hash calculation is on ser

[jira] [Resolved] (KAFKA-17045) Move MetadataLogConfig from kafka to kafka.raft

[ https://issues.apache.org/jira/browse/KAFKA-17045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-17045. --- Resolution: Duplicate This will be covered by https://issues.apache.org/jira/browse/KAFKA-15599

[jira] [Created] (KAFKA-19009) Move MetadataCacheTest to metadata module

PoAn Yang created KAFKA-19009: - Summary: Move MetadataCacheTest to metadata module Key: KAFKA-19009 URL: https://issues.apache.org/jira/browse/KAFKA-19009 Project: Kafka Issue Type: Sub-task

Re: [DISCUSS] KIP-1143: Deprecated Optional and return String from public Endpoint#listenerName

che/kafka/blob/trunk/clients/src/main/java/org/apache/kafka/clients/admin/RaftVoterEndpoint.java >>>> >>>> Best, >>>> Chia-Ping >>>> >>>> >>>> >>>> Ismael Juma 於 2025年3月17日 週一 上午4:48寫道： >>>> >>>

Re: [DISCUSS] KIP-1143: Deprecated Optional and return String from public Endpoint#listenerName

t;> >>>> We cannot make incompatible changes to public classes outside of major >>>> releases. The evolving annotation was left by mistake given that these >>>> classes have been there for a long time by now. >>>> >>>> The general

[DISCUSS] KIP-1143: Deprecated Optional and return String from public Endpoint#listenerName

Hi all, I would like to start a discussion thread on KIP-1143. This KIP removes redundant org.apache.kafka.network.EndPoint and replaces it with org.apache.kafka.common.Endpoint. Also, it changes output of Endpoint#listenerName from Optional to String. Please take a look and feel free to share

Re: [DISCUSS] KIP-1142: Allow to list non-existent group which has dynamic config

ich is not the same as > listing the existing groups): > >> bin/kafka-configs.sh --describe --entity-type groups > > And perhaps, this could list the config for the existing groups because it > uses ListGroups to get the list of groups: > >> bin/kafka-configs.sh --describe --e

[jira] [Created] (KAFKA-18998) Move AuthHelper to server module

PoAn Yang created KAFKA-18998: - Summary: Move AuthHelper to server module Key: KAFKA-18998 URL: https://issues.apache.org/jira/browse/KAFKA-18998 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-18997) Move ConfigHelper to server module

PoAn Yang created KAFKA-18997: - Summary: Move ConfigHelper to server module Key: KAFKA-18997 URL: https://issues.apache.org/jira/browse/KAFKA-18997 Project: Kafka Issue Type: Improvement

[DISCUSS] KIP-1142: Allow to list non-existent group which has dynamic config

Hi all, I would like to start a discussion thread on KIP-1142. Currently, kafka-configs.sh requires explicit group names to describe configurations, which limits flexibility in managing dynamically configured groups. This KIP proposes extending the ListGroups API to include groups that do not

[jira] [Created] (KAFKA-18975) Move CustomQuotaCallbackTest and ConsumerIntegrationTest out of core module

PoAn Yang created KAFKA-18975: - Summary: Move CustomQuotaCallbackTest and ConsumerIntegrationTest out of core module Key: KAFKA-18975 URL: https://issues.apache.org/jira/browse/KAFKA-18975 Project: Kafka

Re: [DISCUSS] KIP-1101: Trigger rebalance on rack topology changes

an inspiration/reference. I suppose that we could use it on the server >>> but we should definitely not use it on the client. I am not sure how others >>> feel about it. >>> >>> Best, >>> David >>> >>> On Mon, Jan 6, 2025 at 5:21 AM Po

[jira] [Resolved] (KAFKA-18845) Fail test QuorumControllerTest#testUncleanShutdownBrokerElrEnabled

[ https://issues.apache.org/jira/browse/KAFKA-18845?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-18845. --- Resolution: Fixed > Fail test QuorumControllerTest#testUncleanShutdownBrokerElrEnab

[jira] [Created] (KAFKA-18937) Consider to add kraft state to BootstrapMetadata

PoAn Yang created KAFKA-18937: - Summary: Consider to add kraft state to BootstrapMetadata Key: KAFKA-18937 URL: https://issues.apache.org/jira/browse/KAFKA-18937 Project: Kafka Issue Type

[jira] [Created] (KAFKA-18884) Move TransactionMetadata to transaction-coordinator module

PoAn Yang created KAFKA-18884: - Summary: Move TransactionMetadata to transaction-coordinator module Key: KAFKA-18884 URL: https://issues.apache.org/jira/browse/KAFKA-18884 Project: Kafka Issue

[jira] [Created] (KAFKA-18883) Move TransactionLog to transaction-coordinator module

PoAn Yang created KAFKA-18883: - Summary: Move TransactionLog to transaction-coordinator module Key: KAFKA-18883 URL: https://issues.apache.org/jira/browse/KAFKA-18883 Project: Kafka Issue Type

[jira] [Resolved] (KAFKA-18441) Fix flaky KafkaAdminClientTest#testAdminClientApisAuthenticationFailure

[ https://issues.apache.org/jira/browse/KAFKA-18441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-18441. --- Resolution: Fixed > Fix flaky KafkaAdminClientTest#testAdminClientApisAuthenticationFail

[jira] [Created] (KAFKA-18712) Move Endpoint to server module

PoAn Yang created KAFKA-18712: - Summary: Move Endpoint to server module Key: KAFKA-18712 URL: https://issues.apache.org/jira/browse/KAFKA-18712 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-18707) Move KRaftMetadataCachePublisher to metadata module

PoAn Yang created KAFKA-18707: - Summary: Move KRaftMetadataCachePublisher to metadata module Key: KAFKA-18707 URL: https://issues.apache.org/jira/browse/KAFKA-18707 Project: Kafka Issue Type

[jira] [Created] (KAFKA-18706) Move AclPublisher to metadata module

PoAn Yang created KAFKA-18706: - Summary: Move AclPublisher to metadata module Key: KAFKA-18706 URL: https://issues.apache.org/jira/browse/KAFKA-18706 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-18705) Move ConfigRepository to metadata module

PoAn Yang created KAFKA-18705: - Summary: Move ConfigRepository to metadata module Key: KAFKA-18705 URL: https://issues.apache.org/jira/browse/KAFKA-18705 Project: Kafka Issue Type: Sub-task

[jira] [Created] (KAFKA-18704) Move metadata code from `core` to `metadata` module

PoAn Yang created KAFKA-18704: - Summary: Move metadata code from `core` to `metadata` module Key: KAFKA-18704 URL: https://issues.apache.org/jira/browse/KAFKA-18704 Project: Kafka Issue Type

[jira] [Created] (KAFKA-18555) Avoid casting MetadataCache to KRaftMetadataCache

PoAn Yang created KAFKA-18555: - Summary: Avoid casting MetadataCache to KRaftMetadataCache Key: KAFKA-18555 URL: https://issues.apache.org/jira/browse/KAFKA-18555 Project: Kafka Issue Type

[jira] [Created] (KAFKA-18546) Change ClientUtilsTest#testParseAndValidateAddressesWithReverseLookup to mock test

PoAn Yang created KAFKA-18546: - Summary: Change ClientUtilsTest#testParseAndValidateAddressesWithReverseLookup to mock test Key: KAFKA-18546 URL: https://issues.apache.org/jira/browse/KAFKA-18546 Project

[jira] [Created] (KAFKA-18541) Fix flaky KafkaStreamsTelemetryIntegrationTest#shouldPassCorrectMetricsDynamicInstances

PoAn Yang created KAFKA-18541: - Summary: Fix flaky KafkaStreamsTelemetryIntegrationTest#shouldPassCorrectMetricsDynamicInstances Key: KAFKA-18541 URL: https://issues.apache.org/jira/browse/KAFKA-18541

[jira] [Created] (KAFKA-18537) Fix flaky RemoteIndexCacheTest#testCleanerThreadShutdown

PoAn Yang created KAFKA-18537: - Summary: Fix flaky RemoteIndexCacheTest#testCleanerThreadShutdown Key: KAFKA-18537 URL: https://issues.apache.org/jira/browse/KAFKA-18537 Project: Kafka Issue

[jira] [Created] (KAFKA-18536) Flaky ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle

PoAn Yang created KAFKA-18536: - Summary: Flaky ReplicationQuotasTest.shouldBootstrapTwoBrokersWithFollowerThrottle Key: KAFKA-18536 URL: https://issues.apache.org/jira/browse/KAFKA-18536 Project: Kafka

[jira] [Created] (KAFKA-18535) Flaky PlaintextConsumerPollTest.testMaxPollIntervalMsDelayInRevocation

PoAn Yang created KAFKA-18535: - Summary: Flaky PlaintextConsumerPollTest.testMaxPollIntervalMsDelayInRevocation Key: KAFKA-18535 URL: https://issues.apache.org/jira/browse/KAFKA-18535 Project: Kafka

[jira] [Resolved] (KAFKA-18440) Admin does not convert the AuthorizationException to fatal error in using bootstrap controllers

[ https://issues.apache.org/jira/browse/KAFKA-18440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-18440. --- Reviewer: Divij Vaidya Resolution: Fixed > Admin does not convert the AuthorizationExcept

[jira] [Created] (KAFKA-18448) Support SSL protocol with java.security.auth.login.config

PoAn Yang created KAFKA-18448: - Summary: Support SSL protocol with java.security.auth.login.config Key: KAFKA-18448 URL: https://issues.apache.org/jira/browse/KAFKA-18448 Project: Kafka Issue

[jira] [Created] (KAFKA-18447) Support SASL_SSL protocol with java.security.auth.login.config

PoAn Yang created KAFKA-18447: - Summary: Support SASL_SSL protocol with java.security.auth.login.config Key: KAFKA-18447 URL: https://issues.apache.org/jira/browse/KAFKA-18447 Project: Kafka

[jira] [Created] (KAFKA-18431) Remove KafkaController

PoAn Yang created KAFKA-18431: - Summary: Remove KafkaController Key: KAFKA-18431 URL: https://issues.apache.org/jira/browse/KAFKA-18431 Project: Kafka Issue Type: Sub-task Reporter

[jira] [Created] (KAFKA-18423) Remove ZkData

PoAn Yang created KAFKA-18423: - Summary: Remove ZkData Key: KAFKA-18423 URL: https://issues.apache.org/jira/browse/KAFKA-18423 Project: Kafka Issue Type: Sub-task Reporter: PoAn Yang

  1   2   >