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

+1 (non-binding), thanks for the KIP! 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 of KafkaPrincipalSerde > alongside KafkaPrincipalBuilder, which i

[jira] [Created] (KAFKA-19339) Move DelayedFetch to server module

Kuan Po Tseng created KAFKA-19339: - Summary: Move DelayedFetch to server module Key: KAFKA-19339 URL: https://issues.apache.org/jira/browse/KAFKA-19339 Project: Kafka Issue Type: Sub-task

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

; > >> On Thu, May 22, 2025 at 12:54 AM Kamal Chandraprakash < > >> kamal.chandraprak...@gmail.com> wrote: > >> > >>> +1 (binding). Thanks for the KIP! > >>> > >>> On Wed, May 21, 2025 at 9:04 PM Chia-Ping Tsai > wrote: &

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

Hello everyone, I would like to start a vote on KIP-1179. KIP Link: https://cwiki.apache.org/confluence/x/xAlWFQ Best regards, Kuan-Po

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

hread.pool.size` > 10 or default 2? > > Thank you. > Luke > > > On Tue, May 20, 2025 at 9:28 AM Kuan-Po Tseng wrote: > > > Hello everyone, > > > > Just giving this thread a little nudge. If there’s no more feedback, I’ll > > kick off the vote tomorrow. &

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

e to discuss a KIP regarding introducing a new configuration, > > remote.log.manager.follower.thread.pool.size > > > > Thank you! > > > > KIP link: https://cwiki.apache.org/confluence/x/xAlWFQ > > > > Best, > > Kuan-Po Tseng > > >

Re: [VOTE] 3.9.1 RC2

he Kafka quickstart & Kafka Streams quickstart against - Docker apache/kafka:3.9.1-rc2 image - Docker apache/kafka-native:3.9.1-rc2 image +1 (non-binding) Thank you for the release! Best, Kuan-Po Tseng On 2025/05/14 12:46:38 Luke Chen wrote: > Hi all, > > Thanks for the vote so far

[jira] [Resolved] (KAFKA-19275) client-state and thread-state metrics are always ""Unavailable"

[ https://issues.apache.org/jira/browse/KAFKA-19275?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kuan Po Tseng resolved KAFKA-19275. --- Resolution: Fixed > client-state and thread-state metrics are always "&quo

[jira] [Created] (KAFKA-19264) Remove fallback for thread pool sizes in RemoteLogManagerConfig

Kuan Po Tseng created KAFKA-19264: - Summary: Remove fallback for thread pool sizes in RemoteLogManagerConfig Key: KAFKA-19264 URL: https://issues.apache.org/jira/browse/KAFKA-19264 Project: Kafka

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

+1(non-binding), thanks for the KIP! Best, Kuan-Po Tseng On 2025/05/05 07:02:04 TengYao Chi wrote: > Hello everyone, > > I would like to call a vote for KIP-1130 > <https://cwiki.apache.org/confluence/x/sYpEF>, which proposed adding > metrics indicating connection count ex

Re: [DISCUSS] KIP-1162: Redesign ClientQuotaCallback#updateClusterMetadata

ional node ID condition. Best, Kuan-Po Tseng On 2025/04/30 18:21:23 Chia-Ping Tsai wrote: > hi Kuan-Po > > > In TopicImage, there is a similar method, Map PartitionRegistration> partitions(), but we can't directly reuse its return > value here. As you mentioned, we'

Re: [DISCUSS] KIP-1162: Redesign ClientQuotaCallback#updateClusterMetadata

ild the collection. That said, since this KIP proposes to make PartitionRegistration implements PartitionInfo, the cost of generating the collection should be low. Thank you! Best, Kuan-Po Tseng On 2025/04/29 11:20:30 Chia-Ping Tsai wrote: > hi Kuan-Po > > Thanks for updating KIP. This

Re: [DISCUSS] KIP-1162: Redesign ClientQuotaCallback#updateClusterMetadata

compatible too: once users switch over to the new interface, they won’t need to recompile after we remove the old interface. By the way, I’ve also updated the KIP based on this idea. Would be great if you could take a look when you have some time. Thanks a lot! Best, Kuan-Po Tseng On 2025/04

Re: [DISCUSS] KIP-1162: Redesign ClientQuotaCallback#updateClusterMetadata

the "rejected alternatives" section as you suggested. Thanks again! Best, Kuan-Po Tseng On 2025/04/29 08:18:34 Chia-Ping Tsai wrote: > hi Kuan-Po > > Could you please add the approaches we discussed before to "rejected" > section? It could help readers to understa

Re: [VOTE] KIP-1141: Simplifying MetadataQuorumCommand by Leveraging Admin API for Controller Management

;Step 1" and "Step 2". Otherwise, as you mentioned, we won’t be able to retrieve the controller UUID and its corresponding endpoints for Step 3. I’m not sure if I’ve misunderstood anything, so please let me know if there’s anything I’ve missed. Thanks so much for reviewing my KIP! Best

Re: [VOTE] 3.9.1 RC1

Hi TengYao, I did some testing on the upgrade path: - Set up a ZK-based Kafka cluster on 3.5, created some topics, and produced a bunch of messages - Upgraded to 3.9.1-RC1 - Migrated to KRaft And everything worked smoothly! Thanks a lot for all your hard work! Best, Kuan-Po Tseng On 2025/04

[DISCUSS] KIP-1162: Redesign ClientQuotaCallback#updateClusterMetadata

: https://cwiki.apache.org/confluence/x/zInoF Best, Kuan-Po Tseng

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

Hello everyone, I would like to start a vote on KIP-1141, thank you! KIP: https://cwiki.apache.org/confluence/x/PZFEF Discussion thread: https://lists.apache.org/thread/mq5n8j8w0ycg9fhd1m4zcc2ctrgfd0d4 Best, Kuan-Po Tseng

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

/main/scala/kafka/server/ConfigHelper.scala#L121-L123) Please feel free to reach out if you have any further questions or need clarification. Thank you again for your valuable feedback! Best, Kuan-Po Tseng On 2025/04/03 16:04:36 José Armando García Sancio wrote: > Hi Chia, > > On T

Re: [ANNOUNCE] New committer: Apoorv Mittal

Congrats Apoorv! On Sat, Apr 12, 2025 at 9:50 AM Guozhang Wang wrote: > Congratulations Apoorv! > > On Fri, Apr 11, 2025 at 3:33 PM Apoorv Mittal > wrote: > > > > Thank you so much everyone! I really appreciate it. I'm excited to be > > joining the Kafka committer community. > > > > Regards, >

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

+1 (non-binding), thanks for the KIP. On 2025/04/10 07:51:53 TengYao Chi wrote: > Hello everyone, > > I would like to call a vote on KIP-1148 > . > > Here is > the discussion thread. >

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

Hi Harish, Thank you for improving the documentation! +1 (non-binding) Best, Kuan-Po Tseng On 2025/03/27 09:30:12 Andrew Schofield wrote: > Hi Harish, > Thanks for this great KIP. I’m really looking forward to being able to write > Kafka docs in Markdown instead of HTML. > &

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

Hi all, If there are no further opinions, I would like to start the vote tomorrow. Thank you! Best, Kuan-Po Tseng On 2025/03/31 00:54:12 Kuan Po Tseng wrote: > Hi Chia-Ping, > > Thank you for your feedback! I agree with you that deprecating those options > in 4.x would be a

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

Hi Chia-Ping, Thank you for your feedback! I agree with you that deprecating those options in 4.x would be a bit too soon. I’ve added these points to the Alternatives section. Thanks again! Best, Kuan-Po Tseng On 2025/03/30 19:22:12 Chia-Ping Tsai wrote: > hi Kuan-Po > > &g

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

y discussion threads starts with [DISCUSS] prefix > - have you considered deprecating the old way of adding/removing controllers? > > > On Mon, Mar 10, 2025 at 2:27 AM Kuan Po Tseng wrote: > > > > Hi everyone, > > > > I'd like to start a discussion thread o

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

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:

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

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: [VOTE] KIP-1124: Providing a clear Kafka Client upgrade path

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 "

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

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: [DISCISS] KIP-860: Add client-provided option to guard against unintentional replication factor change during partition reassignments

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 於

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

[ 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

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

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: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

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

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: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

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: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

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

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

; 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: [VOTE] KIP-1124: Providing a clear Kafka Client upgrade path

> 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

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

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

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

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

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: [DISCUSS] KIP-1124: Providing a clear Kafka Client upgrade path

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

. 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: [DISCISS] KIP-860: Add client-provided option to guard against unintentional replication factor change during partition reassignments

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

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

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

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

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

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

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

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

[ 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] [Created] (KAFKA-18296) Remove deprecated KafkaBasedLog constructor

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

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

Re: [ANNOUNCE] New committer: Andrew Schofield

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.

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

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-18075) Prevent ClusterInstance default producer and consumer initialization with empty configs

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-17728) Add missing config `replica-directory-id` to raft README

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

Re: [ANNOUNCE] New committer: Lianet Magrans

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: [VOTE] KIP-1077: Deprecate `ForeachProcessor` and move to internal package

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

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

a vote. Thanks, Kuan-Po Tseng

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

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

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

[ 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-17358) ClusterTestExtensions KRAFT mode should support all security protocol

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] [Created] (KAFKA-17286) Flaky PlaintextConsumerSubscriptionTest#testSubscribeInvalidTopic

Kuan Po Tseng created KAFKA-17286: - Summary: Flaky PlaintextConsumerSubscriptionTest#testSubscribeInvalidTopic Key: KAFKA-17286 URL: https://issues.apache.org/jira/browse/KAFKA-17286 Project: Kafka

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

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: [DISCUSS] KIP-1078: Remove Leaking Getter Methods in Joined Helper Class

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

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

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

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

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-17235) system test test_performance_service.py failed

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] [Resolved] (KAFKA-16942) Use ConcurrentHashMap in RecordAccumulator#nodeStats

[ 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-16942) Use ConcurrentHashMap in RecordAccumulator#nodeStats

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

Request permissions to Create KIP

regards, Kuan Po Tseng

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

+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

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

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-16794) Can't open videos in streams documentation

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] [Resolved] (KAFKA-16595) Introduce ClusterTemplate in ClusterTests

[ 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-16627) Remove ClusterConfig parameter in BeforeEach and AfterEach

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-16595) Introduce template in ClusterTests

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-16477) Detect thread leaked client-metrics-reaper in tests

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-16455) Check partition exists before send reassignments to server in ReassignPartitionsCommand

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-16414) Inconsistent active segment expiration behavior between retention.ms and retention.bytes

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