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

2024-05-24 Thread Kuan Po Tseng
+1 (non-binding) On 2024/05/23 16:26:42 Frank Yang wrote: > 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.apach

Request permissions to Create KIP

2024-06-05 Thread Kuan Po Tseng
regards, Kuan Po Tseng

KIP-1077: Deprecate `ForeachProcessor` and move to internal package

2024-08-03 Thread Kuan Po Tseng
Hello everyone, In KIP-1077 (https://cwiki.apache.org/confluence/x/eA-OEg), we plan to deprecate ForeachProcessor and move it to an internal package, as it is intended for internal use only. If you have any questions or suggestions, please feel free to reply. Thank you! Best regards, Kuan-Po

Re: [DISCUSS] KIP-1078: Remove Leaking Getter Methods in Joined Helper Class

2024-08-04 Thread Kuan Po Tseng
Thank you for the nice KIP ! About deprecating Joined#gracePeriod, did you mean we should move the Joined#gracePeriod to JoinedInternal class as I didn't see the corresponding method in JoinedInternal you mentioned. Best regards, Kuan-Po Tseng On 2024/08/04 16:13:31 TengYao Chi

Re: [DISCUSS] KIP-1078: Remove Leaking Getter Methods in Joined Helper Class

2024-08-04 Thread Kuan Po Tseng
Thank you ! LGTM ! Best regards, Kuan-Po Tseng On 2024/08/04 16:40:12 TengYao Chi wrote: > Hello Kuan Po > > I just reviewed the code, and you are right. > > Currently, Joined#gracePeriod is not in the JoinedInternal. I will slightly > modify the content of th

Re: KIP-1077: Deprecate `ForeachProcessor` and move to internal package

2024-08-18 Thread Kuan Po Tseng
> > > I think this proposal is fair enough. > > > > > > Chia-Ping Tsai 於 2024年8月4日 週日 下午3:45寫道: > > > > > >> Thanks Kuan-Po for writing KIP-1077. LGTM > > >> > > >> Kuan Po Tseng 於 2024年8月4日 週日 下午2:34寫道: > > >> &

[VOTE] KIP-1077: Deprecate `ForeachProcessor` and move to internal package

2024-08-18 Thread Kuan Po Tseng
a vote. Thanks, Kuan-Po Tseng

Re: [VOTE] KIP-1077: Deprecate `ForeachProcessor` and move to internal package

2024-08-26 Thread Kuan Po Tseng
Hi everyone, I'm closing this vote with the KIP being accepted with 4 binding +1s from Chia-Ping, Lucas, Bruno, and Matthias, along with 2 non-binding +1s from TengYao and 黃竣陽. Thank you all for your participation! On 2024/08/22 04:09:06 "Matthias J. Sax" wrote: > +1 (binding) > > On 8/19/24

Re: [ANNOUNCE] New committer: Lianet Magrans

2024-08-28 Thread Kuan Po Tseng
Congrats Lianet !!! On 2024/08/29 02:37:19 Luke Chen wrote: > Congratulations Lianet! > > Luke > > On Thu, Aug 29, 2024 at 9:54 AM Lianet M. wrote: > > > Thank you very much everyone! It truly takes the great shared knowledge you > > all put out there with amazing reviews and discussions. > >

Re: [ANNOUNCE] New committer: Andrew Schofield

2024-12-02 Thread Kuan Po Tseng
Congrats! Andrew ! On 2024/12/02 14:13:52 David Arthur wrote: > The Project Management Committee (PMC) for Apache Kafka is pleased to > announce Andrew Schofield as a new Kafka committer. > > Andrew has been active in the project since May of 2023 and has contributed > a great deal in that time.

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-02-07 Thread Kuan Po Tseng
Hi all, Based on our discussion, I added a section on choosing the appropriate bridge version from an API compatibility perspective for upgrading to Kafka 4.0. Let me know if you have any thoughts. Thank you! Best, Kuan-Po On 2025/02/07 03:34:46 Kuan Po Tseng wrote: > Hi Chia-Ping, > &

Re: [DISCISS] KIP-860: Add client-provided option to guard against unintentional replication factor change during partition reassignments

2025-02-05 Thread Kuan Po Tseng
Hi all, After discussing with Stanislav Kozlovski, I plan to continue implementing this KIP. However, I have a question regarding the Validation section. It says, "If the targetReplicaSet of the reassignment differs from the current replica set of the partition, an error is thrown." I’m wonder

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-02-06 Thread Kuan Po Tseng
Hi Chia-Ping, Sorry for the delayed response. I’ve checked all relevant JIRAs using the following Jira Query Language: project = KAFKA AND status in (Resolved, Closed) AND fixVersion = 4.0.0 AND text ~ "Remove" order by updated DESC Based on this, I checked the JIRAs related to removing deprec

Re: [DISCISS] KIP-860: Add client-provided option to guard against unintentional replication factor change during partition reassignments

2025-02-06 Thread Kuan Po Tseng
. If the partition IS > > reasigning, then we check `currentReassignmentTargetReplicaSet.size != > > newTargetReplicaSet.size` > > > > Best, > > Stan > > > > On 2025/02/05 14:46:08 Kuan Po Tseng wrote: > > > Hi all, > > > > > >

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-02-11 Thread Kuan Po Tseng
Hello everyone, If there are no other opinions, I would like to start a vote tomorrow, thank you! Best, Kuan Po On Sat, Feb 8, 2025 at 1:51 AM Kuan Po Tseng wrote: > Hi all, > > Based on our discussion, I added a section on choosing the appropriate > bridge version from an API c

[VOTE] KIP-1124: Providing a clear Kafka Client upgrade path

2025-02-12 Thread Kuan Po Tseng
Hello, I'd like to initiate a vote on KIP-1124, which aims to provide a clear upgrade path for Kafka clients. This proposal will not only help users transition smoothly but also reduce the development effort required to support upgrades. Discuss Thread: https://lists.apache.org/thread/v7by71w1cmn4

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-01-20 Thread Kuan Po Tseng
e simply removing the UPGRADE_FROM config. > > >> > > >> I mention this here because this means if a user needs to upgrade a > > >> Streams > > >> app from, say, version 1.0 to version 4.0 with 2.3 as a bridge release, > > >> they would

[DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-01-15 Thread Kuan Po Tseng
te it if you could take a look and share your thoughts or feedback. Best regards, Kuan-Po Tseng

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-01-17 Thread Kuan Po Tseng
state how many major versions of backward compatibility we support in the Backwards Compatibility section. On 2025/01/15 13:44:09 Kuan Po Tseng wrote: > Hi all, > > I'd like to initiate a discussion thread on *KIP-1124,* which proposes a > clear upgrade path for Kafka Client, in

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-02-19 Thread Kuan Po Tseng
; https://kafka.apache.org/39/documentation/streams/upgrade-guide > > Thanks Kuan Po! > > Lianet > > On Tue, Feb 11, 2025 at 11:22 AM Kuan Po Tseng wrote: > > > Hello everyone, > > > > If there are no other opinions, I would like to start a vote tomorro

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-02-23 Thread Kuan Po Tseng
emphasize: - Simplifying testing - Reducing compatibility challenges across too many versions - Clearly defining the recommended upgrade paths Best, Kuan-Po Tseng On 2025/02/21 23:55:51 Sophie Blee-Goldman wrote: > whew, long response from Matthias :P Lot to digest but I want to add > on/

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-02-24 Thread Kuan Po Tseng
nation > > 1. minimize code refactoring - // Kafka Client: 3.3.x - 3.9.x + Kafka > Streams: 3.6.x - 3.9.x > 2. starts with quorum APIs - // 3.3.x - 3.9.x > 3. xxx > 4. aaa > n. last stable/active version: 3.9.x // we can emphasize the 3.9 is > recommended by community >

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-02-26 Thread Kuan Po Tseng
ert, and I would like to hear others' opinions as well. I just updated the KIP, and I hope I have addressed all your comments above. Please let me know if I missed anything. Best, Kuan-Po Tseng On 2025/02/25 03:32:06 "Matthias J. Sax" wrote: > Thanks all. Seems we are converging.

Re: [VOTE] KIP-1124: Providing a clear Kafka Client upgrade path

2025-02-17 Thread Kuan Po Tseng
> Best, > Chia-Ping > > On 2025/02/12 14:49:37 Kuan Po Tseng wrote: > > Hello, > > I'd like to initiate a vote on KIP-1124, which aims to provide a clear > > upgrade path for Kafka clients. This proposal will not only help users > > transition smoothly b

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-03-03 Thread Kuan Po Tseng
bridge version from an API compatibility perspective should be [3.8.x–3.9.x]. Best, Kuan-Po Tseng On 2025/03/04 00:44:47 Chia-Ping Tsai wrote: > Dear all, > > Thank you for the discussion. Apologies for introducing an unrelated topic. > Here's a summary of that discussion. >

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-03-04 Thread Kuan Po Tseng
Hi Chia-ping, Thank you for your feedback. I've updated the KIP and also added an explanation for why the client bridge version starts at 3.4 - "In 4.0.0, the most recent removed deprecated APIs were from 3.3.0, so the bridge version starts from 3.4." Best, Kuan-Po Tseng On 2

Re: [VOTE] KIP-1124: Providing a clear Kafka Client upgrade path

2025-03-05 Thread Kuan Po Tseng
Thanks everyone for voting and feedback. The vote has passed with 4 binding votes (Matthias, Chia-Ping, David and Bruno). Best, Kuan-Po Tseng On 2025/03/05 09:30:55 Bruno Cadonna wrote: > Hi, > > +1 (binding) > > Thanks for the KIP, > Bruno > > On 05.03.25 09:49, D

Re: [VOTE] KIP-1124: Providing a clear Kafka Client upgrade path

2025-03-09 Thread Kuan Po Tseng
Hi everyone, The vote has now been open for over 72 hours and has passed with 4 binding votes (Matthias, Chia-Ping, David and Bruno). Best, Kuan-Po Tseng On 2025/03/06 05:44:33 Kuan Po Tseng wrote: > Hi Ismael, > > Sorry about that... I'll revert the KIP state back to "

KIP-1141: Simplifying MetadataQuorumCommand by Leveraging Admin API for Controller Management

2025-03-09 Thread Kuan Po Tseng
nce/x/PZFEF. I believe this proposal could provide a better user experience, and I’d really appreciate it if you could take a look and share your thoughts or feedback. Best regards, Kuan-Po Tseng

Re: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

2025-02-28 Thread Kuan Po Tseng
Hi Matthias, Feel free to edit the KIP directly – I'm totally fine with it. Thanks a lot! Best, Kuan-Po Tseng On 2025/02/28 07:35:10 "Matthias J. Sax" wrote: > Thanks all. I am happy that we are making progress to close this out. > > As mentioned in my (long) email l

Re: [DISCISS] KIP-860: Add client-provided option to guard against unintentional replication factor change during partition reassignments

2025-03-05 Thread Kuan Po Tseng
support! Best, Kuan-Po Tseng On 2025/02/06 18:42:29 Chia-Ping Tsai wrote: > hi Stan > > thanks for sharing the details! > > to Kuan-Po > > Could you please tweak the KIP-860 according to Stan's response :) > > Best, > Chia-Ping > > Stanislav Kozlovski 於

Re: [VOTE] KIP-1124: Providing a clear Kafka Client upgrade path

2025-03-15 Thread Kuan Po Tseng
Hi Ismael, Sorry about that... I'll revert the KIP state back to "Voting" and, as you suggested, wait for 72 hours before proceeding. Best, Kuan-Po Tseng On 2025/03/06 05:22:57 Ismael Juma wrote: > I meant converged (instead of converted). > > On Wed, Mar 5, 2025, 9:

[jira] [Resolved] (KAFKA-16595) Introduce ClusterTemplate in ClusterTests

2024-05-08 Thread Kuan Po Tseng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16595?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng resolved KAFKA-16595. --- Resolution: Won't Do As discussed in [https://github.com/apache/kafka/pull/

[jira] [Created] (KAFKA-16794) Can't open videos in streams documentation

2024-05-19 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-16794: - Summary: Can't open videos in streams documentation Key: KAFKA-16794 URL: https://issues.apache.org/jira/browse/KAFKA-16794 Project: Kafka Issue Type

[jira] [Created] (KAFKA-16795) Fix broken compatibility in kafka.tools.NoOpMessageFormatter, kafka.tools.DefaultMessageFormatter, and kafka.tools.LoggingMessageFormatter

2024-05-19 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-16795: - Summary: Fix broken compatibility in kafka.tools.NoOpMessageFormatter, kafka.tools.DefaultMessageFormatter, and kafka.tools.LoggingMessageFormatter Key: KAFKA-16795 URL: https

[jira] [Created] (KAFKA-16942) Use ConcurrentHashMap in RecordAccumulator#nodeStats

2024-06-12 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-16942: - Summary: Use ConcurrentHashMap in RecordAccumulator#nodeStats Key: KAFKA-16942 URL: https://issues.apache.org/jira/browse/KAFKA-16942 Project: Kafka Issue

[jira] [Resolved] (KAFKA-16942) Use ConcurrentHashMap in RecordAccumulator#nodeStats

2024-06-14 Thread Kuan Po Tseng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng resolved KAFKA-16942. --- Resolution: Won't Do The performance in get method is not obvious between ConcurrentHa

[jira] [Created] (KAFKA-17235) system test test_performance_service.py failed

2024-07-31 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-17235: - Summary: system test test_performance_service.py failed Key: KAFKA-17235 URL: https://issues.apache.org/jira/browse/KAFKA-17235 Project: Kafka Issue Type

[jira] [Created] (KAFKA-17256) KRAFT should honor the listener name and security protocol from ClusterConfig

2024-08-03 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-17256: - Summary: KRAFT should honor the listener name and security protocol from ClusterConfig Key: KAFKA-17256 URL: https://issues.apache.org/jira/browse/KAFKA-17256

[jira] [Created] (KAFKA-17286) Flaky PlaintextConsumerSubscriptionTest#testSubscribeInvalidTopic

2024-08-07 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-17286: - Summary: Flaky PlaintextConsumerSubscriptionTest#testSubscribeInvalidTopic Key: KAFKA-17286 URL: https://issues.apache.org/jira/browse/KAFKA-17286 Project: Kafka

[jira] [Created] (KAFKA-17358) ClusterTestExtensions KRAFT mode should support all security protocol

2024-08-18 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-17358: - Summary: ClusterTestExtensions KRAFT mode should support all security protocol Key: KAFKA-17358 URL: https://issues.apache.org/jira/browse/KAFKA-17358 Project

[jira] [Resolved] (KAFKA-17358) ClusterTestExtensions KRAFT mode should support all security protocol

2024-08-18 Thread Kuan Po Tseng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17358?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng resolved KAFKA-17358. --- Resolution: Duplicate we already have other issue talking about this https

[jira] [Created] (KAFKA-16414) Inconsistent active segment expiration behavior between retention.ms and retention.bytes

2024-03-24 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-16414: - Summary: Inconsistent active segment expiration behavior between retention.ms and retention.bytes Key: KAFKA-16414 URL: https://issues.apache.org/jira/browse/KAFKA-16414

[jira] [Created] (KAFKA-16455) Check partition exists before send reassignments to server in ReassignPartitionsCommand

2024-04-01 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-16455: - Summary: Check partition exists before send reassignments to server in ReassignPartitionsCommand Key: KAFKA-16455 URL: https://issues.apache.org/jira/browse/KAFKA-16455

[jira] [Created] (KAFKA-16477) Detect thread leaked client-metrics-reaper in tests

2024-04-05 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-16477: - Summary: Detect thread leaked client-metrics-reaper in tests Key: KAFKA-16477 URL: https://issues.apache.org/jira/browse/KAFKA-16477 Project: Kafka Issue

[jira] [Created] (KAFKA-16595) Introduce template in ClusterTests

2024-04-21 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-16595: - Summary: Introduce template in ClusterTests Key: KAFKA-16595 URL: https://issues.apache.org/jira/browse/KAFKA-16595 Project: Kafka Issue Type: Improvement

[jira] [Created] (KAFKA-16627) Remove ClusterConfig parameter in BeforeEach and AfterEach

2024-04-25 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-16627: - Summary: Remove ClusterConfig parameter in BeforeEach and AfterEach Key: KAFKA-16627 URL: https://issues.apache.org/jira/browse/KAFKA-16627 Project: Kafka

[jira] [Created] (KAFKA-17728) Add missing config `replica-directory-id` to raft README

2024-10-08 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-17728: - Summary: Add missing config `replica-directory-id` to raft README Key: KAFKA-17728 URL: https://issues.apache.org/jira/browse/KAFKA-17728 Project: Kafka

[jira] [Created] (KAFKA-18083) ClusterInstance custom controllerListener not work

2024-11-24 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-18083: - Summary: ClusterInstance custom controllerListener not work Key: KAFKA-18083 URL: https://issues.apache.org/jira/browse/KAFKA-18083 Project: Kafka Issue

[jira] [Created] (KAFKA-18296) Remove deprecated KafkaBasedLog constructor

2024-12-17 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-18296: - Summary: Remove deprecated KafkaBasedLog constructor Key: KAFKA-18296 URL: https://issues.apache.org/jira/browse/KAFKA-18296 Project: Kafka Issue Type

[jira] [Created] (KAFKA-18234) DumpLogSegments cannot print ConsumerGroupRegularExpression record

2024-12-13 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-18234: - Summary: DumpLogSegments cannot print ConsumerGroupRegularExpression record Key: KAFKA-18234 URL: https://issues.apache.org/jira/browse/KAFKA-18234 Project: Kafka

[jira] [Created] (KAFKA-18075) Prevent ClusterInstance default producer and consumer initialization with empty configs

2024-11-23 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-18075: - Summary: Prevent ClusterInstance default producer and consumer initialization with empty configs Key: KAFKA-18075 URL: https://issues.apache.org/jira/browse/KAFKA-18075

[jira] [Created] (KAFKA-18401) Transaction version 2 does not support commit transaction without records

2025-01-04 Thread Kuan Po Tseng (Jira)
Kuan Po Tseng created KAFKA-18401: - Summary: Transaction version 2 does not support commit transaction without records Key: KAFKA-18401 URL: https://issues.apache.org/jira/browse/KAFKA-18401 Project

[jira] [Resolved] (KAFKA-18343) Use java_pids to implement pids

2024-12-24 Thread Kuan Po Tseng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18343?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng resolved KAFKA-18343. --- Fix Version/s: 4.0.0 Reviewer: Justine Olshan Resolution: Fixed >

[jira] [Resolved] (KAFKA-14121) AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor

2025-03-05 Thread Kuan Po Tseng (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng resolved KAFKA-14121. --- Resolution: Fixed > AlterPartitionReassignments API should allow callers to specify