Re: [PR] MINOR: Delete DeleteGroupsResult class. [kafka]

2025-03-05 Thread via GitHub
ijuma commented on code in PR #19057: URL: https://github.com/apache/kafka/pull/19057#discussion_r1982857330 ## clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupsResult.java: ## @@ -20,13 +20,33 @@ import org.apache.kafka.common.KafkaFuture; import java.u

Re: [PR] KAFKA-18648: Make `records` in `FetchResponse` nullable again [kafka]

2025-03-05 Thread via GitHub
ijuma commented on PR #19131: URL: https://github.com/apache/kafka/pull/19131#issuecomment-2703049893 I'll update the KIP once this is merged. -- 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 the

Re: [PR] KAFKA-18811: Included admin.client.config in VerifiableShareConsumer.java [kafka]

2025-03-05 Thread via GitHub
chirag-wadhwa5 closed pull request #19108: KAFKA-18811: Included admin.client.config in VerifiableShareConsumer.java URL: https://github.com/apache/kafka/pull/19108 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[PR] KAFKA-18811-2: Added command configs to admin client as well in VerifiableShareConsumer [kafka]

2025-03-05 Thread via GitHub
chirag-wadhwa5 opened a new pull request, #19130: URL: https://github.com/apache/kafka/pull/19130 This PR includes a new flag in VerifiableShareConsumer.java called admin.client.config to include a properties file for admin client related configs Reference: [KAFKA-18811](https://issu

[jira] [Commented] (KAFKA-18246) Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs

2025-03-05 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932852#comment-17932852 ] Chia-Ping Tsai commented on KAFKA-18246: revert: https://github.com/apache/kafk

Re: [PR] KAFKA-18461: Fix potential NPE in setDelta after map is erased [kafka]

2025-03-05 Thread via GitHub
leaf-soba commented on code in PR #18684: URL: https://github.com/apache/kafka/pull/18684#discussion_r1982759489 ## server-common/src/main/java/org/apache/kafka/timeline/Snapshot.java: ## @@ -47,6 +48,7 @@ T getDelta(Revertable owner) { } void setDelta(Revertable ow

[jira] [Resolved] (KAFKA-18910) Remove kafka.utils.json

2025-03-05 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18910. Fix Version/s: 4.1.0 Resolution: Fixed > Remove kafka.utils.json > ---

[jira] [Commented] (KAFKA-18927) Remove LATEST_0_11, LATEST_1_0, LATEST_1_1, LATEST_2_0

2025-03-05 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932840#comment-17932840 ] Chia-Ping Tsai commented on KAFKA-18927: [~ijuma] yes, you are right. I will rev

[jira] [Assigned] (KAFKA-18928) Support to dynamically change config for specific controller

2025-03-05 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-18928: -- Assignee: xuanzhang gong (was: Chia-Ping Tsai) > Support to dynamically change confi

[jira] [Updated] (KAFKA-18788) Improve simple assignor by having a max no. of partitions limit and min no. of partitions threshold assignment to members

2025-03-05 Thread Abhinav Dixit (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Abhinav Dixit updated KAFKA-18788: -- Description: The current simple assignor doesn't offer perfect sharing between share consumer

[jira] [Resolved] (KAFKA-18246) Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs

2025-03-05 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18246. Fix Version/s: 4.1.0 (was: 4.0.0) Resolution: Fixed > Fix Co

[jira] [Commented] (KAFKA-18246) Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs

2025-03-05 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932839#comment-17932839 ] Chia-Ping Tsai commented on KAFKA-18246: run the e2e "tests/kafkatest/tests/conn

[jira] [Reopened] (KAFKA-18246) Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs

2025-03-05 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18246?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reopened KAFKA-18246: > Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs > ---

[jira] [Commented] (KAFKA-18246) Fix ConnectRestApiTest.test_rest_api by adding multiversioning configs

2025-03-05 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18246?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932837#comment-17932837 ] Chia-Ping Tsai commented on KAFKA-18246: I will revert this from 4.0 to follow K

[jira] [Commented] (KAFKA-18928) Support to dynamically change config for specific controller

2025-03-05 Thread xuanzhang gong (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932833#comment-17932833 ] xuanzhang gong commented on KAFKA-18928: Hi,i will handle this issue ,plz assign

[jira] [Commented] (KAFKA-18067) Kafka Streams can leak Producer client under EOS

2025-03-05 Thread TengYao Chi (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932826#comment-17932826 ] TengYao Chi commented on KAFKA-18067: - Hi [~ableegoldman]  Thanks for the informati

Re: [PR] MINOR: Clean up metadata module [kafka]

2025-03-05 Thread via GitHub
sjhajharia commented on PR #19069: URL: https://github.com/apache/kafka/pull/19069#issuecomment-2702786625 Sure @mumrah Will keep that in mind -- 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

Re: [PR] MINOR: TopicIdPartition Records Benchmark [kafka]

2025-03-05 Thread via GitHub
ijuma commented on PR #18917: URL: https://github.com/apache/kafka/pull/18917#issuecomment-2702772140 Interesting, so the record implementation of `hashCode` is significantly faster than the previous implementation. -- This is an automated message from the Apache Git Service. To respond t

Re: [PR] KAFKA-18379: Enforce resigned cannot transition to any other state in same epoch [kafka]

2025-03-05 Thread via GitHub
github-actions[bot] commented on PR #18789: URL: https://github.com/apache/kafka/pull/18789#issuecomment-2702684614 A label of 'needs-attention' was automatically added to this PR in order to raise the attention of the committers. Once this issue has been triaged, the `triage` label s

Re: [PR] KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol [kafka]

2025-03-05 Thread via GitHub
frankvicky commented on code in PR #18600: URL: https://github.com/apache/kafka/pull/18600#discussion_r1982650451 ## raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientSnapshotTest.java: ## @@ -795,21 +800,20 @@ public void testFetchSnapshotRequestAsLeader(boolean withKip8

[jira] [Commented] (KAFKA-18927) Remove LATEST_0_11, LATEST_1_0, LATEST_1_1, LATEST_2_0

2025-03-05 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932814#comment-17932814 ] Ismael Juma commented on KAFKA-18927: - The change here is basically reverting the ch

Re: [PR] KAFKA-17552: Handle LIST_OFFSETS request for max_timestamp when remote storage is enabled [kafka]

2025-03-05 Thread via GitHub
github-actions[bot] commented on PR #17248: URL: https://github.com/apache/kafka/pull/17248#issuecomment-2702713397 This PR has been closed since it has not had any activity in 120 days. If you feel like this was a mistake, or you would like to continue working on it, please feel free to

Re: [PR] KAFKA-17552: Handle LIST_OFFSETS request for max_timestamp when remote storage is enabled [kafka]

2025-03-05 Thread via GitHub
github-actions[bot] closed pull request #17248: KAFKA-17552: Handle LIST_OFFSETS request for max_timestamp when remote storage is enabled URL: https://github.com/apache/kafka/pull/17248 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

Re: [PR] MINOR: zk2kraft: add more information about kafka-configs.sh [kafka]

2025-03-05 Thread via GitHub
chia7712 commented on code in PR #19100: URL: https://github.com/apache/kafka/pull/19100#discussion_r1982635141 ## docs/zk2kraft.html: ## @@ -153,6 +153,67 @@ Configurations +Dynamic Log Levels + + + +The

[jira] [Created] (KAFKA-18928) Support to dynamically change config for specific controller

2025-03-05 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-18928: -- Summary: Support to dynamically change config for specific controller Key: KAFKA-18928 URL: https://issues.apache.org/jira/browse/KAFKA-18928 Project: Kafka

Re: [PR] KAFKA-3987: Replace MD5 for FIPS 140-3 compliance in Log Cleaner. [kafka]

2025-03-05 Thread via GitHub
github-actions[bot] commented on PR #19035: URL: https://github.com/apache/kafka/pull/19035#issuecomment-2702684508 A label of 'needs-attention' was automatically added to this PR in order to raise the attention of the committers. Once this issue has been triaged, the `triage` label s

Re: [PR] [WIP] JWT bearer grant type support [kafka]

2025-03-05 Thread via GitHub
github-actions[bot] commented on PR #18912: URL: https://github.com/apache/kafka/pull/18912#issuecomment-2702684563 A label of 'needs-attention' was automatically added to this PR in order to raise the attention of the committers. Once this issue has been triaged, the `triage` label s

Re: [PR] KAFKA-18576: Convert ConfigType to Enum [kafka]

2025-03-05 Thread via GitHub
github-actions[bot] commented on PR #18711: URL: https://github.com/apache/kafka/pull/18711#issuecomment-2702684656 A label of 'needs-attention' was automatically added to this PR in order to raise the attention of the committers. Once this issue has been triaged, the `triage` label s

Re: [PR] KAFKA-18637: Fix max connections per ip and override reconfigurations [kafka]

2025-03-05 Thread via GitHub
frankvicky commented on code in PR #19099: URL: https://github.com/apache/kafka/pull/19099#discussion_r1982611756 ## core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala: ## @@ -482,6 +482,30 @@ class DynamicBrokerReconfigurationTest extends Quoru

[jira] [Assigned] (KAFKA-18927) Remove LATEST_0_11, LATEST_1_0, LATEST_1_1, LATEST_2_0

2025-03-05 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18927?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-18927: -- Assignee: Cheng Yi Chang (was: Chia-Ping Tsai) > Remove LATEST_0_11, LATEST_1_0, LAT

[jira] [Commented] (KAFKA-18927) Remove LATEST_0_11, LATEST_1_0, LATEST_1_1, LATEST_2_0

2025-03-05 Thread Cheng Yi Chang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932812#comment-17932812 ] Cheng Yi Chang commented on KAFKA-18927: Hi, [~chia7712]  Could you please assi

[jira] [Commented] (KAFKA-18927) Remove LATEST_0_11, LATEST_1_0, LATEST_1_1, LATEST_2_0

2025-03-05 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18927?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932808#comment-17932808 ] Chia-Ping Tsai commented on KAFKA-18927: from https://github.com/apache/kafka/pu

Re: [PR] KAFKA-18839: Drop EAGER rebalancing support in Kafka Streams [kafka]

2025-03-05 Thread via GitHub
chia7712 commented on PR #18988: URL: https://github.com/apache/kafka/pull/18988#issuecomment-2702645351 > Seems we can simplify the docker build and cleanup some more code as follow up. open https://issues.apache.org/jira/browse/KAFKA-18927 -- This is an automated message from the

[jira] [Created] (KAFKA-18927) Remove LATEST_0_11, LATEST_1_0, LATEST_1_1, LATEST_2_0

2025-03-05 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-18927: -- Summary: Remove LATEST_0_11, LATEST_1_0, LATEST_1_1,LATEST_2_0 Key: KAFKA-18927 URL: https://issues.apache.org/jira/browse/KAFKA-18927 Project: Kafka

Re: [PR] HOTFIX: Do not use highest version when version is valid [kafka]

2025-03-05 Thread via GitHub
chia7712 merged PR #19109: URL: https://github.com/apache/kafka/pull/19109 -- 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 the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache

[jira] [Commented] (KAFKA-18861) kafka-streams stuck in a loop of "SyncGroup failed" with an unbalanced assignment

2025-03-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18861?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932787#comment-17932787 ] A. Sophie Blee-Goldman commented on KAFKA-18861: Sounds like a similar s

[jira] [Commented] (KAFKA-18925) Add streams groups support in Admin.listGroups.

2025-03-05 Thread Lan Ding (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932798#comment-17932798 ] Lan Ding commented on KAFKA-18925: -- Hi [~lucasbru] , are we ready to do this? I'm happy

[jira] [Commented] (KAFKA-18819) StreamsGroupHeartbeat API and StreamsGroupDescribe API must check topic describe

2025-03-05 Thread Lan Ding (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18819?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932797#comment-17932797 ] Lan Ding commented on KAFKA-18819: -- Hi [~lucasbru] , are we ready to do this? I'm happy

[PR] Testing: run build serially [kafka]

2025-03-05 Thread via GitHub
mumrah opened a new pull request, #19128: URL: https://github.com/apache/kafka/pull/19128 Trying something -- 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 the specific comment. To unsubscribe, e

[jira] [Commented] (KAFKA-18921) Low CPU utilization during streams integration tests

2025-03-05 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932795#comment-17932795 ] David Arthur commented on KAFKA-18921: -- The Timeline section of build scans added C

[PR] KAFKA-18920: The kcontrollers must set kraft.version in ApiVersionsResponse [kafka]

2025-03-05 Thread via GitHub
cmccabe opened a new pull request, #19127: URL: https://github.com/apache/kafka/pull/19127 The kafka controllers need to set kraft.version in their ApiVersionsResponse messages according to the current kraft.version reported by the Raft layer. Instead, currently they always set it to 0.

[jira] [Updated] (KAFKA-18920) The kcontrollers do not set kraft.version in ApiVersionsResponse

2025-03-05 Thread Colin McCabe (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Colin McCabe updated KAFKA-18920: - Summary: The kcontrollers do not set kraft.version in ApiVersionsResponse (was: kafka-feature d

Re: [PR] KAFKA-18736: Decide when a heartbeat should be sent [kafka]

2025-03-05 Thread via GitHub
zheguang commented on code in PR #19121: URL: https://github.com/apache/kafka/pull/19121#discussion_r1982385169 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsGroupHeartbeatRequestManager.java: ## @@ -254,34 +284,131 @@ public StreamsGroupHeartbeatRe

Re: [PR] TESTING update readme [kafka]

2025-03-05 Thread via GitHub
mumrah closed pull request #19123: TESTING update readme URL: https://github.com/apache/kafka/pull/19123 -- 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 the specific comment. To unsubscribe, e-mail:

Re: [PR] KAFKA-18919 Clarify that KafkaPrincipalBuilder classes must also implement KafkaPrincipalSerde [kafka]

2025-03-05 Thread via GitHub
chia7712 commented on code in PR #19104: URL: https://github.com/apache/kafka/pull/19104#discussion_r1980994112 ## docs/zk2kraft.html: ## @@ -57,7 +57,7 @@ Configurations In KRaft mode, Kafka eliminates its dependency on ZooKeeper, and the control

Re: [PR] KAFKA-16580: Enable dynamic quorum reconfiguration for raft simulation tests pt 1 [kafka]

2025-03-05 Thread via GitHub
kevin-wu24 commented on code in PR #18987: URL: https://github.com/apache/kafka/pull/18987#discussion_r1982298361 ## raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java: ## @@ -3637,6 +3637,11 @@ QuorumState quorum() { return quorum; } +// Visible o

Re: [PR] KAFKA-18917: TransformValues throws NPE [kafka]

2025-03-05 Thread via GitHub
ableegoldman commented on PR #19089: URL: https://github.com/apache/kafka/pull/19089#issuecomment-2702232938 ah, good catch, and thanks for the fix! -- 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 t

Re: [PR] HOTFIX Fix asf.yaml strict [2/n] [kafka]

2025-03-05 Thread via GitHub
mumrah merged PR #19126: URL: https://github.com/apache/kafka/pull/19126 -- 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 the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.o

[PR] Fix asf.yaml strict [2/n] [kafka]

2025-03-05 Thread via GitHub
mumrah opened a new pull request, #19126: URL: https://github.com/apache/kafka/pull/19126 Change the `strict` value to false. Follow-up of #19124 -- 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 t

[jira] [Commented] (KAFKA-18067) Kafka Streams can leak Producer client under EOS

2025-03-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932778#comment-17932778 ] A. Sophie Blee-Goldman commented on KAFKA-18067: thanks for catching thi

[jira] [Updated] (KAFKA-18067) Kafka Streams can leak Producer client under EOS

2025-03-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18067?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] A. Sophie Blee-Goldman updated KAFKA-18067: --- Fix Version/s: 4.1.0 > Kafka Streams can leak Producer client under EOS > --

Re: [PR] KAFKA-16580: Enable dynamic quorum reconfiguration for raft simulation tests pt 1 [kafka]

2025-03-05 Thread via GitHub
ahuang98 commented on code in PR #18987: URL: https://github.com/apache/kafka/pull/18987#discussion_r1982287669 ## raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java: ## @@ -3637,6 +3637,11 @@ QuorumState quorum() { return quorum; } +// Visible onl

[jira] [Commented] (KAFKA-18921) Low CPU utilization during streams integration tests

2025-03-05 Thread A. Sophie Blee-Goldman (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932770#comment-17932770 ] A. Sophie Blee-Goldman commented on KAFKA-18921: [~davidarthur] is there

Re: [PR] KAFKA-18613: Add describeStreamsGroup to Admin API [kafka]

2025-03-05 Thread via GitHub
bbejeck commented on code in PR #19116: URL: https://github.com/apache/kafka/pull/19116#discussion_r1982259039 ## clients/src/main/java/org/apache/kafka/clients/admin/DescribeStreamsGroupsResult.java: ## @@ -0,0 +1,68 @@ +/* + * Licensed to the Apache Software Foundation (ASF) u

Re: [PR] HOTFIX Fix asf.yaml strict [1/n] [kafka]

2025-03-05 Thread via GitHub
mumrah merged PR #19124: URL: https://github.com/apache/kafka/pull/19124 -- 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 the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.o

Re: [PR] KAFKA-16580: Enable dynamic quorum reconfiguration for raft simulation tests pt 1 [kafka]

2025-03-05 Thread via GitHub
ahuang98 commented on code in PR #18987: URL: https://github.com/apache/kafka/pull/18987#discussion_r1982280759 ## raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java: ## @@ -550,14 +576,17 @@ void canAddObserverAndRemovePartitionedVoter( initializeC

Re: [PR] KAFKA-13022: Optimize ClientQuotasImage#describe [kafka]

2025-03-05 Thread via GitHub
ahuang98 commented on code in PR #19079: URL: https://github.com/apache/kafka/pull/19079#discussion_r1982266631 ## metadata/src/main/java/org/apache/kafka/image/ClientQuotasImage.java: ## @@ -126,40 +144,45 @@ public DescribeClientQuotasResponseData describe(DescribeClientQuota

Re: [PR] KAFKA-18602: Incorrect FinalizedVersionLevel reported for dynamic KRaft quorum (wip) [kafka]

2025-03-05 Thread via GitHub
ijuma commented on PR #18685: URL: https://github.com/apache/kafka/pull/18685#issuecomment-2702191844 Let's add a test please. -- 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 the specific comment

Re: [PR] KAFKA-16758: Extend Consumer#close with an option to leave the group or not [kafka]

2025-03-05 Thread via GitHub
ableegoldman commented on code in PR #17614: URL: https://github.com/apache/kafka/pull/17614#discussion_r1982252797 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java: ## @@ -1151,31 +1153,28 @@ protected void handlePollTimeoutExpiry()

Re: [PR] KAFKA-17014: ScramFormatter should not use String for password [kafka]

2025-03-05 Thread via GitHub
mingdaoy commented on code in PR #19082: URL: https://github.com/apache/kafka/pull/19082#discussion_r1982210800 ## clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClient.java: ## @@ -190,7 +190,7 @@ private void setState(State state) { priv

Re: [PR] KAFKA-17014: ScramFormatter should not use String for password [kafka]

2025-03-05 Thread via GitHub
mingdaoy commented on code in PR #19082: URL: https://github.com/apache/kafka/pull/19082#discussion_r1982214194 ## metadata/src/main/java/org/apache/kafka/metadata/storage/ScramParser.java: ## @@ -173,7 +173,8 @@ byte[] saltedPassword(byte[] salt, int iterations) throws Excepti

Re: [PR] KAFKA-17014: ScramFormatter should not use String for password [kafka]

2025-03-05 Thread via GitHub
mingdaoy commented on code in PR #19082: URL: https://github.com/apache/kafka/pull/19082#discussion_r198021 ## clients/src/main/java/org/apache/kafka/common/security/scram/internals/ScramSaslClient.java: ## @@ -190,7 +190,7 @@ private void setState(State state) { priv

Re: [PR] KAFKA-17014: ScramFormatter should not use String for password [kafka]

2025-03-05 Thread via GitHub
mingdaoy commented on code in PR #19082: URL: https://github.com/apache/kafka/pull/19082#discussion_r1982207332 ## metadata/src/main/java/org/apache/kafka/metadata/storage/ScramParser.java: ## @@ -173,7 +173,9 @@ byte[] saltedPassword(byte[] salt, int iterations) throws Excepti

Re: [PR] KAFKA-17014: ScramFormatter should not use String for password [kafka]

2025-03-05 Thread via GitHub
mingdaoy commented on code in PR #19082: URL: https://github.com/apache/kafka/pull/19082#discussion_r1982216871 ## core/src/main/scala/kafka/server/DelegationTokenManager.scala: ## @@ -100,13 +100,13 @@ class DelegationTokenManager(val config: KafkaConfig, } /** - * @p

Re: [PR] KAFKA-17014: ScramFormatter should not use String for password [kafka]

2025-03-05 Thread via GitHub
mingdaoy commented on code in PR #19082: URL: https://github.com/apache/kafka/pull/19082#discussion_r1982214194 ## metadata/src/main/java/org/apache/kafka/metadata/storage/ScramParser.java: ## @@ -173,7 +173,8 @@ byte[] saltedPassword(byte[] salt, int iterations) throws Excepti

Re: [PR] KAFKA-18766:Docs: Make usage of allow.everyone.if.no.acl.found config clearer [kafka]

2025-03-05 Thread via GitHub
Iamoshione commented on PR #19077: URL: https://github.com/apache/kafka/pull/19077#issuecomment-2702116652 @AndrewJSchofield Branch updated with trunk. Please let me know if any further changes are needed. Thanks! -- This is an automated message from the Apache Git Service. To respond to

Re: [PR] KAFKA-18766:Docs: Make usage of allow.everyone.if.no.acl.found config clearer [kafka]

2025-03-05 Thread via GitHub
AndrewJSchofield commented on PR #19077: URL: https://github.com/apache/kafka/pull/19077#issuecomment-2702110906 @Iamoshione Please could you update the branch with the latest changes from trunk. I will need a green build of up-to-date code to merge. -- This is an automated message from t

Re: [PR] KAFKA-18766:Docs: Make usage of allow.everyone.if.no.acl.found config clearer [kafka]

2025-03-05 Thread via GitHub
Iamoshione commented on PR #19077: URL: https://github.com/apache/kafka/pull/19077#issuecomment-2702105935 @AndrewJSchofield Apologies for the oversight—I didn’t notice it on time. I’ve now addressed the request as specified. Let me know if any further changes are needed. Thanks! -- This

Re: [PR] KAFKA-18900: Experimental share consumer acknowledge mode config [kafka]

2025-03-05 Thread via GitHub
mumrah commented on code in PR #19113: URL: https://github.com/apache/kafka/pull/19113#discussion_r1982166952 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java: ## @@ -1062,6 +1065,24 @@ private void ensureExplicitAcknowledgement() {

[PR] Small fit and finish changes to config doc strings [kafka]

2025-03-05 Thread via GitHub
cherylws opened a new pull request, #19125: URL: https://github.com/apache/kafka/pull/19125 - Adding a space, article and punctuation to the doc strings for consistency and readability. If you would like to tag individuals, add some commentary, upload images, or include other suppl

[PR] HOTFIX Fix asf.yaml strict part 1 [kafka]

2025-03-05 Thread via GitHub
mumrah opened a new pull request, #19124: URL: https://github.com/apache/kafka/pull/19124 We need to reapply this asf.yaml change, so first setting it to "true" -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL a

Re: [PR] KAFKA-18766:Docs: Make usage of allow.everyone.if.no.acl.found config clearer [kafka]

2025-03-05 Thread via GitHub
AndrewJSchofield commented on code in PR #19077: URL: https://github.com/apache/kafka/pull/19077#discussion_r1982140648 ## docs/security.html: ## @@ -2366,4 +2374,4 @@ security.inter.broker.protocol=SSL - Review Comment: I still do not see why this PR contains this fin

[jira] [Commented] (KAFKA-18054) Automatically detect missed configs needed by a topology

2025-03-05 Thread Lorcan (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932736#comment-17932736 ] Lorcan commented on KAFKA-18054: Hi [~ableegoldman], I’ve done some investigation into t

[PR] TESTING update readme [kafka]

2025-03-05 Thread via GitHub
mumrah opened a new pull request, #19123: URL: https://github.com/apache/kafka/pull/19123 Just testing a new PR -- 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 the specific comment. To unsubscri

Re: [PR] KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol [kafka]

2025-03-05 Thread via GitHub
ahuang98 commented on code in PR #18600: URL: https://github.com/apache/kafka/pull/18600#discussion_r1982108615 ## raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientSnapshotTest.java: ## @@ -795,21 +800,20 @@ public void testFetchSnapshotRequestAsLeader(boolean withKip853

Re: [PR] KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol [kafka]

2025-03-05 Thread via GitHub
ahuang98 commented on code in PR #18600: URL: https://github.com/apache/kafka/pull/18600#discussion_r1982108615 ## raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientSnapshotTest.java: ## @@ -795,21 +800,20 @@ public void testFetchSnapshotRequestAsLeader(boolean withKip853

Re: [PR] KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol [kafka]

2025-03-05 Thread via GitHub
ahuang98 commented on PR #18600: URL: https://github.com/apache/kafka/pull/18600#issuecomment-2701942128 @frankvicky let me know when you need another review, I spot checked some of the comments I left earlier that you thumbs up-ed and it seems they haven't all been addressed yet -- This

[jira] [Updated] (KAFKA-18925) Add streams groups support in Admin.listGroups.

2025-03-05 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-18925: Component/s: streams > Add streams groups support in Admin.listGroups. > -

Re: [PR] KAFKA-18561: Remove withKip853Rpc and replace it with withRaftProtocol [kafka]

2025-03-05 Thread via GitHub
ahuang98 commented on code in PR #18600: URL: https://github.com/apache/kafka/pull/18600#discussion_r1982110708 ## raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientSnapshotTest.java: ## @@ -52,13 +54,19 @@ import java.util.concurrent.atomic.AtomicLong; import java.util.

Re: [PR] MINOR Add a required status check for trunk [kafka]

2025-03-05 Thread via GitHub
mumrah merged PR #19122: URL: https://github.com/apache/kafka/pull/19122 -- 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 the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.o

Re: [PR] MINOR Add a required status check for trunk [kafka]

2025-03-05 Thread via GitHub
mumrah commented on code in PR #19122: URL: https://github.com/apache/kafka/pull/19122#discussion_r1981908712 ## .asf.yaml: ## @@ -45,3 +45,19 @@ github: squash_commit_message: PR_TITLE_AND_DESC merge: false rebase: false + + protected_branches: +trunk: +

Re: [PR] KAFKA-18766:Docs: Make usage of allow.everyone.if.no.acl.found config clearer [kafka]

2025-03-05 Thread via GitHub
Iamoshione commented on PR #19077: URL: https://github.com/apache/kafka/pull/19077#issuecomment-2701858209 @AndrewJSchofield Hello there I have adjusted the indentation and removed the unnecessary div tag at the end of the page -- This is an automated message from the Apache Git Service.

Re: [PR] KAFKA-18602: Incorrect FinalizedVersionLevel reported for dynamic KRaft quorum (wip) [kafka]

2025-03-05 Thread via GitHub
jsancio commented on PR #18685: URL: https://github.com/apache/kafka/pull/18685#issuecomment-2701811371 @FrankYang0529 is this still a WIP? I would like to get this fixed and included in the 4.0.0 release. cc @dajac @junrao -- This is an automated message from the Apache Git Service. To

[jira] [Commented] (KAFKA-18920) kafka-feature doesn't report the correct kraft.version

2025-03-05 Thread Mahsa Seifikar (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932713#comment-17932713 ] Mahsa Seifikar commented on KAFKA-18920: There is a similar Jira ticket https:/

Re: [PR] KAFKA-18766:Docs: Make usage of allow.everyone.if.no.acl.found config clearer [kafka]

2025-03-05 Thread via GitHub
Iamoshione closed pull request #19077: KAFKA-18766:Docs: Make usage of allow.everyone.if.no.acl.found config clearer URL: https://github.com/apache/kafka/pull/19077 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL

[jira] [Commented] (KAFKA-18477) remove usage of OffsetForLeaderEpochRequest in AbstractFetcherThread

2025-03-05 Thread Jun Rao (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932712#comment-17932712 ] Jun Rao commented on KAFKA-18477: - [~chia7712] : Good point. If the follower doesn't hav

Re: [PR] KAFKA-18637: Fix max connections per ip and override reconfigurations [kafka]

2025-03-05 Thread via GitHub
azhar2407 commented on code in PR #19099: URL: https://github.com/apache/kafka/pull/19099#discussion_r1981949803 ## core/src/test/scala/integration/kafka/server/DynamicBrokerReconfigurationTest.scala: ## @@ -482,6 +482,30 @@ class DynamicBrokerReconfigurationTest extends Quorum

Re: [PR] MINOR: zk2kraft: add more information about kafka-configs.sh [kafka]

2025-03-05 Thread via GitHub
ijuma commented on code in PR #19100: URL: https://github.com/apache/kafka/pull/19100#discussion_r1981944751 ## docs/zk2kraft.html: ## @@ -153,6 +153,67 @@ Configurations +Dynamic Log Levels + + + +The dyn

Re: [PR] MINOR: zk2kraft: add more information about kafka-configs.sh [kafka]

2025-03-05 Thread via GitHub
cmccabe commented on code in PR #19100: URL: https://github.com/apache/kafka/pull/19100#discussion_r1981933910 ## docs/zk2kraft.html: ## @@ -153,6 +153,67 @@ Configurations +Dynamic Log Levels + + + +The d

Re: [PR] MINOR: zk2kraft: add more information about kafka-configs.sh [kafka]

2025-03-05 Thread via GitHub
cmccabe commented on code in PR #19100: URL: https://github.com/apache/kafka/pull/19100#discussion_r1981929991 ## docs/zk2kraft.html: ## @@ -153,6 +153,67 @@ Configurations +Dynamic Log Levels + + + +The d

Re: [PR] KAFKA-18646: Null records in fetch response breaks librdkafka [kafka]

2025-03-05 Thread via GitHub
junrao commented on code in PR #18726: URL: https://github.com/apache/kafka/pull/18726#discussion_r1981925892 ## clients/src/main/resources/common/message/FetchResponse.json: ## @@ -106,7 +106,7 @@ ]}, { "name": "PreferredReadReplica", "type": "int32", "version

Re: [PR] MINOR: Delete DeleteGroupsResult class. [kafka]

2025-03-05 Thread via GitHub
smjn commented on code in PR #19057: URL: https://github.com/apache/kafka/pull/19057#discussion_r1981910462 ## clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupsResult.java: ## @@ -20,13 +20,33 @@ import org.apache.kafka.common.KafkaFuture; import java.ut

Re: [PR] MINOR Add a required status check for trunk [kafka]

2025-03-05 Thread via GitHub
mumrah commented on code in PR #19122: URL: https://github.com/apache/kafka/pull/19122#discussion_r1981908712 ## .asf.yaml: ## @@ -45,3 +45,19 @@ github: squash_commit_message: PR_TITLE_AND_DESC merge: false rebase: false + + protected_branches: +trunk: +

Re: [PR] MINOR: Delete DeleteGroupsResult class. [kafka]

2025-03-05 Thread via GitHub
AndrewJSchofield commented on code in PR #19057: URL: https://github.com/apache/kafka/pull/19057#discussion_r1981904870 ## clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupsResult.java: ## @@ -20,13 +20,33 @@ import org.apache.kafka.common.KafkaFuture; im

Re: [PR] MINOR: Clean up metadata module [kafka]

2025-03-05 Thread via GitHub
mumrah commented on PR #19069: URL: https://github.com/apache/kafka/pull/19069#issuecomment-2701677430 @sjhajharia just a quick note -- if you force push your branch after someone has reviewed your PR, it basically destroys the history of the review and inline conversations. It's best to me

Re: [PR] MINOR: Delete DeleteGroupsResult class. [kafka]

2025-03-05 Thread via GitHub
junrao commented on code in PR #19057: URL: https://github.com/apache/kafka/pull/19057#discussion_r1981900730 ## clients/src/main/java/org/apache/kafka/clients/admin/DeleteShareGroupsResult.java: ## @@ -20,13 +20,33 @@ import org.apache.kafka.common.KafkaFuture; import java.

Re: [PR] KAFKA-18461: Fix potential NPE in setDelta after map is erased [kafka]

2025-03-05 Thread via GitHub
mumrah commented on code in PR #18684: URL: https://github.com/apache/kafka/pull/18684#discussion_r1981899587 ## server-common/src/main/java/org/apache/kafka/timeline/Snapshot.java: ## @@ -47,6 +48,7 @@ T getDelta(Revertable owner) { } void setDelta(Revertable owner

Re: [PR] KAFKA-18461: Fix potential NPE in setDelta after map is erased [kafka]

2025-03-05 Thread via GitHub
mumrah commented on PR #18684: URL: https://github.com/apache/kafka/pull/18684#issuecomment-270121 Can you please merge trunk into this PR and let the CI run again? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use t

Re: [PR] KAFKA-18766:Docs: Make usage of allow.everyone.if.no.acl.found config clearer [kafka]

2025-03-05 Thread via GitHub
AndrewJSchofield commented on code in PR #19077: URL: https://github.com/apache/kafka/pull/19077#discussion_r1981867953 ## docs/security.html: ## @@ -1248,11 +1248,16 @@ https://cwiki.apache.org/confluence/display/KAFKA/KIP-11+-+Authorization+Interface";>KIP-11 and resourc

Re: [PR] MINOR Add a required status check for trunk [kafka]

2025-03-05 Thread via GitHub
mumrah commented on PR #19122: URL: https://github.com/apache/kafka/pull/19122#issuecomment-2701616024 Here's how Pulsar has their repo configured: https://github.com/apache/pulsar/blob/master/.asf.yaml -- This is an automated message from the Apache Git Service. To respond to the message

  1   2   3   >