[jira] [Resolved] (KAFKA-19573) Update num.recovery.threads.per.data.dir configs

2025-08-06 Thread Luke Chen (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Luke Chen resolved KAFKA-19573. --- Resolution: Fixed > Update num.recovery.threads.per.data.dir configs > -

Re: [PR] KAFKA-19573: Update num.recovery.threads.per.data.dir configs [kafka]

2025-08-06 Thread via GitHub
showuon merged PR #20299: URL: https://github.com/apache/kafka/pull/20299 -- 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-18836 Make ConsumerGroupMetadata an interface [kafka]

2025-08-06 Thread via GitHub
github-actions[bot] commented on PR #18977: URL: https://github.com/apache/kafka/pull/18977#issuecomment-3162355509 This PR is being marked as stale since it has not had any activity in 90 days. If you would like to keep this PR alive, please leave a comment asking for a review. If the P

Re: [PR] Kafka 16801 FIx Streams upgrade :test target doesn't find any junit tests [kafka]

2025-08-06 Thread via GitHub
github-actions[bot] commented on PR #20260: URL: https://github.com/apache/kafka/pull/20260#issuecomment-3162317516 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] Fix IllegalStateException for Transaction Producer [kafka]

2025-08-06 Thread via GitHub
github-actions[bot] commented on PR #19204: URL: https://github.com/apache/kafka/pull/19204#issuecomment-3162318873 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-18171: Unexpected Change in bootstrap.servers Behavior After Upgrade to 3.8.0 [kafka]

2025-08-06 Thread via GitHub
github-actions[bot] commented on PR #18706: URL: https://github.com/apache/kafka/pull/18706#issuecomment-3162319226 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-19299: Fix race condition in RemoteIndexCacheTest [kafka]

2025-08-06 Thread via GitHub
github-actions[bot] commented on PR #19927: URL: https://github.com/apache/kafka/pull/19927#issuecomment-3162318069 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

[PR] KAFKA-16926: Optimize BeginQuorumEpoch heartbeat [kafka]

2025-08-06 Thread via GitHub
TaiJuWu opened a new pull request, #20318: URL: https://github.com/apache/kafka/pull/20318 Instead of sending out BeginQuorum requests to every voter on a cadence, we can save on some requests by only sending to those which have not fetched within the fetch timeout. -- This is an automat

[jira] [Assigned] (KAFKA-16926) Optimize BeginQuorumEpoch heartbeat

2025-08-06 Thread TaiJuWu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-16926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TaiJuWu reassigned KAFKA-16926: --- Assignee: TaiJuWu (was: Quoc Phong Dang) > Optimize BeginQuorumEpoch heartbeat > -

Re: [PR] KAFKA-19259: Async consumer fetch intermittent delays on console consumer [kafka]

2025-08-06 Thread via GitHub
kirktrue commented on PR #19980: URL: https://github.com/apache/kafka/pull/19980#issuecomment-3162066628 Here are some preliminary results: | Metric | CLASSIC (trunk) | CONSUMER (trunk) | CONSUMER (branch)| |:---|---

[jira] [Created] (KAFKA-19584) Native docker image authentication fails with SASL PLAIN

2025-08-06 Thread Rob Young (Jira)
Rob Young created KAFKA-19584: - Summary: Native docker image authentication fails with SASL PLAIN Key: KAFKA-19584 URL: https://issues.apache.org/jira/browse/KAFKA-19584 Project: Kafka Issue Type

[jira] [Created] (KAFKA-19583) Native docker image fails to start when using SASL OAUTHBEARER mechanism

2025-08-06 Thread Rob Young (Jira)
Rob Young created KAFKA-19583: - Summary: Native docker image fails to start when using SASL OAUTHBEARER mechanism Key: KAFKA-19583 URL: https://issues.apache.org/jira/browse/KAFKA-19583 Project: Kafka

Re: [PR] MINOR: retry upon missing source topic [kafka]

2025-08-06 Thread via GitHub
mjsax merged PR #20284: URL: https://github.com/apache/kafka/pull/20284 -- 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-19078: Automatic controller addition to cluster metadata partition [kafka]

2025-08-06 Thread via GitHub
jsancio commented on code in PR #19589: URL: https://github.com/apache/kafka/pull/19589#discussion_r2258341169 ## raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java: ## @@ -3271,13 +3317,46 @@ private long pollFollowerAsVoter(FollowerState state, long currentTimeMs)

[jira] [Updated] (KAFKA-4007) Improve fetch pipelining for low values of max.poll.records

2025-08-06 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-4007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Lianet Magrans updated KAFKA-4007: -- Component/s: clients > Improve fetch pipelining for low values of max.poll.records > --

Re: [PR] KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry [kafka]

2025-08-06 Thread via GitHub
k-raina commented on code in PR #20144: URL: https://github.com/apache/kafka/pull/20144#discussion_r2258086094 ## clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java: ## @@ -713,14 +716,20 @@ private Optional> createPushRequest(ClientT

Re: [PR] KAFKA-18884: Move TransactionMetadata to transaction-coordinator module [kafka]

2025-08-06 Thread via GitHub
jolshan commented on PR #19699: URL: https://github.com/apache/kafka/pull/19699#issuecomment-3161284148 @FrankYang0529 @chia7712 How are things going here? I can help review if we need to get it over the line. cc: @artemlivshits @rreddy-22 -- This is an automated message from the

Re: [PR] KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry [kafka]

2025-08-06 Thread via GitHub
k-raina commented on code in PR #20144: URL: https://github.com/apache/kafka/pull/20144#discussion_r2258038334 ## clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java: ## @@ -379,14 +382,25 @@ public Optional> createRequest() {

Re: [PR] KAFKA-19506 : Implement dynamic compression type selection and fallback for client telemetry [kafka]

2025-08-06 Thread via GitHub
apoorvmittal10 commented on code in PR #20144: URL: https://github.com/apache/kafka/pull/20144#discussion_r2257849303 ## clients/src/main/java/org/apache/kafka/common/telemetry/internals/ClientTelemetryReporter.java: ## @@ -713,14 +716,20 @@ private Optional> createPushRequest(

[jira] [Commented] (KAFKA-19558) kafka-consumer-groups.sh --describe --all-groups command times out on large clusters with many consumer groups

2025-08-06 Thread Ranuga Disansa (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18012411#comment-18012411 ] Ranuga Disansa commented on KAFKA-19558: hi, i am looking into this, i will give

[jira] [Assigned] (KAFKA-19558) kafka-consumer-groups.sh --describe --all-groups command times out on large clusters with many consumer groups

2025-08-06 Thread Ranuga Disansa (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ranuga Disansa reassigned KAFKA-19558: -- Assignee: Ranuga Disansa > kafka-consumer-groups.sh --describe --all-groups command t

Re: [PR] [Work in progress] [KAFKA-19174] Gradle version upgrade 8 -->> 9 [kafka]

2025-08-06 Thread via GitHub
chia7712 commented on PR #19513: URL: https://github.com/apache/kafka/pull/19513#issuecomment-3160881920 @dejan2609 any update? -- 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 commen

Re: [PR] MINOR: Fix the link for the heading Errant Record Reporter in connect.html [kafka]

2025-08-06 Thread via GitHub
chia7712 merged PR #20313: URL: https://github.com/apache/kafka/pull/20313 -- 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] [Assigned] (KAFKA-19582) the current assignments shown by ReassignPartitionsCommand should include the log directories

2025-08-06 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-19582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] 黃竣陽 reassigned KAFKA-19582: --- Assignee: 黃竣陽 (was: Chia-Ping Tsai) > the current assignments shown by ReassignPartitionsCommand should in

Re: [PR] KAFKA-19572: Added check to prevent NPE logs during ShareConsumer::close [kafka]

2025-08-06 Thread via GitHub
apoorvmittal10 commented on code in PR #20290: URL: https://github.com/apache/kafka/pull/20290#discussion_r2256984922 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/ShareConsumerImpl.java: ## @@ -895,12 +895,14 @@ private void close(final Duration timeout,

Re: [PR] KAFKA-19567: Added the check for underlying partition being the leader in delayedShareFetch tryComplete methhod [kafka]

2025-08-06 Thread via GitHub
chirag-wadhwa5 commented on code in PR #20280: URL: https://github.com/apache/kafka/pull/20280#discussion_r2257665532 ## core/src/test/java/kafka/server/share/DelayedShareFetchTest.java: ## @@ -1761,6 +1859,16 @@ public void testRemoteStorageFetchHappensForAllTopicPartitions()

Re: [PR] KAFKA-16996: Fix leastLoadedNode to avoid selecting faulty nodes [kafka]

2025-08-06 Thread via GitHub
Programmer-RD-AI commented on code in PR #20213: URL: https://github.com/apache/kafka/pull/20213#discussion_r2257666156 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/ClassicKafkaConsumer.java: ## @@ -1283,6 +1292,48 @@ private void updateLastSeenEpochIfNew

[jira] [Assigned] (KAFKA-19582) the current assignments shown by ReassignPartitionsCommand should include the log directories

2025-08-06 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai reassigned KAFKA-19582: -- Assignee: Chia-Ping Tsai > the current assignments shown by ReassignPartitionsCommand

[jira] [Updated] (KAFKA-19582) the current assignments shown by ReassignPartitionsCommand should include the log directories

2025-08-06 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai updated KAFKA-19582: --- Issue Type: Bug (was: Improvement) > the current assignments shown by ReassignPartitionsCom

[jira] [Created] (KAFKA-19582) the current assignments shown by ReassignPartitionsCommand should include the log directories

2025-08-06 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-19582: -- Summary: the current assignments shown by ReassignPartitionsCommand should include the log directories Key: KAFKA-19582 URL: https://issues.apache.org/jira/browse/KAFKA-19582

Re: [PR] MINOR: cleanup in QuotaFactory [kafka]

2025-08-06 Thread via GitHub
chia7712 merged PR #20312: URL: https://github.com/apache/kafka/pull/20312 -- 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-15599: Move KafkaMetadataLog to the raft module [kafka]

2025-08-06 Thread via GitHub
mimaison commented on PR #19762: URL: https://github.com/apache/kafka/pull/19762#issuecomment-3160754449 @jsancio Can you take another look? Thanks -- 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

[PR] KAFKA-18068: Fix the typo `PARTITIONER_ADPATIVE_PARTITIONING_ENABLE` in ProducerConfig [kafka]

2025-08-06 Thread via GitHub
mingyen066 opened a new pull request, #20317: URL: https://github.com/apache/kafka/pull/20317 Fixes a typo in ProducerConfig: Renames `PARTITIONER_ADPATIVE_PARTITIONING_ENABLE_CONFIG` → `PARTITIONER_ADAPTIVE_PARTITIONING_ENABLE_CONFIG` The old key is retained for backward co

Re: [PR] KAFKA-7883 add schema.namespace support to SetSchemaMetadata SMT in Kafka Connect [kafka]

2025-08-06 Thread via GitHub
MartinJohannessen commented on PR #11442: URL: https://github.com/apache/kafka/pull/11442#issuecomment-3160650045 Guys, please. I need this. I'm having to literally make a hundred individual worker configurations instead of one, because I don't have this. -- This is an automated message f

Re: [PR] MINOR: cleanup in QuotaFactory [kafka]

2025-08-06 Thread via GitHub
chia7712 commented on code in PR #20312: URL: https://github.com/apache/kafka/pull/20312#discussion_r2257546961 ## core/src/main/java/kafka/server/QuotaFactory.java: ## @@ -51,61 +51,14 @@ public void record(long value) { } }; -public static class QuotaManage

Re: [PR] KAFKA-18105 Fix flaky PlaintextAdminIntegrationTest#testElectPreferredLeaders [kafka]

2025-08-06 Thread via GitHub
jim0987795064 commented on code in PR #20068: URL: https://github.com/apache/kafka/pull/20068#discussion_r2257295892 ## core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala: ## @@ -2850,6 +2851,33 @@ class PlaintextAdminIntegrationTest extends BaseAdmin

Re: [PR] MINOR: Add test coverage for StorageTool format command feature validation [kafka]

2025-08-06 Thread via GitHub
sjhajharia commented on PR #20303: URL: https://github.com/apache/kafka/pull/20303#issuecomment-3159921077 ccL: @jolshan as you authored KIP-1022 PRs. -- 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

Re: [PR] MINOR: Migrate EligibleLeaderReplicasIntegrationTest to use new test infra [kafka]

2025-08-06 Thread via GitHub
jim0987795064 commented on PR #20199: URL: https://github.com/apache/kafka/pull/20199#issuecomment-3159776077 > @jim0987795064 could you please fix the conflicts Thanks for this comment, I've already fixed this conflicts -- This is an automated message from the Apache Git Service. T

[jira] [Assigned] (KAFKA-17243) MetadataQuorumCommand describe to include CommittedVoters

2025-08-06 Thread TaiJuWu (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] TaiJuWu reassigned KAFKA-17243: --- Assignee: TaiJuWu (was: Chu Cheng Li) > MetadataQuorumCommand describe to include CommittedVoters

Re: [PR] KAFKA-19481: Fix flaky test testConsumerGroupHeartbeatWithRegex [kafka]

2025-08-06 Thread via GitHub
jmmonte2 commented on PR #20298: URL: https://github.com/apache/kafka/pull/20298#issuecomment-3160143725 @squah-confluent Thank you! I noticed the approval did not go through due to lack of write access. Do you have another reviewer I can add on? -- This is an automated message from the

Re: [PR] KAFKA-19020: Handle strict max fetch records in share fetch [kafka]

2025-08-06 Thread via GitHub
apoorvmittal10 commented on PR #20246: URL: https://github.com/apache/kafka/pull/20246#issuecomment-3160029498 @JimmyWang6 I think we should support both i.e. current and strict functionality. That means if the acquire method is called with acquire mode as `strict` then we should only acqui

Re: [PR] KAFKA-19567: Added the check for underlying partition being the leader in delayedShareFetch tryComplete methhod [kafka]

2025-08-06 Thread via GitHub
apoorvmittal10 commented on code in PR #20280: URL: https://github.com/apache/kafka/pull/20280#discussion_r2257007459 ## core/src/main/java/kafka/server/share/DelayedShareFetch.java: ## @@ -368,6 +368,12 @@ public boolean tryComplete() { "topic partition

[PR] KAFKA-18265: Move persister call outside of the lock (3/N) [kafka]

2025-08-06 Thread via GitHub
apoorvmittal10 opened a new pull request, #20316: URL: https://github.com/apache/kafka/pull/20316 Minor PR to move persister call outside of the lock. The lock is not required while making the persister call. -- This is an automated message from the Apache Git Service. To respond to the m

[PR] KAFKA-19464: Remove unnecessary update for find next fetch offset [kafka]

2025-08-06 Thread via GitHub
apoorvmittal10 opened a new pull request, #20315: URL: https://github.com/apache/kafka/pull/20315 The PR removes unnecessary updates for find next fetch offset. When the state is in transition and not yet completed then anyways respective offsets should not be considered for acquisition. Th

[jira] [Comment Edited] (KAFKA-19012) Messages ending up on the wrong topic

2025-08-06 Thread Krzysztof Barczynski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18012357#comment-18012357 ] Krzysztof Barczynski edited comment on KAFKA-19012 at 8/6/25 11:41 AM: ---

[jira] [Commented] (KAFKA-19012) Messages ending up on the wrong topic

2025-08-06 Thread Krzysztof Barczynski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18012357#comment-18012357 ] Krzysztof Barczynski commented on KAFKA-19012: -- Today we experienced the sa

[jira] [Updated] (KAFKA-19012) Messages ending up on the wrong topic

2025-08-06 Thread Krzysztof Barczynski (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Krzysztof Barczynski updated KAFKA-19012: - Attachment: image-2025-08-06-13-34-30-830.png > Messages ending up on the wrong

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

2025-08-06 Thread via GitHub
sjhajharia commented on PR #20214: URL: https://github.com/apache/kafka/pull/20214#issuecomment-3159376019 Thank you @chia7712 for the review. I have addressed the same. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

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

2025-08-06 Thread via GitHub
sjhajharia commented on code in PR #20214: URL: https://github.com/apache/kafka/pull/20214#discussion_r2256733952 ## trogdor/src/main/java/org/apache/kafka/trogdor/workload/PartitionsSpec.java: ## @@ -84,7 +83,9 @@ public List partitionNumbers() { } ret

[jira] [Resolved] (KAFKA-19502) During write state call processing, a batch can be split into offsets which is not accounted for

2025-08-06 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19502?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Apoorv Mittal resolved KAFKA-19502. --- Fix Version/s: 4.2.0 Resolution: Not A Problem > During write state call processing,

[jira] [Commented] (KAFKA-19502) During write state call processing, a batch can be split into offsets which is not accounted for

2025-08-06 Thread Apoorv Mittal (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18012331#comment-18012331 ] Apoorv Mittal commented on KAFKA-19502: --- Closing this ticket as LSO can't be moved

Re: [PR] PoC: Add `rewrite` support for `RemoveUnusedImports` [kafka]

2025-08-06 Thread via GitHub
Pankraz76 commented on PR #20314: URL: https://github.com/apache/kafka/pull/20314#issuecomment-3158121526 ``` > Task :rewriteDryRun No recipes were activated. Activate a recipe with rewrite.activeRecipe("com.fully.qualified.RecipeClassName") in your build file, or on the command line

Re: [PR] PoC: Add `rewrite` support for `errorprone.refasterrules` [kafka]

2025-08-06 Thread via GitHub
Pankraz76 commented on PR #20219: URL: https://github.com/apache/kafka/pull/20219#issuecomment-3158149355 kindly request some feedback on enabler: - https://github.com/apache/kafka/pull/20314 -- This is an automated message from the Apache Git Service. To respond to the message, ple

[PR] PoC: Add `rewrite` support for `RemoveUnusedImports` [kafka]

2025-08-06 Thread via GitHub
Pankraz76 opened a new pull request, #20314: URL: https://github.com/apache/kafka/pull/20314 enabler for: - https://github.com/apache/kafka/pull/20219 ### PoC: Add `rewrite` support for `errorprone.refasterrules.FileRulesRecipes` trying to automate efforts like:

Re: [PR] MINOR: Align order on gradle command [kafka]

2025-08-06 Thread via GitHub
Pankraz76 commented on PR #20278: URL: https://github.com/apache/kafka/pull/20278#issuecomment-3157819091 reconsider -- 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 uns

Re: [PR] MINOR: Align order on gradle command [kafka]

2025-08-06 Thread via GitHub
Pankraz76 closed pull request #20278: MINOR: Align order on gradle command URL: https://github.com/apache/kafka/pull/20278 -- 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 un

[PR] MINOR: Fix the link for the heading Errant Record Reporter in connect.html [kafka]

2025-08-06 Thread via GitHub
joshua2519 opened a new pull request, #20313: URL: https://github.com/apache/kafka/pull/20313 The link for the heading Errant Record Reporter is missing the # symbol, which is causing it to redirect to a 404 Not Found page. -- This is an automated message from the Apache Git Service. To r