[jira] [Created] (KAFKA-19317) Fix flaky test : ShareConsumerTest.testAlterReadUncommittedToReadCommittedIsolationLevel()

Shivsundar R created KAFKA-19317: Summary: Fix flaky test : ShareConsumerTest.testAlterReadUncommittedToReadCommittedIsolationLevel() Key: KAFKA-19317 URL: https://issues.apache.org/jira/browse/KAFKA-19317

Re: Missing Response Formats in Kafka Protocol Guide

PR opened: https://github.com/apache/kafka/pull/19769 Thanks! - Andy On Tue, 20 May 2025 at 11:35, Ziming Deng wrote: > Can you submit a PR to fix it? Thank you! > > > On May 20, 2025, at 11:26, Andy Li wrote: > > > > Hey Ziming, > > > > Thanks for pointing to org.apache.kafka.common.protocol

Re: Missing Response Formats in Kafka Protocol Guide

Can you submit a PR to fix it? Thank you! > On May 20, 2025, at 11:26, Andy Li wrote: > > Hey Ziming, > > Thanks for pointing to org.apache.kafka.common.protocol.Protocal.main! > > It seem that this line should use `<=` instead `<`: > > Protocol.java >

Re: Missing Response Formats in Kafka Protocol Guide

Hey Ziming, Thanks for pointing to org.apache.kafka.common.protocol.Protocal.main! It seem that this line should use `<=` instead `<`: Protocol.java

[PR] MINOR: Add 3.9.1 blog post [kafka-site]

frankvicky opened a new pull request, #688: URL: https://github.com/apache/kafka-site/pull/688 This patch adds a new post for the 3.9.1 release. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to th

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

Hi Kuan-Po, Thanks for the KIP! Questions: 1. If `remote.log.manager.thread.pool.size` is set and `remote.log.manager.follower.thread.pool.size` is not set, we will still honor the setting in `remote.log.manager.thread.pool.size`, right? We should add in KIP to make it clear. 2. Suppose `remote.

Re: Missing Response Formats in Kafka Protocol Guide

Hello Andi, This page content is generated from org.apache.kafka.common.protocol.Protocal.main , can you help to check it? > On May 20, 2025, at 09:13, Andy Li wrote: > > Hi Kafka Team, > > I noticed a couple of response formats missing from the Kafka protocol guide >

Re: Missing Response Formats in Kafka Protocol Guide

hi Andy thanks for your report. We will check it later. Best, Chia-Ping Andy Li 於 2025年5月20日 週二 上午9:14寫道： > Hi Kafka Team, > > I noticed a couple of response formats missing from the Kafka protocol > guide > : > > - *ApiVersions Response

Re: [VOTE] KIP-1135: Deprecated "org.apache.kafka.disallowed.login.modules"

+1 (binding) from me. Thanks for the KIP. Luke On Mon, May 19, 2025 at 11:12 PM Chia-Ping Tsai wrote: > +1 (binding) > > 龚宣璋 於 2025年5月14日 週三 下午7:29寫道： > > > Hi Chia-Ping > > You are right. > > I don't think this should be optional. We should enforce the use of the > > allowlist > > > > Chia-Pi

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

Hello everyone, Just giving this thread a little nudge. If there’s no more feedback, I’ll kick off the vote tomorrow. Also, thanks to Kamal for reviewing this KIP! Best Regards, Kuan-Po On Mon, May 19, 2025 at 11:16 PM Kamal Chandraprakash < kamal.chandraprak...@gmail.com> wrote: > Hi Kuan-Po,

Missing Response Formats in Kafka Protocol Guide

Hi Kafka Team, I noticed a couple of response formats missing from the Kafka protocol guide : - *ApiVersions Response (Version: 4)* — Only versions 0–3 are documented, though version 4 of the request is included. - *DescribeTopicPartitions

Re: [VOTE] KIP-1150: Diskless Topics

Since there are so many unanswered questions here, I am going to leave a -1 (binding) here just as a procedural matter. Hopefully I will soon be able to remove this once we figure everything out. Take a look at my questions in the DISCUSS thread. thank you, Colin On Tue, May 13, 2025, at 09:5

[jira] [Created] (KAFKA-19316) Add share_consumer_group_command_test.py system test

Chirag Wadhwa created KAFKA-19316: - Summary: Add share_consumer_group_command_test.py system test Key: KAFKA-19316 URL: https://issues.apache.org/jira/browse/KAFKA-19316 Project: Kafka Issue

[jira] [Created] (KAFKA-19315) Move ControllerMutationQuotaManager to server module

Chia-Ping Tsai created KAFKA-19315: -- Summary: Move ControllerMutationQuotaManager to server module Key: KAFKA-19315 URL: https://issues.apache.org/jira/browse/KAFKA-19315 Project: Kafka Issu

[jira] [Created] (KAFKA-19314) Remove unnecessary code of closing snapshotWriter

Chia-Ping Tsai created KAFKA-19314: -- Summary: Remove unnecessary code of closing snapshotWriter Key: KAFKA-19314 URL: https://issues.apache.org/jira/browse/KAFKA-19314 Project: Kafka Issue T

Re: [PR] MINOR: Update 3.9.1 site [kafka-site]

showuon commented on code in PR #687: URL: https://github.com/apache/kafka-site/pull/687#discussion_r2095279625 ## 39/streams/developer-guide/config-streams.html: ## @@ -1387,7 +1387,7 @@ client.id - +

[PR] MINOR: Update 3.9.1 site [kafka-site]

frankvicky opened a new pull request, #687: URL: https://github.com/apache/kafka-site/pull/687 The vote for the 3.9.1 release has been accepted. Hence, we should update the respective site content. -- This is an automated message from the Apache Git Service. To respond to the message, ple

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

[ https://issues.apache.org/jira/browse/KAFKA-19302?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-19302. Fix Version/s: 4.1.0 Resolution: Fixed > Move ReplicaState and Replica to server mo

[jira] [Created] (KAFKA-19313) Replace LogOffsetMetadata#UNIFIED_LOG_UNKNOWN_OFFSET by UnifiedLog.UNKNOWN_OFFSET

Chia-Ping Tsai created KAFKA-19313: -- Summary: Replace LogOffsetMetadata#UNIFIED_LOG_UNKNOWN_OFFSET by UnifiedLog.UNKNOWN_OFFSET Key: KAFKA-19313 URL: https://issues.apache.org/jira/browse/KAFKA-19313

Re: KIP-1182 Quality of Service (QoS) for Apache Kafka

Answers inline: On Wed, May 14, 2025 at 2:42 AM Andrew Schofield < andrew_schofield_j...@outlook.com> wrote: > Hi Peter and David, > Thanks for the KIP. > > It contains some interesting ideas but it's very nebulous at this point. True. However, we believed that until we actually put a proposal

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

Hi Kuan-Po, The proposal to add the new remote.log.manager.follower.thread.pool.size config, LGTM. Thanks for making this change! -- Kamal On Mon, May 12, 2025 at 10:19 PM KuanPo Tseng wrote: > Hello everyone, > > I’d like to discuss a KIP regarding introducing a new configuration, > remote.lo

Re: [VOTE] KIP-1135: Deprecated "org.apache.kafka.disallowed.login.modules"

+1 (binding) 龚宣璋 於 2025年5月14日 週三 下午7:29寫道： > Hi Chia-Ping > You are right. > I don't think this should be optional. We should enforce the use of the > allowlist > > Chia-Ping Tsai 于2025年5月14日周三 13:07写道： > > > hi Xuan-Zhang > > > > (optional) we can deprecate `org.apache.kafka.disallowed.login.m

[jira] [Created] (KAFKA-19312) Share partition fetch locks concurrent thread release

Apoorv Mittal created KAFKA-19312: - Summary: Share partition fetch locks concurrent thread release Key: KAFKA-19312 URL: https://issues.apache.org/jira/browse/KAFKA-19312 Project: Kafka Issue

Re: [DISCUSS] KIP-1153: Kafka Streams `CloseOptions` should not have a public constructor

Hi all, I’d like to manually bump this thread. If there’s no further feedback, I’ll start the vote tomorrow. Best Regards, Jiunn-Yang > 黃竣陽 於 2025年5月8日 晚上8:35 寫道： > > Hi all, > > Thanks for all the feedback. I’ve updated the KIP and introduced a > CloseOptionsInternal class that provides a

[jira] [Created] (KAFKA-19311) Document the different behaviors of commitAsync between classic consumer and async consumer

Chia-Ping Tsai created KAFKA-19311: -- Summary: Document the different behaviors of commitAsync between classic consumer and async consumer Key: KAFKA-19311 URL: https://issues.apache.org/jira/browse/KAFKA-19311

Re: [DISCUSS] KIP-1173: Connect Storage Topics Sharing Across Clusters

Hi Greg / Chris, I hope I’ve addressed all the questions — please let me know if any further clarification is needed. Also, when you have a moment, could you please review the KIP and let me know if there's anything else that needs attention? Best regards, Pritam On Sat, May 3, 2025 at 10:43 PM

Re: [DISCUSS] KIP-1153: Extending support for Microsecond Precision for Kafka Connect

Hi Kafka Community, Here is the KIP LInk -> https://cwiki.apache.org/confluence/pages/viewpage.action?pageId=347933282 On Mon, May 19, 2025 at 6:47 PM pritam kumar wrote: > Hi Kafka Community, > > Could you please review this KIP proposal when you have a chance? > > Thank you, > Pritam > > > On

Re: [DISCUSS] KIP-1153: Extending support for Microsecond Precision for Kafka Connect

Hi Kafka Community, Could you please review this KIP proposal when you have a chance? Thank you, Pritam On Sat, May 3, 2025 at 10:53 PM pritam kumar wrote: > Hi Chris, > Can you please review this one too? > > On Sat, Apr 5, 2025 at 7:00 AM pritam kumar > wrote: > >> Hi Kafka Community, >> S

[jira] [Created] (KAFKA-19310) Missing mocks for DelayedShareFetchTest tests related to Memory Records slicing

Abhinav Dixit created KAFKA-19310: - Summary: Missing mocks for DelayedShareFetchTest tests related to Memory Records slicing Key: KAFKA-19310 URL: https://issues.apache.org/jira/browse/KAFKA-19310 Pro

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

+1 (binding). Thanks for the KIP! On Mon, May 19, 2025, 16:58 Ivan Yurchenko wrote: > Thank you everyone! > > The KIP is accepted with 5 binding and 3 non-binding votes. > I'll make the implementation PR shortly. > > Best, > Ivan > > > On Thu, May 15, 2025, at 09:33, Luke Chen wrote: > > +1 bind

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

Thank you everyone! The KIP is accepted with 5 binding and 3 non-binding votes. I'll make the implementation PR shortly. Best, Ivan On Thu, May 15, 2025, at 09:33, Luke Chen wrote: > +1 binding from me. > > Thanks. > Luke > > On Wed, May 14, 2025 at 7:14 PM Satish Duggana > wrote: > > > Tha

[jira] [Resolved] (KAFKA-19226) Add test_console_share_consumer system test

[ https://issues.apache.org/jira/browse/KAFKA-19226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19226. --- Fix Version/s: 4.1.0 Resolution: Fixed > Add test_console_share_consumer system test

[jira] [Resolved] (KAFKA-19217) ShareConsumerTest.testComplexShareConsumer is unreliable

[ https://issues.apache.org/jira/browse/KAFKA-19217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19217. --- Fix Version/s: 4.1.0 Resolution: Fixed > ShareConsumerTest.testComplexShareConsumer i

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

Hi TengYao, Thanks for the KIP, I have some questions: AM1: There exists metric "kafka.network:type=Acceptor,name=AcceptorBlockedPercent,listener={listener}" which records blocked time for all the requests which are waiting for connection slot, because of throttling time or no connection slot.

Re: [PR] MINOR: Update 3.9.1 site [kafka-site]

frankvicky commented on code in PR #687: URL: https://github.com/apache/kafka-site/pull/687#discussion_r2095285699 ## 39/documentation.html: ## @@ -30,7 +30,7 @@ - + Review Comment: Interesting... I don't change these manually. 🤔 -- This is an a

Re: [PR] MINOR: Update 3.9.1 site [kafka-site]

frankvicky commented on code in PR #687: URL: https://github.com/apache/kafka-site/pull/687#discussion_r2095284021 ## 39/javadoc/allclasses-index.html: ## @@ -11,7 +11,7 @@ - + Review Comment: Exactly -- This is an automated message from the Apache Git Service. To

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

Hi Omnia, Thanks for the explanation and update. It's better now. Questions: > 2. It's not clear how the "retry count" comes into play in the KIP. It > needs more explanation. My initial thinking is the retry configs are a must for all blob stores, so we can provide them, and validate them for fr

[jira] [Resolved] (KAFKA-17894) Additional metrics for cooperative consumption

[ https://issues.apache.org/jira/browse/KAFKA-17894?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-17894. --- Resolution: Done > Additional metrics for cooperative consumption >