[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] [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

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] [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-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] 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

[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

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

[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

[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

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

[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] [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] [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] [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-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

[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

[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] [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] [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] [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] 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

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] 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

[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] 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

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-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] 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

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] 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] 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

[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-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] [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

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

[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] [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

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-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] 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-18804: Remove slf4j warning when using tool script [kafka]

2025-03-05 Thread via GitHub
chia7712 merged PR #18918: URL: https://github.com/apache/kafka/pull/18918 -- 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

Re: [PR] KAFKA-17607: Add CI step to verify LICENSE-binary [kafka]

2025-03-05 Thread via GitHub
xijiu commented on PR #18299: URL: https://github.com/apache/kafka/pull/18299#issuecomment-2700736205 @chia7712 Thanks for CR and I have fixed them. There is a small point that when I executed the python script locally, it prompted that I needed to provide parameters. Please take a look

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

2025-03-05 Thread via GitHub
chirag-wadhwa5 opened a new pull request, #19108: URL: https://github.com/apache/kafka/pull/19108 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

Re: [PR] KAFKA-14484: Move UnifiedLog to storage module [kafka]

2025-03-05 Thread via GitHub
mimaison commented on code in PR #19030: URL: https://github.com/apache/kafka/pull/19030#discussion_r1981276951 ## storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java: ## @@ -55,6 +113,2289 @@ public class UnifiedLog { public static final String STR

[jira] [Assigned] (KAFKA-18924) Running the storage module tests produces a storage/storage.log file

2025-03-05 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-18924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 黃竣陽 reassigned KAFKA-18924: --- Assignee: 黃竣陽 > Running the storage module tests produces a storage/storage.log file >

Re: [PR] MINOR: Refactor GroupCoordinatorConfig [kafka]

2025-03-05 Thread via GitHub
dajac merged PR #19092: URL: https://github.com/apache/kafka/pull/19092 -- 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.or

Re: [PR] KAFKA-10864: Convert end txn marker schema to use auto-generated protocol [kafka]

2025-03-05 Thread via GitHub
chia7712 merged PR #9766: URL: https://github.com/apache/kafka/pull/9766 -- 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

[jira] [Created] (KAFKA-18924) Running the storage module tests produces a storage/storage.log file

2025-03-05 Thread Mickael Maison (Jira)
Mickael Maison created KAFKA-18924: -- Summary: Running the storage module tests produces a storage/storage.log file Key: KAFKA-18924 URL: https://issues.apache.org/jira/browse/KAFKA-18924 Project: Kaf

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

2025-03-05 Thread via GitHub
apoorvmittal10 commented on code in PR #19108: URL: https://github.com/apache/kafka/pull/19108#discussion_r1981287886 ## tools/src/main/java/org/apache/kafka/tools/VerifiableShareConsumer.java: ## @@ -562,6 +557,13 @@ private static ArgumentParser argParser() { .met

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

2025-03-05 Thread via GitHub
dengziming commented on PR #19109: URL: https://github.com/apache/kafka/pull/19109#issuecomment-2700803255 Hello @chia7712 , sorry for my negligence, I accidentally set highest version in all cases, it's influential currently but is a time bomb for future. -- This is an automated message

[jira] [Commented] (KAFKA-17808) InstanceAlreadyExistsException: kafka.admin.client:type=app-info,id=connector-dlq-adminclient- when add connector with tasks

2025-03-05 Thread Jhen-Yung Hsu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17808?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932554#comment-17932554 ] Jhen-Yung Hsu commented on KAFKA-17808: --- [~ignat233] Could you provide the steps t

Re: [PR] [MINOR] Cleanup Storage Module [kafka]

2025-03-05 Thread via GitHub
sjhajharia commented on PR #19072: URL: https://github.com/apache/kafka/pull/19072#issuecomment-2700255546 Thanks @m1a2st Seems like I missed it as it looked different. Have fixed the same. -- This is an automated message from the Apache Git Service. To respond to the message, please l

[PR] KAFKA-18031: Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt [kafka]

2025-03-05 Thread via GitHub
TaiJuWu opened a new pull request, #19105: URL: https://github.com/apache/kafka/pull/19105 Jira: https://issues.apache.org/jira/browse/KAFKA-18031 This test expose an issue: If the request number exceeds `maxInFlightRequestsPerConnection`, the `LeaveGroup` request would be not sent

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_r1981043279 ## docs/security.html: ## @@ -1248,11 +1248,15 @@ https://cwiki.apache.org/confluence/display/KAFKA/KIP-11+-+Authorization+Interface";>KIP-11 and resourc

Re: [PR] KAFKA-18142 switch Kafka's Gradle build shadow plugin to `com.gradleup.shadow` (and upgrade plugin version) [kafka]

2025-03-05 Thread via GitHub
apoorvmittal10 commented on PR #18018: URL: https://github.com/apache/kafka/pull/18018#issuecomment-2700506846 @mumrah Can you please review it as well and help merging then changes. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to Gi

Re: [PR] KAFKA-14484: Move UnifiedLog to storage module [kafka]

2025-03-05 Thread via GitHub
mimaison commented on code in PR #19030: URL: https://github.com/apache/kafka/pull/19030#discussion_r1981156216 ## storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java: ## @@ -55,6 +113,2289 @@ public class UnifiedLog { public static final String STR

Re: [PR] KAFKA-18031: Flaky PlaintextConsumerTest testCloseLeavesGroupOnInterrupt [kafka]

2025-03-05 Thread via GitHub
TaiJuWu commented on PR #19105: URL: https://github.com/apache/kafka/pull/19105#issuecomment-2700559090 @lianetm Please take a look when you are available, thanks. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the UR

Re: [PR] KAFKA-14484: Move UnifiedLog to storage module [kafka]

2025-03-05 Thread via GitHub
mimaison commented on code in PR #19030: URL: https://github.com/apache/kafka/pull/19030#discussion_r1981166972 ## storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java: ## @@ -55,6 +113,2289 @@ public class UnifiedLog { public static final String STR

[PR] MINOR: KAFKA-18876 4.0 docs follow-up [kafka]

2025-03-05 Thread via GitHub
mingdaoy opened a new pull request, #19107: URL: https://github.com/apache/kafka/pull/19107 https://github.com/apache/kafka/pull/19103#issuecomment-2700303106 Fixed the snapshot file format: ![image](https://github.com/user-attachments/assets/7acf4c81-b684-4b1d-9479-1c03096b05a3)

Re: [PR] MINOR: KAFKA-18876 4.0 docs follow-up (2) [kafka]

2025-03-05 Thread via GitHub
chia7712 commented on code in PR #19107: URL: https://github.com/apache/kafka/pull/19107#discussion_r1981171909 ## docs/ops.html: ## @@ -3965,7 +3965,7 @@ The kafka-metadata-shell.sh tool can be used to interactively inspect the state of the cluster metadata partition: - $ b

[jira] [Commented] (KAFKA-15371) MetadataShell is stuck when bootstrapping

2025-03-05 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-15371?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17932594#comment-17932594 ] Deng Ziming commented on KAFKA-15371: - [~chia7712] As far as I can see, the .log fil

Re: [PR] MINOR: KAFKA-18876 4.0 docs follow-up (2) [kafka]

2025-03-05 Thread via GitHub
frankvicky commented on code in PR #19107: URL: https://github.com/apache/kafka/pull/19107#discussion_r1981192398 ## docs/ops.html: ## @@ -3965,7 +3965,7 @@ The kafka-metadata-shell.sh tool can be used to interactively inspect the state of the cluster metadata partition: - $

Re: [PR] KAFKA-14121: AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor [kafka]

2025-03-05 Thread via GitHub
clolov merged PR #18983: URL: https://github.com/apache/kafka/pull/18983 -- 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-14484: Move UnifiedLog to storage module [kafka]

2025-03-05 Thread via GitHub
mimaison commented on code in PR #19030: URL: https://github.com/apache/kafka/pull/19030#discussion_r1981152506 ## storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java: ## @@ -55,6 +113,2289 @@ public class UnifiedLog { public static final String STR

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_r1981121079 ## docs/zk2kraft.html: ## @@ -153,6 +153,67 @@ Configurations +Dynamic Log Levels + + + +The

Re: [PR] KAFKA-14121: AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor [kafka]

2025-03-05 Thread via GitHub
clolov commented on PR #18983: URL: https://github.com/apache/kafka/pull/18983#issuecomment-2700629939 That's a good question, I will merge as-is and reachout to people to hear their opinions. -- This is an automated message from the Apache Git Service. To respond to the message, please l

Re: [PR] MINOR: KAFKA-18876 4.0 docs follow-up (2) [kafka]

2025-03-05 Thread via GitHub
frankvicky commented on code in PR #19107: URL: https://github.com/apache/kafka/pull/19107#discussion_r1981192398 ## docs/ops.html: ## @@ -3965,7 +3965,7 @@ The kafka-metadata-shell.sh tool can be used to interactively inspect the state of the cluster metadata partition: - $

Re: [PR] KAFKA-18817: ShareGroupHeartbeat and ShareGroupDescribe API must check topic describe [kafka]

2025-03-05 Thread via GitHub
clolov merged PR #19083: URL: https://github.com/apache/kafka/pull/19083 -- 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-14121: AlterPartitionReassignments API should allow callers to specify the option of preserving the replication factor [kafka]

2025-03-05 Thread via GitHub
clolov commented on PR #18983: URL: https://github.com/apache/kafka/pull/18983#issuecomment-2700635940 I will also let you resolve the JIRA appropriately and move the KIP to the correct section + update the Kafka version in which it will be going out! -- This is an automated message from

Re: [PR] MINOR: KAFKA-18876 4.0 docs follow-up (2) [kafka]

2025-03-05 Thread via GitHub
Yunyung commented on code in PR #19107: URL: https://github.com/apache/kafka/pull/19107#discussion_r1981209854 ## docs/ops.html: ## @@ -3965,7 +3965,7 @@ The kafka-metadata-shell.sh tool can be used to interactively inspect the state of the cluster metadata partition: - $ bi

Re: [PR] MINOR: KAFKA-18876 4.0 docs follow-up (2) [kafka]

2025-03-05 Thread via GitHub
Yunyung commented on code in PR #19107: URL: https://github.com/apache/kafka/pull/19107#discussion_r1981209854 ## docs/ops.html: ## @@ -3965,7 +3965,7 @@ The kafka-metadata-shell.sh tool can be used to interactively inspect the state of the cluster metadata partition: - $ bi

Re: [PR] MINOR: KAFKA-18876 4.0 docs follow-up (2) [kafka]

2025-03-05 Thread via GitHub
Yunyung commented on code in PR #19107: URL: https://github.com/apache/kafka/pull/19107#discussion_r1981209854 ## docs/ops.html: ## @@ -3965,7 +3965,7 @@ The kafka-metadata-shell.sh tool can be used to interactively inspect the state of the cluster metadata partition: - $ bi

Re: [PR] KAFKA-14484: Move UnifiedLog to storage module [kafka]

2025-03-05 Thread via GitHub
mimaison commented on code in PR #19030: URL: https://github.com/apache/kafka/pull/19030#discussion_r1981217329 ## storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java: ## @@ -55,6 +113,2289 @@ public class UnifiedLog { public static final String STR

Re: [PR] KAFKA-14484: Move UnifiedLog to storage module [kafka]

2025-03-05 Thread via GitHub
mimaison commented on code in PR #19030: URL: https://github.com/apache/kafka/pull/19030#discussion_r1981225722 ## storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java: ## @@ -55,6 +113,2289 @@ public class UnifiedLog { public static final String STR

Re: [PR] KAFKA-14484: Move UnifiedLog to storage module [kafka]

2025-03-05 Thread via GitHub
mimaison commented on code in PR #19030: URL: https://github.com/apache/kafka/pull/19030#discussion_r1981230458 ## storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java: ## @@ -55,6 +113,2289 @@ public class UnifiedLog { public static final String STR

[jira] [Updated] (KAFKA-16936) Upgrade slf4j to 2.0.9 and integrate "-Dslf4j.provider" to kafka script

2025-03-05 Thread TengYao Chi (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TengYao Chi updated KAFKA-16936: Summary: Upgrade slf4j to 2.0.9 and integrate "-Dslf4j.provider" to kafka script (was: Upgrade sl

Re: [PR] KAFKA-18886: add behavior change of CreateTopicPolicy and AlterConfigPolicy to zk2kraft [kafka]

2025-03-05 Thread via GitHub
chia7712 merged PR #19087: URL: https://github.com/apache/kafka/pull/19087 -- 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] [Resolved] (KAFKA-18804) Remove slf4j warning when using tool script.

2025-03-05 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18804. Fix Version/s: 4.1.0 Resolution: Fixed > Remove slf4j warning when using tool scrip

[PR] MINOR: transformValues test improvment [kafka]

2025-03-05 Thread via GitHub
lucasbru opened a new pull request, #19106: URL: https://github.com/apache/kafka/pull/19106 Follow-up to 295760d3eb68178eac96ee4211fa75dfdbddfa95. Also check the set of state stores as suggested in reviews. -- This is an automated message from the Apache Git Service. To respond to the mes

[jira] [Resolved] (KAFKA-12903) Replace producer state entry with auto-generated protocol

2025-03-05 Thread Deng Ziming (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-12903?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deng Ziming resolved KAFKA-12903. - Resolution: Duplicate Already fixed in KAFKA-17056 > Replace producer state entry with auto-gen

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

2025-03-05 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-18910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 黃竣陽 updated KAFKA-18910: Summary: Remove kafka.utils.json (was: Romve kafka.utils.json ) > Remove kafka.utils.json > ---

Re: [PR] MINOR: transformValues test improvement [kafka]

2025-03-05 Thread via GitHub
cadonna commented on code in PR #19106: URL: https://github.com/apache/kafka/pull/19106#discussion_r1981351538 ## streams/src/test/java/org/apache/kafka/streams/kstream/internals/KTableTransformValuesTest.java: ## @@ -410,6 +410,8 @@ public void shouldCalculateCorrectOldValuesI

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

2025-03-05 Thread via GitHub
chirag-wadhwa5 commented on code in PR #19108: URL: https://github.com/apache/kafka/pull/19108#discussion_r1981366175 ## tools/src/main/java/org/apache/kafka/tools/VerifiableShareConsumer.java: ## @@ -596,18 +599,29 @@ public static VerifiableShareConsumer createFromArgs(Argume

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

2025-03-05 Thread via GitHub
chirag-wadhwa5 commented on code in PR #19108: URL: https://github.com/apache/kafka/pull/19108#discussion_r1981368859 ## tools/src/main/java/org/apache/kafka/tools/VerifiableShareConsumer.java: ## @@ -562,6 +557,13 @@ private static ArgumentParser argParser() { .met

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

2025-03-05 Thread via GitHub
cadonna commented on PR #19121: URL: https://github.com/apache/kafka/pull/19121#issuecomment-2701535257 Call for review: @aliehsaeedii -- 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 specifi

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_r1981866135 ## .asf.yaml: ## @@ -45,3 +45,19 @@ github: squash_commit_message: PR_TITLE_AND_DESC merge: false rebase: false + + protected_branches: +trunk: +

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

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

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

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: 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: 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] 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-18919 Clarify that KafkaPrincipalBuilder classes must also implement KafkaPrincipalSerde [kafka]

2025-03-05 Thread via GitHub
chia7712 merged PR #19104: URL: https://github.com/apache/kafka/pull/19104 -- 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

[PR] KAFKA-18613: Add StreamsGroupHeartbeat handler in the group coordinator [kafka]

2025-03-05 Thread via GitHub
lucasbru opened a new pull request, #19114: URL: https://github.com/apache/kafka/pull/19114 Basic streams group heartbeat handling. The main part of are the unit tests that make sure that we behave, for the most part, like a consumer group. - No support for static membership - No s

Re: [PR] MINOR: KAFKA-18876 4.0 docs follow-up (2) [kafka]

2025-03-05 Thread via GitHub
mingdaoy commented on code in PR #19107: URL: https://github.com/apache/kafka/pull/19107#discussion_r1981577358 ## docs/ops.html: ## @@ -3965,7 +3965,7 @@ The kafka-metadata-shell.sh tool can be used to interactively inspect the state of the cluster metadata partition: - $ b

  1   2   3   >