Re: [DISCUSS] KIP-1080: Fix the typo: `maxlifeTimeMs` in CreateDelegationTokenOptions

Thanks for fixing the typo. LGTM. Best, PoAn On 2024/08/12 14:03:27 TengYao Chi wrote: > Hi > Could you please remove the placeholder from the KIP template ? > > Best, > TengYao > > TengYao Chi 於 2024年8月12日 週一 下午9:47寫道： > > > Hi > > Thanks for this KIP, LGTM. > > > > Best Regards, > > TengYao

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

Hi Lucas, Thanks for the review! 1) Yes, I add related change for kafka-share-groups.sh to the KIP. Could you take a look? Thanks for the suggestion. 2) We use CONSUMER-ID as member ID. If we use MEMBER-EPOCH here, users may confuse what is different between CONSUMER and MEMBER. Thanks, PoAn

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

's presented as if the option already exists and we're >> only changing the output (which is the case for kafka-consumer-groups but >> not for kafka-share-groups) >> >> That's all on my side. Thanks! >> >> Lianet >> >> On Wed, Nov 20,

Re: [VOTE] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

oolean` instead of an unboxed boolean. It > seems we could use the unboxed type here. > > Cheers, > Lucas > > On Tue, Nov 26, 2024 at 1:55 AM PoAn Yang wrote: >> >> Hi everyone, >> >> Thanks for your voting. >> >> The KIP passes with 4 +1 (

[VOTE] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

Hi All, I would like to start vote on KIP-1099: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1099%3A+Extend+kafka-consumer-groups+command+line+tool+to+support+new+consumer+group Discussion thread: https://lists.apache.org/thread/lo64123wm3kjmjsx72xg67wvjx9nykk8 Thanks, PoAn

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

DJ4: Could you please also include the required changes to the > ConsumerGroupDescribed API in the public interface section? We basically > need to bump the version, add the new field, etc. > > Thanks, > David > > On Mon, Nov 18, 2024 at 5:40 AM PoAn Yang wrote: > &

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

/modern/consumer/ConsumerGroupMember.java#L454 > > > Best, > Chia-Ping > > On 2024/11/19 15:45:16 PoAn Yang wrote: >> Hi David, >> >> Thanks for the reminder. >> >> DJ4: Add related content to the KIP. >> Bump validVersions in ConsumerGrou

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

gt;>>> Lianet >>>> >>>> On Thu, Oct 31, 2024 at 7:30 AM Andrew Schofield < >>>> andrew_schofield_j...@outlook.com> wrote: >>>> >>>>> Hi PoAn, >>>>> Thanks for the KIP. I have a few comments. >>>>>

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

> Hi, > > DJ2: Using "-" sounds good to me. > > DJ3: That seems reasonable to me. > > DJ4: Why not add it right now? I don't want to change the output of the > tool too many times. > > Best, > David > > On Fri, Nov 15, 2024 at 3:23 PM PoAn Ya

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

introduce any >> changes to the —describe —verbose option. (If not, it would mean a bigger >> change to the output of —describe —verbose which I expect is not the >> intention?) >> >> Thanks! >> >> Lianet >> >> >> On Wed, Nov 20, 2

Re: Plz help on kafka consumer API performance(taking time on the first consumer.poll())

Hi Giridar, > *Code explanation:Fetching records is taking time for the first poll.* > Poll Records Count: 500 diff: 1284 > Poll Records Count: 500 diff: 3 > > For the first 500 records it took 1284 ms and next 500 records it took 4 ms > > *Why this much difference? I would like to improve the p

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

gt; Best, > Chia-Ping > > PoAn Yang 於 2024年11月23日 週六 下午12:35寫道： > >> Hi Chia-Ping / David, >> >> Thanks for the great suggestion. >> >> How about using “isClassic”? >> The term like “isLegacy” may be equivocal in the future. >> For example, if w

Re: [ANNOUNCE] New committer: Andrew Schofield

Congratulations Andrew! PoAn > On Dec 2, 2024, at 10:36 PM, Rajini Sivaram wrote: > > Congratulations, Andrew! Well deserved! > > Regards, > > Rajini > > On Mon, Dec 2, 2024 at 2:31 PM Kamal Chandraprakash < > kamal.chandraprak...@gmail.com> wrote: > >> Congrats Andrew! >> >> On Mon, Dec 2

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

Hi David, Thanks for the feedback. Yes, I agree that the “UPGRADED” column name is better. I updated the KIP. Best, PoAn > On Nov 25, 2024, at 11:11 PM, PoAn Yang wrote: > > Hi Andrew, > > Thanks for the feedback. > > AS4: Change TARGET-ASSIGNMENT-EPOCH to ASSIGNMENT

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

iate. Personally, I would prefer > just MEMBER-EPOCH and ASSIGNMENT, and remove the "target" fields. > > Thanks, > Andrew > > > From: PoAn Yang > Sent: 24 November 2024 15:08 > To: dev@kafka.apache.org > Subje

Re: [DISCUSS] Apache Kafka 4.0.0 release

Hi David, Based on your comment on KIP-1099. I’ve added KIP-1099 to the release plan. Thanks, PoAn > On Nov 20, 2024, at 8:11 PM, Divij Vaidya wrote: > > Based on initial feedback from the community, I don't anticipate > the

Re: [VOTE] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

t; Subject: Re: [VOTE] KIP-1099: Extend kafka-consumer-groups command line >>> tool to support new consumer group >>> >>> +1 (binding) >>> >>> In gmail, the discuss and the vote threads got merged somehow. >>> >>> On Wed, Nov 20, 2024

Re: [VOTE] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

/17958#discussion_r1865801241 Regards, PoAn > On Nov 28, 2024, at 8:27 PM, PoAn Yang wrote: > > Hi Lucas, > > Thanks for the reminder. Yes, we can use an unboxed boolean. > Update the KIP. > > Thanks, > PoAn > >> On Nov 28, 2024, at 8:23 PM, Lucas Brutschy

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

gt; additioning them. I wonder if this is a good practice. Intuitively, >> I would >>>>> have used XOR or hashed the hashed. Guava has a method for combining >>>>> hashes. It may be worth looking into the algorithm used. >>>>> >>>>> D

Re: [DISCUSS] KIP-1071: Streams Rebalance Protocol

Hi Lucas, Thanks for the KIP. PY1: In StreamsGroupHeartbeatRequest, it uses broker and zkBroker in listeners field. Is this intended? IIUC, the KIP will be implemented in 4.1. The zookeeper will be removed in 4.0. Probably, we should change it as broker and controller. We may need a similar cha

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

Hi Chia-Ping, Thanks for the vote and reminder. I update the KIP for it. Regards, PoAn > On Dec 16, 2024, at 5:19 PM, TaiJu Wu wrote: > > +1 （non-binding） > > On Mon, Dec 16, 2024 at 5:01 PM PoAn Yang wrote: > >> Hi All, >> >> I would like to

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

Hi All, I would like to start vote on KIP-1101: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1101%3A+Trigger+rebalance+on+rack+topology+changes Discussion thread: https://lists.apache.org/thread/l8ko353v3nn1blgymsty895x6c98oxlx Thanks, PoAn

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

Hi Chia-Ping / David / Andrew, Thanks for the review and suggestions. DJ01: Removed all implementation details. DJ02: Does the “incrementally” mean that we only calculate the difference parts? For example, if the number of partition change, we only calculate the hash of number of partition and

Re: [VOTE] KIP-1068: New metrics for the new KafkaConsumer

Hi everyone, During the implementation of KIP-1068, we add a new metric `application-events-expired-size`. It helps to measure how many application events are expired. Currently, we don't add a similar metric for background events. The only background event with a result in the form of a future i

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

non upgraded members. What do you think? >> >> If we cannot find a good way to represent this, we could drop it from this >> KIP too. >> >> Best, >> David >> >> On Fri, Nov 22, 2024 at 5:12 PM PoAn Yang wrote: >> >>> Hi Chia-Ping

Re: [DISCUSS] KIP-1099: Extend kafka-consumer-groups command line tool to support new consumer group

t's true. This inconsistency >> feels >>> confusing to me. For example, users call Admin#describeConsumerGroups and >>> see that a member has the 'consumer' protocol when it's in a classic >> group. >>> Then, if the group is upgra

Re: [VOTE] KIP-1020 Move `window.size.ms` and `windowed.inner.serde.class` from `StreamsConfig` to TimeWindowedDe/Serializer class

Hi everyone, During implementation of KIP-1020, we found that SessionWindowedDe/Serializer also use `windowed.inner.class.serde`. I update the KIP to introduce `windowed.inner.serializer.class` to SessionWindowedSerializer and `windowed.inner.deserializer.class` to SessionWindowedDeserializer. Th

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

[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

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

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

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寫道： >>>> >>>

[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: 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

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

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

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-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

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

[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-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: [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, >>> >>

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: >>

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: [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-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-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: [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: [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

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-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-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

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: [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

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

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

[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

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

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-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: [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

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

[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

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

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,

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: 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: [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: [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-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: [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: [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

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. >> >

[jira] [Resolved] (KAFKA-16506) add the scala version of tool-related classes back to core module to follow KIP-906

[ https://issues.apache.org/jira/browse/KAFKA-16506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-16506. --- Resolution: Not A Problem Compare commands between 2.8 and trunk brand in folders core/src/main

[jira] [Resolved] (KAFKA-16843) Remove preAppendErrors from createPutCacheCallback

[ https://issues.apache.org/jira/browse/KAFKA-16843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang resolved KAFKA-16843. --- Resolution: Fixed > Remove preAppendErrors from createPutCacheCallb

[jira] [Created] (KAFKA-17110) Enable valid test case in KafkaConsumerTest for AsyncKafkaConsumer

PoAn Yang created KAFKA-17110: - Summary: Enable valid test case in KafkaConsumerTest for AsyncKafkaConsumer Key: KAFKA-17110 URL: https://issues.apache.org/jira/browse/KAFKA-17110 Project: Kafka

[jira] [Created] (KAFKA-17129) Revisit FindCoordinatorResponse in KafkaConsumerTest

PoAn Yang created KAFKA-17129: - Summary: Revisit FindCoordinatorResponse in KafkaConsumerTest Key: KAFKA-17129 URL: https://issues.apache.org/jira/browse/KAFKA-17129 Project: Kafka Issue Type

[jira] [Created] (KAFKA-17159) Make sure kafka-cluster-test-kit-executor get down when closing KafkaClusterTestKit

PoAn Yang created KAFKA-17159: - Summary: Make sure kafka-cluster-test-kit-executor get down when closing KafkaClusterTestKit Key: KAFKA-17159 URL: https://issues.apache.org/jira/browse/KAFKA-17159

[jira] [Created] (KAFKA-17187) Add executor-AlterAcls to ClusterTestExtensions#SKIPPED_THREAD_PREFIX

PoAn Yang created KAFKA-17187: - Summary: Add executor-AlterAcls to ClusterTestExtensions#SKIPPED_THREAD_PREFIX Key: KAFKA-17187 URL: https://issues.apache.org/jira/browse/KAFKA-17187 Project: Kafka

[jira] [Created] (KAFKA-17189) Add Thread::isAlive to DetectThreadLeak#of filter

PoAn Yang created KAFKA-17189: - Summary: Add Thread::isAlive to DetectThreadLeak#of filter Key: KAFKA-17189 URL: https://issues.apache.org/jira/browse/KAFKA-17189 Project: Kafka Issue Type: Sub

[jira] [Created] (KAFKA-17255) Migrate ListOffsetsIntegrationTest to ClusterTestExtensions framework

PoAn Yang created KAFKA-17255: - Summary: Migrate ListOffsetsIntegrationTest to ClusterTestExtensions framework Key: KAFKA-17255 URL: https://issues.apache.org/jira/browse/KAFKA-17255 Project: Kafka

[jira] [Created] (KAFKA-17258) Migrate AdminFenceProducersIntegrationTest to ClusterTestExtensions framework

PoAn Yang created KAFKA-17258: - Summary: Migrate AdminFenceProducersIntegrationTest to ClusterTestExtensions framework Key: KAFKA-17258 URL: https://issues.apache.org/jira/browse/KAFKA-17258 Project

[jira] [Created] (KAFKA-17257) Migrate BrokerApiVersionsCommandTest to ClusterTestExtensions

PoAn Yang created KAFKA-17257: - Summary: Migrate BrokerApiVersionsCommandTest to ClusterTestExtensions Key: KAFKA-17257 URL: https://issues.apache.org/jira/browse/KAFKA-17257 Project: Kafka

[jira] [Created] (KAFKA-17259) Support to override serverProperties and restart cluster in ClusterTestExtensions

PoAn Yang created KAFKA-17259: - Summary: Support to override serverProperties and restart cluster in ClusterTestExtensions Key: KAFKA-17259 URL: https://issues.apache.org/jira/browse/KAFKA-17259 Project

[jira] [Created] (KAFKA-17312) Fix tests shouldForwardAllDbOptionsCalls and shouldOverwriteAllOptionsMethods in RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest

PoAn Yang created KAFKA-17312: - Summary: Fix tests shouldForwardAllDbOptionsCalls and shouldOverwriteAllOptionsMethods in RocksDBGenericOptionsToDbOptionsColumnFamilyOptionsAdapterTest Key: KAFKA-17312 URL: https

[jira] [Created] (KAFKA-17377) Consider using defaultApiTimeoutMs in AsyncKafkaConsumer#unsubscribe

PoAn Yang created KAFKA-17377: - Summary: Consider using defaultApiTimeoutMs in AsyncKafkaConsumer#unsubscribe Key: KAFKA-17377 URL: https://issues.apache.org/jira/browse/KAFKA-17377 Project: Kafka

[jira] [Created] (KAFKA-16387) Allow kafka-metadata-shell to read a running server metadata

PoAn Yang created KAFKA-16387: - Summary: Allow kafka-metadata-shell to read a running server metadata Key: KAFKA-16387 URL: https://issues.apache.org/jira/browse/KAFKA-16387 Project: Kafka

[jira] [Created] (KAFKA-16391) Cleanup .lock file after server is down

PoAn Yang created KAFKA-16391: - Summary: Cleanup .lock file after server is down Key: KAFKA-16391 URL: https://issues.apache.org/jira/browse/KAFKA-16391 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-16413) Add tests for FileLock

PoAn Yang created KAFKA-16413: - Summary: Add tests for FileLock Key: KAFKA-16413 URL: https://issues.apache.org/jira/browse/KAFKA-16413 Project: Kafka Issue Type: Test Reporter: PoAn

[jira] [Created] (KAFKA-16467) Add README to docs folder

PoAn Yang created KAFKA-16467: - Summary: Add README to docs folder Key: KAFKA-16467 URL: https://issues.apache.org/jira/browse/KAFKA-16467 Project: Kafka Issue Type: Test Reporter

[jira] [Created] (KAFKA-16472) Integration tests in Java don't really run kraft case

PoAn Yang created KAFKA-16472: - Summary: Integration tests in Java don't really run kraft case Key: KAFKA-16472 URL: https://issues.apache.org/jira/browse/KAFKA-16472 Project: Kafka Issue

[jira] [Created] (KAFKA-16476) Check whether TestInfo contains correct parameter name

PoAn Yang created KAFKA-16476: - Summary: Check whether TestInfo contains correct parameter name Key: KAFKA-16476 URL: https://issues.apache.org/jira/browse/KAFKA-16476 Project: Kafka Issue Type

  1   2   >