[
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
> ---
[
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)
>
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
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
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
[
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
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
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
[
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
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
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
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
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
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
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
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=
[
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
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
[
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
[
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
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
[
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
[
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
[
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
[
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
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
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()
/
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
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
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
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
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
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
[
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
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
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
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
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
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
[
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
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
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
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
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
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
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
[
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
> ---
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:

> Improve EndToEndLatency
> ---
>
>
[
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
> -
[
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
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
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.
[
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
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
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
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
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
[
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
[
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:
--
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
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
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
[
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
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
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
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
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
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
[
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
[
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
>
[
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
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) {
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
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
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--
[
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]. "
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
[
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
[ 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
[
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
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
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
86 matches
Mail list logo