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

2024-11-14 Thread Frank Yang
we could get this one in AK 4.0 as it changes the > output of the command. > > Thanks, > DJ > > On Fri, Nov 1, 2024 at 7:40 AM Frank Yang wrote: > >> Hi Sean / Andrew / Lianet, >> >> Thanks for all your review and suggestions. >> >> AS1, LM1,

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

2024-11-05 Thread Frank Yang
the changed topics from caches on a > metadata change, as the first heartbeat request would update the caches for > all changed topics. > > Q3: Could you please include a section about the choice of hash > implementation? The hash implementation must be consistent across different > JDK

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

2024-11-01 Thread Frank Yang
Hi all, I would like to start a discussion thread on KIP-1101. Trigger rebalance on rack topology changes. In this KIP, we aim to use less memory / disk resources to detect rack changes in the new coordinator. https://cwiki.apache.org/confluence/display/KAFKA/KIP-1101%3A+Trigger+rebalance+on+ra

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

2024-10-31 Thread Frank Yang
Lucas Brutschy wrote: >>> Hi Frank, >>> >>> thanks for the KIP! >>> >>> 1) For consistency, should we do the same for >>> kafka-share-groups.sh, ShareGroupDescription, etc. ? Even if we do not >>> implement it right now if the s

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

2024-10-23 Thread Frank Yang
Hi all, I would like to kick off the discussion of KIP-1099. This KIP enhances the kafka-consumer-groups tools to include state which is introduced by KIP-848. https://cwiki.apache.org/confluence/display/KAFKA/KIP-1099%3A+Extend+kafka-consumer-groups+command+line+tool+to+support+new+consumer+gro

[DISCUSS] KIP-1093: Add more observability for MirrorMaker2

2024-09-23 Thread Frank Yang
Hi everyone, I’d like to kick off the discussion of new metrics in MirrorMaker2. https://cwiki.apache.org/confluence/display/KAFKA/KIP-1093%3A+Add+more+observability+for+MirrorMaker2 Feel free to give me any suggestion and feedback. Thanks for your review. Thanks, PoAn

Re: Request permissions to Create KIP

2024-06-05 Thread Frank Yang
Hi Josep, I just got Confluence account, too. Could you grant me the permission to create KIP as well? Thank you. JIRA: yangpoan Confluence: yangpoan Best Regards, PoAn Yang > On Jun 5, 2024, at 7:35 PM, Josep Prat wrote: > > Hi! > Thanks for your interest in Apache Kafka. Your accounts are

Re: [VOTE] KIP 1047 - Introduce new org.apache.kafka.tools.api.Decoder to replace kafka.serializer.Decoder

2024-05-26 Thread Frank Yang
thanks for the KIP. >> +1 (binding) >> >> Best, >> >> On Fri, May 24, 2024 at 11:11 AM Kuan Po Tseng >> wrote: >> >>> +1 (non-binding) >>> >>> On 2024/05/23 16:26:42 Frank Yang wrote: >>>> Hi all, >>>&

[VOTE] KIP 1047 - Introduce new org.apache.kafka.tools.api.Decoder to replace kafka.serializer.Decoder

2024-05-23 Thread Frank Yang
Hi all, I would like to start a vote on KIP-1047: Introduce new org.apache.kafka.tools.api.Decoder to replace kafka.serializer.Decoder. KIP: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1047+Introduce+new+org.apache.kafka.tools.api.Decoder+to+replace+kafka.serializer.Decoder Discussion

[DISCUSS] KIP 1047 - Introduce new org.apache.kafka.tools.api.Decoder to replace kafka.serializer.Decoder

2024-05-22 Thread Frank Yang
Hi team, Chia-Ping Tsai and I would like to propose KIP-1047 to migrate kafka.serializer.Decoder from core module (scala) to tools module (java). Feedback and comments are welcome. KIP-1047: https://cwiki.apache.org/confluence/display/KAFKA/KIP-1047+Introduce+new+org.apache.kafka.tools.api.Dec