[jira] [Resolved] (KAFKA-18792) Enforce uniform PR structure for merge queue

2025-03-19 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur resolved KAFKA-18792. -- Resolution: Fixed > Enforce uniform PR structure for merge queue > ---

[jira] [Updated] (KAFKA-19013) Pre-format PR description for merge queue

2025-03-19 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur updated KAFKA-19013: - Summary: Pre-format PR description for merge queue (was: Pre-format PR body for merge queue) >

Re: [PR] KAFKA-18975: Move clients-integration-test out of core module [kafka]

2025-03-19 Thread via GitHub
FrankYang0529 commented on PR #19217: URL: https://github.com/apache/kafka/pull/19217#issuecomment-2732538893 @chia7712 @kirktrue , thanks for review. I addressed all comments. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub a

[PR] KAFKA-19013 Reformat PR body to 72 characters [kafka]

2025-03-19 Thread via GitHub
mumrah opened a new pull request, #19242: URL: https://github.com/apache/kafka/pull/19242 Delete this text and replace it with a detailed description of your change. The PR title and body will become the squashed commit message. If you would like to tag individuals, add some comme

Re: [PR] KAFKA-19013 Reformat PR body to 72 characters [kafka]

2025-03-19 Thread via GitHub
mumrah commented on PR #19242: URL: https://github.com/apache/kafka/pull/19242#issuecomment-2737080357 To test this out, checkout the PR and run the following: ``` PR_NUMBER=19071 python .github/scripts/pr-format.py ``` ⚠️ Do not run with GITHUB_ACTIONS set, or it will act

[jira] [Commented] (KAFKA-14579) Move DumpLogSegments to tools

2025-03-19 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-14579?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936870#comment-17936870 ] Mickael Maison commented on KAFKA-14579: [~taijuwu] At the moment DumpLogSegment

[PR] MINOR: refactoring periodic tasks to wrap a ControllerWriteOperation [kafka]

2025-03-19 Thread via GitHub
kevin-wu24 opened a new pull request, #19245: URL: https://github.com/apache/kafka/pull/19245 Refactor periodic tasks framework to wrap a `ControllerWriteOperation`, not just a `Supplier>`. -- This is an automated message from the Apache Git Service. To respond to the message, please

Re: [PR] KAFKA-14486: Move LogCleanerManager to storage module [kafka]

2025-03-19 Thread via GitHub
mimaison commented on code in PR #19216: URL: https://github.com/apache/kafka/pull/19216#discussion_r2003823244 ## core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala: ## @@ -1,886 +0,0 @@ -/** Review Comment: The approach we have taken so far is to not migrate th

[jira] [Commented] (KAFKA-18648) kafka-python requires metadata request version 0

2025-03-19 Thread Dana Powers (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936892#comment-17936892 ] Dana Powers commented on KAFKA-18648: - kafka-python latest release now supports 2.1

[PR] MINOR: Add 4.0.0 to core system tests [kafka]

2025-03-19 Thread via GitHub
dajac opened a new pull request, #19238: URL: https://github.com/apache/kafka/pull/19238 This patch updates all the core system tests to include 4.0.0. -- 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

Re: [PR] MINOR: Add 4.0.0 to core system tests [kafka]

2025-03-19 Thread via GitHub
dajac commented on PR #19238: URL: https://github.com/apache/kafka/pull/19238#issuecomment-2735604472 I have triggered a run of the system tests. I will post the results when they are done. -- This is an automated message from the Apache Git Service. To respond to the message, please log

[PR] MINOR: Add 4.0.0 to streams system tests [kafka]

2025-03-19 Thread via GitHub
dajac opened a new pull request, #19239: URL: https://github.com/apache/kafka/pull/19239 This patch adds 4.0.0 to streams system tests. -- 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

[PR] KAFKA-18845: Fix flaky QuorumControllerTest#testUncleanShutdownBrokerElrEnabled [kafka]

2025-03-19 Thread via GitHub
FrankYang0529 opened a new pull request, #19240: URL: https://github.com/apache/kafka/pull/19240 There're two root causes: 1. When we unclean shutdown `brokerToBeTheLeader`, we didn't wait for the result. That means when we send heartbeat to unfence broker, it has chance to use stale bro

[jira] [Created] (KAFKA-19011) Improve EndToEndLatency

2025-03-19 Thread Chia-Ping Tsai (Jira)
Chia-Ping Tsai created KAFKA-19011: -- Summary: Improve EndToEndLatency Key: KAFKA-19011 URL: https://issues.apache.org/jira/browse/KAFKA-19011 Project: Kafka Issue Type: Improvement

Re: [PR] KAFKA-17774: Adding capability to handle max fetch records in Share Fetch (KIP-932) [kafka]

2025-03-19 Thread via GitHub
chia7712 commented on code in PR #17322: URL: https://github.com/apache/kafka/pull/17322#discussion_r2004253095 ## core/src/main/java/kafka/server/share/SharePartition.java: ## @@ -1658,6 +1706,26 @@ private long findLastOffsetAcknowledged() { return lastOffsetAcknowled

Re: [PR] MINOR Capture heap dump after OOM on CI [kafka]

2025-03-19 Thread via GitHub
chia7712 commented on code in PR #19031: URL: https://github.com/apache/kafka/pull/19031#discussion_r2004316995 ## .github/actions/run-gradle/action.yml: ## @@ -96,9 +99,11 @@ runs: -Pkafka.test.xml.output.dir=$TEST_XML_OUTPUT_DIR \ -Pkafka.cluster.test.repeat=

[jira] [Commented] (KAFKA-18713) Kafka Streams Left-Join not always emitting the last value

2025-03-19 Thread Stanislav Spiridonov (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936944#comment-17936944 ] Stanislav Spiridonov commented on KAFKA-18713: -- Good news, but how is it sa

[PR] MINOR: Specify 2.1 as the minimum broker version for clients [kafka]

2025-03-19 Thread via GitHub
ijuma opened a new pull request, #19250: URL: https://github.com/apache/kafka/pull/19250 (no comment) -- 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] [Commented] (KAFKA-18648) kafka-python requires metadata request version 0

2025-03-19 Thread Ismael Juma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18648?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936893#comment-17936893 ] Ismael Juma commented on KAFKA-18648: - That's great [~dana.powers]. Thanks! > kafka

[jira] [Updated] (KAFKA-19014) Potential race condition in remote-log-reader and remote-log-index-cleaner thread

2025-03-19 Thread Hasil Sharma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hasil Sharma updated KAFKA-19014: - Labels: tiered-storage (was: ) > Potential race condition in remote-log-reader and remote-log-i

[jira] [Created] (KAFKA-19014) Potential race condition in remote-log-reader and remote-log-index-cleaner thread

2025-03-19 Thread Hasil Sharma (Jira)
Hasil Sharma created KAFKA-19014: Summary: Potential race condition in remote-log-reader and remote-log-index-cleaner thread Key: KAFKA-19014 URL: https://issues.apache.org/jira/browse/KAFKA-19014 Pro

[jira] [Updated] (KAFKA-19014) Potential race condition in remote-log-reader and remote-log-index-cleaner thread

2025-03-19 Thread Hasil Sharma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hasil Sharma updated KAFKA-19014: - Summary: Potential race condition in remote-log-reader and remote-log-index-cleaner thread (was

[jira] [Updated] (KAFKA-19014) Potential race condition in remote-log-reader and remote-log-index-cleaner thread + MappedByteBuffer misuse

2025-03-19 Thread Hasil Sharma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hasil Sharma updated KAFKA-19014: - Summary: Potential race condition in remote-log-reader and remote-log-index-cleaner thread + Map

[jira] [Updated] (KAFKA-19014) Potential race condition in remote-log-reader and remote-log-index-cleaner thread

2025-03-19 Thread Hasil Sharma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hasil Sharma updated KAFKA-19014: - Description: A race condition between threads below results in MappedByteBuffer to reference to

[jira] [Updated] (KAFKA-19014) Potential race condition in remote-log-reader and remote-log-index-cleaner thread

2025-03-19 Thread Hasil Sharma (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hasil Sharma updated KAFKA-19014: - Description: A race condition between threads below results in MappedByteBuffer to reference to

Re: [PR] KAFKA-18893: KIP-877 Add support for ReplicaSelector [kafka]

2025-03-19 Thread via GitHub
mimaison commented on code in PR #19064: URL: https://github.com/apache/kafka/pull/19064#discussion_r2004270758 ## core/src/main/scala/kafka/server/ReplicaManager.scala: ## @@ -1723,7 +1723,7 @@ class ReplicaManager(val config: KafkaConfig, metadata => findPreferredRe

Re: [PR] KAFKA-17182: Consumer fetch sessions are evicted too quickly with AsyncKafkaConsumer [kafka]

2025-03-19 Thread via GitHub
junrao commented on code in PR #18795: URL: https://github.com/apache/kafka/pull/18795#discussion_r2004442106 ## clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractFetch.java: ## @@ -432,7 +439,14 @@ protected Map prepareFetchRequests() /

[PR] KAFKA-6416: Helm chart for deploying Kafka to Kubernetes [kafka]

2025-03-19 Thread via GitHub
askew opened a new pull request, #19249: URL: https://github.com/apache/kafka/pull/19249 This PR adds a [Helm][helm] chart for deploying [Kafka][Kafka] to [Kubernetes][Kubernetes]. It is designed to run brokers and controllers in separate pods. All the configuration is template

Re: [PR] KAFKA-15303: Avoid unnecessary re-serialization in FK-join [kafka]

2025-03-19 Thread via GitHub
patronovski commented on PR #14157: URL: https://github.com/apache/kafka/pull/14157#issuecomment-2738670306 Any updates on this? -- 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 comme

Re: [PR] KAFKA-806: Index may not always observe log.index.interval.bytes (#18012) [kafka]

2025-03-19 Thread via GitHub
FrankYang0529 commented on PR #18842: URL: https://github.com/apache/kafka/pull/18842#issuecomment-2738881180 Rebased it. 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 the specific comm

Re: [PR] KAFKA-17900:Consider async resolution for client-side regex in new consumer [kafka]

2025-03-19 Thread via GitHub
github-actions[bot] closed pull request #17769: KAFKA-17900:Consider async resolution for client-side regex in new consumer URL: https://github.com/apache/kafka/pull/17769 -- 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] MINOR: Specify 2.1 as the minimum broker version for clients [kafka]

2025-03-19 Thread via GitHub
ijuma commented on code in PR #19250: URL: https://github.com/apache/kafka/pull/19250#discussion_r2004796472 ## clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java: ## @@ -157,24 +157,19 @@ * their ProducerRecord into bytes. You can use the included {@l

[jira] [Created] (KAFKA-19015) Remove share session from cache on connection drop

2025-03-19 Thread Andrew Schofield (Jira)
Andrew Schofield created KAFKA-19015: Summary: Remove share session from cache on connection drop Key: KAFKA-19015 URL: https://issues.apache.org/jira/browse/KAFKA-19015 Project: Kafka Is

[jira] [Assigned] (KAFKA-19015) Remove share session from cache on connection drop

2025-03-19 Thread Andrew Schofield (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield reassigned KAFKA-19015: Assignee: Chirag Wadhwa (was: Andrew Schofield) > Remove share session from cach

Re: [PR] MINOR: Optimize the 'waitForVerifyAssignment' method log output [kafka]

2025-03-19 Thread via GitHub
github-actions[bot] closed pull request #17753: MINOR: Optimize the 'waitForVerifyAssignment' method log output URL: https://github.com/apache/kafka/pull/17753 -- 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

Re: [PR] MINOR: Specify 2.1 as the minimum broker version for clients [kafka]

2025-03-19 Thread via GitHub
ijuma commented on code in PR #19250: URL: https://github.com/apache/kafka/pull/19250#discussion_r2004796009 ## clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java: ## @@ -138,14 +138,14 @@ * the batch.size config. Making this larger can result in more

Re: [PR] MINOR: Add 4.0.0 to core system tests [kafka]

2025-03-19 Thread via GitHub
dajac commented on PR #19238: URL: https://github.com/apache/kafka/pull/19238#issuecomment-2739388016 Here is the result of all the system tests: https://confluent-open-source-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/trunk/2025-03-19--001.525166ce-17a5-49d0-a2c3-97

Re: [PR] MINOR: Add 4.0.0 to streams system tests [kafka]

2025-03-19 Thread via GitHub
mjsax commented on code in PR #19239: URL: https://github.com/apache/kafka/pull/19239#discussion_r2004815971 ## streams/upgrade-system-tests-40/src/test/java/org/apache/kafka/streams/tests/StreamsUpgradeTest.java: ## @@ -0,0 +1,120 @@ +/* + * Licensed to the Apache Software Foun

Re: [PR] KAFKA-18966: Change controller_num_nodes_override to override_num_isolated_controllers [kafka]

2025-03-19 Thread via GitHub
chia7712 commented on code in PR #19194: URL: https://github.com/apache/kafka/pull/19194#discussion_r2004167256 ## tests/kafkatest/services/kafka/kafka.py: ## @@ -330,7 +327,7 @@ def __init__(self, context, num_nodes, zk, security_protocol=SecurityConfig.PLAI if se

[jira] [Resolved] (KAFKA-18745) Handle the disconnected inter broker RPC calls within the persister

2025-03-19 Thread Andrew Schofield (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrew Schofield resolved KAFKA-18745. -- Resolution: Fixed > Handle the disconnected inter broker RPC calls within the persiste

Re: [PR] Kafka-18914 Migrate ConsumerRebootstrapTest to use new test infra [kafka]

2025-03-19 Thread via GitHub
github-actions[bot] commented on PR #19154: URL: https://github.com/apache/kafka/pull/19154#issuecomment-2739024549 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: Specify 2.1 as the minimum broker version for clients [kafka]

2025-03-19 Thread via GitHub
ijuma commented on code in PR #19250: URL: https://github.com/apache/kafka/pull/19250#discussion_r2004798260 ## clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java: ## @@ -636,8 +632,6 @@ private TransactionManager configureTransactionState(ProducerConfig

Re: [PR] MINOR: Specify 2.1 as the minimum broker version for clients [kafka]

2025-03-19 Thread via GitHub
ijuma commented on PR #19250: URL: https://github.com/apache/kafka/pull/19250#issuecomment-2739125388 This needs to be cherry-picked to the 4.0 branch. -- 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 g

Re: [PR] [WIP] KAFKA-18279: add JDK 11 check and test for clients and streams module [kafka]

2025-03-19 Thread via GitHub
github-actions[bot] commented on PR #19196: URL: https://github.com/apache/kafka/pull/19196#issuecomment-2739024498 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: Specify 2.1 as the minimum broker version for clients [kafka]

2025-03-19 Thread via GitHub
ijuma commented on code in PR #19250: URL: https://github.com/apache/kafka/pull/19250#discussion_r2004795817 ## clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java: ## @@ -61,9 +61,9 @@ * The consumer is not thread-safe. See Multi-threaded Processing for

Re: [PR] KAFKA-16616: refactor mergeWith and updatePartitionLeadership [kafka]

2025-03-19 Thread via GitHub
lorcanj commented on code in PR #19199: URL: https://github.com/apache/kafka/pull/19199#discussion_r2004922608 ## clients/src/main/java/org/apache/kafka/clients/MetadataSnapshot.java: ## @@ -173,12 +173,15 @@ MetadataSnapshot mergeWith(String newClusterId, Map newMeta

[jira] [Assigned] (KAFKA-17045) Move MetadataLogConfig from kafka to kafka.raft

2025-03-19 Thread PoAn Yang (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-17045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] PoAn Yang reassigned KAFKA-17045: - Assignee: PoAn Yang > Move MetadataLogConfig from kafka to kafka.raft > ---

[PR] KAFKA-19008 Remove scala version from artifacts [kafka]

2025-03-19 Thread via GitHub
m1a2st opened a new pull request, #19241: URL: https://github.com/apache/kafka/pull/19241 We can remove the Scala version from the artifacts. Since Maven artifacts have compatibility concerns, we will only update the tarball. Test in my local machine: ![image](https://github.com/u

[jira] [Commented] (KAFKA-19011) Improve EndToEndLatency

2025-03-19 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936756#comment-17936756 ] Chia-Ping Tsai commented on KAFKA-19011: I add "need-kip" label as we need to ke

Re: [PR] KAFKA-18893: KIP-877 Add support for ReplicaSelector [kafka]

2025-03-19 Thread via GitHub
mimaison commented on code in PR #19064: URL: https://github.com/apache/kafka/pull/19064#discussion_r2003090541 ## core/src/main/scala/kafka/server/ReplicaManager.scala: ## @@ -1723,7 +1723,7 @@ class ReplicaManager(val config: KafkaConfig, metadata => findPreferredRe

Re: [PR] KAFKA-15931: Cancel RemoteLogReader gracefully [kafka]

2025-03-19 Thread via GitHub
jeqo commented on code in PR #19197: URL: https://github.com/apache/kafka/pull/19197#discussion_r2002944925 ## core/src/main/scala/kafka/server/ReplicaManager.scala: ## @@ -1558,7 +1559,7 @@ class ReplicaManager(val config: KafkaConfig, } val remoteFetchMaxWaitMs =

[jira] [Assigned] (KAFKA-19011) Improve EndToEndLatency

2025-03-19 Thread Nick Guo (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nick Guo reassigned KAFKA-19011: Assignee: Nick Guo (was: Chia-Ping Tsai) > Improve EndToEndLatency > --- > >

[jira] [Updated] (KAFKA-19001) Use streams group-level configurations in heartbeat

2025-03-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated KAFKA-19001: Component/s: streams > Use streams group-level configurations in heartbeat > -

[jira] [Commented] (KAFKA-18713) Kafka Streams Left-Join not always emitting the last value

2025-03-19 Thread Matthias J. Sax (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936734#comment-17936734 ] Matthias J. Sax commented on KAFKA-18713: - With 4.0.0 being release now, it is v

Re: [PR] KAFKA-17747: Trigger rebalance on rack topology changes [kafka]

2025-03-19 Thread via GitHub
FrankYang0529 commented on PR #17444: URL: https://github.com/apache/kafka/pull/17444#issuecomment-2736526416 Hi @dajac, if there is no other discussion about [KIP-1101](https://cwiki.apache.org/confluence/display/KAFKA/KIP-1101%3A+Trigger+rebalance+on+rack+topology+changes), I would like t

Re: [PR] KAFKA-18953: [1/N] Add broker side handling for 2 PC (KIP-939) [kafka]

2025-03-19 Thread via GitHub
jolshan merged PR #19193: URL: https://github.com/apache/kafka/pull/19193 -- 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] [Reopened] (KAFKA-18776) Flaky testMarkCoordinatorUnknownLoggingAccuracy

2025-03-19 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Arthur reopened KAFKA-18776: -- The flakiness has regressed https://develocity.apache.org/scans/tests?search.relativeStartTime=P2

Re: [PR] MINOR Mark CoordinatorRequestManagerTest as flaky [kafka]

2025-03-19 Thread via GitHub
mumrah commented on PR #19248: URL: https://github.com/apache/kafka/pull/19248#issuecomment-2737574709 cc @lianetm -- 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 unsub

[PR] KAFKA-15599: Move MetadataLogConfig to raft module [kafka]

2025-03-19 Thread via GitHub
mimaison opened a new pull request, #19246: URL: https://github.com/apache/kafka/pull/19246 Rewrite the class in Java and move it to the raft module. -- 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

Re: [PR] KAFKA-18989 Optimize FileRecord#searchForOffsetWithSize [kafka]

2025-03-19 Thread via GitHub
chia7712 commented on code in PR #19214: URL: https://github.com/apache/kafka/pull/19214#discussion_r2003894741 ## clients/src/main/java/org/apache/kafka/common/record/FileRecords.java: ## @@ -297,12 +297,33 @@ public int writeTo(TransferableChannel destChannel, int offset, int

[PR] MINOR Mark CoordinatorRequestManagerTest as flaky [kafka]

2025-03-19 Thread via GitHub
mumrah opened a new pull request, #19248: URL: https://github.com/apache/kafka/pull/19248 CoordinatorRequestManagerTest#testMarkCoordinatorUnknownLoggingAccuracy has become flaky again. Last 30 days report shows a sudden re-occurrence https://develocity.apache.org/scans/tests?search.relativ

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

2025-03-19 Thread Donny Nadolny (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936813#comment-17936813 ] Donny Nadolny commented on KAFKA-19012: --- Here's our client config: {code:java} p

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

2025-03-19 Thread Donny Nadolny (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936813#comment-17936813 ] Donny Nadolny edited comment on KAFKA-19012 at 3/19/25 1:23 PM: --

Re: [PR] KAFKA-15931: Cancel RemoteLogReader gracefully [kafka]

2025-03-19 Thread via GitHub
junrao commented on code in PR #19197: URL: https://github.com/apache/kafka/pull/19197#discussion_r2003759304 ## core/src/main/scala/kafka/server/DelayedRemoteFetch.scala: ## @@ -88,8 +90,9 @@ class DelayedRemoteFetch(remoteFetchTask: Future[Void], override def onExpiration

Re: [PR] Support keystore with multiple alias entries [kafka]

2025-03-19 Thread via GitHub
mimaison commented on PR #17560: URL: https://github.com/apache/kafka/pull/17560#issuecomment-2737358418 I commented in your DISCUSS thread on the mailing list: https://lists.apache.org/thread/mwpm54kwjsj9vobzkovwp4r5ts1t4jo0 -- This is an automated message from the Apache Git Service. To

Re: [PR] MINOR: Run CI with Java 24 and update documentation (instead of 23) [kafka]

2025-03-19 Thread via GitHub
mumrah commented on PR #19235: URL: https://github.com/apache/kafka/pull/19235#issuecomment-2737693509 @ijuma yea it looks like `setup-java` could not find an image for temurin 24. I guess we'll need to wait for that as well as Gradle to ship support for 24. I expect it won't take very long

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

2025-03-19 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936923#comment-17936923 ] Lianet Magrans commented on KAFKA-19012: Hello [~dnadolny] , thanks for reportin

Re: [PR] KAFKA-18819 StreamsGroupHeartbeat API and StreamsGroupDescribe API check topic describe [kafka]

2025-03-19 Thread via GitHub
lucasbru merged PR #19183: URL: https://github.com/apache/kafka/pull/19183 -- 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-17078: Add SecurityManagerCompatibility shim (#16522) [kafka]

2025-03-19 Thread via GitHub
chia7712 commented on PR #19221: URL: https://github.com/apache/kafka/pull/19221#issuecomment-2737926586 add 3.9.1 RM (@showuon) as reviewer -- 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 s

Re: [PR] KAFKA-806: Index may not always observe log.index.interval.bytes (#18012) [kafka]

2025-03-19 Thread via GitHub
chia7712 commented on PR #18842: URL: https://github.com/apache/kafka/pull/18842#issuecomment-2737928420 @FrankYang0529 could you rebase code to run CI again? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL abo

Re: [PR] KAFKA-18946: Move BrokerReconfigurable and DynamicProducerStateManagerConfig to server module [kafka]

2025-03-19 Thread via GitHub
chia7712 commented on PR #19174: URL: https://github.com/apache/kafka/pull/19174#issuecomment-2737941001 @frankvicky please fix the conflicts -- 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 s

Re: [PR] KAFKA-14486: Move LogCleanerManager to storage module [kafka]

2025-03-19 Thread via GitHub
wernerdv commented on code in PR #19216: URL: https://github.com/apache/kafka/pull/19216#discussion_r2004183479 ## core/src/test/scala/unit/kafka/log/LogCleanerManagerTest.scala: ## @@ -1,886 +0,0 @@ -/** Review Comment: Done -- This is an automated message from the Apac

[jira] [Commented] (KAFKA-6333) java.awt.headless should not be on commandline

2025-03-19 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-6333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936805#comment-17936805 ] Jakhongir Sabirovь commented on KAFKA-6333: --- [https://github.com/apache/kafka/p

[jira] [Assigned] (KAFKA-6333) java.awt.headless should not be on commandline

2025-03-19 Thread Jira
[ https://issues.apache.org/jira/browse/KAFKA-6333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jakhongir Sabirovь reassigned KAFKA-6333: - Assignee: Jakhongir Sabirovь > java.awt.headless should not be on commandline >

[jira] [Commented] (KAFKA-18792) Enforce uniform PR structure for merge queue

2025-03-19 Thread Mickael Maison (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936878#comment-17936878 ] Mickael Maison commented on KAFKA-18792: Would it be worth to also do some valid

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

2025-03-19 Thread via GitHub
jsancio commented on code in PR #18987: URL: https://github.com/apache/kafka/pull/18987#discussion_r2003697404 ## raft/src/test/java/org/apache/kafka/raft/RaftEventSimulationTest.java: ## @@ -1127,14 +1331,75 @@ private MajorityReachedHighWatermark(Cluster cluster) {

[jira] [Created] (KAFKA-19013) Pre-format PR body for merge queue

2025-03-19 Thread David Arthur (Jira)
David Arthur created KAFKA-19013: Summary: Pre-format PR body for merge queue Key: KAFKA-19013 URL: https://issues.apache.org/jira/browse/KAFKA-19013 Project: Kafka Issue Type: Sub-task

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

2025-03-19 Thread Donny Nadolny (Jira)
Donny Nadolny created KAFKA-19012: - Summary: Messages ending up on the wrong topic Key: KAFKA-19012 URL: https://issues.apache.org/jira/browse/KAFKA-19012 Project: Kafka Issue Type: Bug A

Re: [PR] MINOR: Add 4.0.0 to core system tests [kafka]

2025-03-19 Thread via GitHub
dajac commented on PR #19238: URL: https://github.com/apache/kafka/pull/19238#issuecomment-2737021966 Streams system tests are green: https://confluent-open-source-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/trunk/2025-03-19--001.4c419108-8213-40c5-b5a2-b7507f17ea97--

[jira] [Commented] (KAFKA-18792) Enforce uniform PR structure for merge queue

2025-03-19 Thread David Arthur (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18792?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936903#comment-17936903 ] David Arthur commented on KAFKA-18792: -- Yes I think that makes sense [~mimaison]. "

Re: [PR] KAFKA-18975: Move clients-integration-test out of core module [kafka]

2025-03-19 Thread via GitHub
chia7712 merged PR #19217: URL: https://github.com/apache/kafka/pull/19217 -- 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-18975) Move clients-integration-test out of core module

2025-03-19 Thread Chia-Ping Tsai (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-18975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chia-Ping Tsai resolved KAFKA-18975. Fix Version/s: 4.1.0 Resolution: Fixed > Move clients-integration-test out of core

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

2025-03-19 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19012 ] Lianet Magrans deleted comment on KAFKA-19012: was (Author: JIRAUSER300183): Hello [~dnadolny], thanks for reporting this. Could you please share the client configs and debug/trace logs

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

2025-03-19 Thread Lianet Magrans (Jira)
[ https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17936913#comment-17936913 ] Lianet Magrans commented on KAFKA-19012: Hello [~dnadolny], thanks for reporting

Re: [PR] MINOR: Add 4.0.0 to streams system tests [kafka]

2025-03-19 Thread via GitHub
dajac commented on PR #19239: URL: https://github.com/apache/kafka/pull/19239#issuecomment-2737023479 Steams system tests are green: https://confluent-open-source-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/trunk/2025-03-19--001.4c419108-8213-40c5-b5a2-b7507f17ea97--1

Re: [PR] KAFKA-18845: Fix flaky QuorumControllerTest#testUncleanShutdownBrokerElrEnabled [kafka]

2025-03-19 Thread via GitHub
mumrah commented on code in PR #19240: URL: https://github.com/apache/kafka/pull/19240#discussion_r2004040049 ## metadata/src/test/java/org/apache/kafka/controller/QuorumControllerTest.java: ## @@ -474,24 +475,28 @@ public void testUncleanShutdownBrokerElrEnabled() throws Throw