TaiJuWu commented on PR #19301:
URL: https://github.com/apache/kafka/pull/19301#issuecomment-2760498267
@m1a2st Could you merge trunk to re-trigger CI?
I am not sure why CI fail, it seems unrelated this PR.
--
This is an automated message from the Apache Git Service.
To respond to the m
[
https://issues.apache.org/jira/browse/KAFKA-15873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939136#comment-17939136
]
Lorcan commented on KAFKA-15873:
Hi [~calvinliu], I've created a minor patch that addres
[
https://issues.apache.org/jira/browse/KAFKA-19021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-19021:
---
Fix Version/s: 4.1.0
> Broker should not be allowed to be promoted t
[
https://issues.apache.org/jira/browse/KAFKA-16719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sushant Mahajan resolved KAFKA-16719.
-
Resolution: Fixed
> Add AdminClient.deleteShareGroups
>
gongxuanzhang commented on PR #19226:
URL: https://github.com/apache/kafka/pull/19226#issuecomment-2762049890
I changed this pr @mimaison PTAL
--
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 th
[
https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True reassigned KAFKA-19012:
-
Assignee: Kirk True
> Messages ending up on the wrong topic
> -
[
https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939287#comment-17939287
]
Kirk True commented on KAFKA-19012:
---
Taking this task for investigation.
> Messages e
[
https://issues.apache.org/jira/browse/KAFKA-19036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-19036.
Fix Version/s: 4.1.0
Resolution: Fixed
> Rewrite LogAppendTimeTest and move it to s
chia7712 merged PR #19282:
URL: https://github.com/apache/kafka/pull/19282
--
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
ijuma commented on PR #19235:
URL: https://github.com/apache/kafka/pull/19235#issuecomment-2762347678
@srdo Feel free to submit your own PR if you're further along - I can then
close this one.
--
This is an automated message from the Apache Git Service.
To respond to the message, please l
chia7712 commented on code in PR #19285:
URL: https://github.com/apache/kafka/pull/19285#discussion_r2019137257
##
storage/src/main/java/org/apache/kafka/server/purgatory/DelayedRemoteListOffsets.java:
##
@@ -0,0 +1,198 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
dajac commented on PR #19272:
URL: https://github.com/apache/kafka/pull/19272#issuecomment-2748679705
> @dajac nice find. During review of this patch, I noticed an additional
issue located at
https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/KafkaApis.scala#L1183
dejan2609 commented on PR #19265:
URL: https://github.com/apache/kafka/pull/19265#issuecomment-2761896141
Ok then, code refactoring it is.
--
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 spec
dajac commented on code in PR #18510:
URL: https://github.com/apache/kafka/pull/18510#discussion_r2019012548
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/share/ShareGroupStateMessageFormatterTest.java:
##
@@ -164,12 +164,16 @@ private static Stream exceptions() {
chia7712 merged PR #19268:
URL: https://github.com/apache/kafka/pull/19268
--
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 merged PR #19299:
URL: https://github.com/apache/kafka/pull/19299
--
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 code in PR #19283:
URL: https://github.com/apache/kafka/pull/19283#discussion_r2019200151
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/ConsumerTopicCreationTest.java:
##
@@ -0,0 +1,121 @@
+/*
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/KAFKA-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939288#comment-17939288
]
Kirk True commented on KAFKA-19012:
---
[~dnadolny], gentle reminder about the outstandin
wernerdv commented on PR #18937:
URL: https://github.com/apache/kafka/pull/18937#issuecomment-2761342324
@chia7712 Please review when you have time. This is a small PR removing
unused code.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
johnny94 opened a new pull request, #19306:
URL: https://github.com/apache/kafka/pull/19306
(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-m
mingyen066 commented on code in PR #19177:
URL: https://github.com/apache/kafka/pull/19177#discussion_r2009010075
##
server/src/main/java/org/apache/kafka/server/Assignment.java:
##
@@ -57,6 +96,23 @@ boolean valid(int nodeId, MetadataImage image) {
return Replicas.cont
frankvicky opened a new pull request, #19305:
URL: https://github.com/apache/kafka/pull/19305
This patch does some cleanups for the `test-common-internal-api`.
- `.collect(Collectors.toList())` -> `.toList()`
- lambda block -> lambda expression
- remove unnecessary semicolon
-
frankvicky commented on code in PR #19167:
URL: https://github.com/apache/kafka/pull/19167#discussion_r2018839958
##
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java:
##
@@ -89,7 +89,7 @@ public FetchResponseData data() {
*/
public FetchRespon
srdo opened a new pull request, #19311:
URL: https://github.com/apache/kafka/pull/19311
Please ignore, this is a bundle of other PRs on top of each other in order
to check that they pass CI
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
brandboat commented on PR #18510:
URL: https://github.com/apache/kafka/pull/18510#issuecomment-2761854496
Gentle ping @dajac, CI passed, could you take a look when you are available?
Thank you!
--
This is an automated message from the Apache Git Service.
To respond to the message, please
[
https://issues.apache.org/jira/browse/KAFKA-19048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939267#comment-17939267
]
Greg Harris commented on KAFKA-19048:
-
Hi [~pengjialun] ! Thanks for the ticket and
[
https://issues.apache.org/jira/browse/KAFKA-17120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939337#comment-17939337
]
Matthias J. Sax commented on KAFKA-17120:
-
I am wondering if [https://github.com
mjsax opened a new pull request, #19312:
URL: https://github.com/apache/kafka/pull/19312
After cherry-picking
https://github.com/apache/kafka/commit/2181ddbb039ff688f5ff41784d943cb579f7575c,
we realized that the newly added test does not cover EOSv1. This PR closes
this testing gap.
github-actions[bot] commented on PR #19074:
URL: https://github.com/apache/kafka/pull/19074#issuecomment-2763060963
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
github-actions[bot] commented on PR #19222:
URL: https://github.com/apache/kafka/pull/19222#issuecomment-2763060930
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
github-actions[bot] commented on PR #19236:
URL: https://github.com/apache/kafka/pull/19236#issuecomment-2763060904
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
github-actions[bot] commented on PR #19264:
URL: https://github.com/apache/kafka/pull/19264#issuecomment-2763060865
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
[
https://issues.apache.org/jira/browse/KAFKA-19052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
PoAn Yang reassigned KAFKA-19052:
-
Assignee: PoAn Yang
> Document how to query versioned stores/KTables
>
github-actions[bot] closed pull request #17978: update with reentrant lock
URL: https://github.com/apache/kafka/pull/17978
--
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
srdo commented on PR #19235:
URL: https://github.com/apache/kafka/pull/19235#issuecomment-2762718631
@ijuma I just have the bits I linked above, which is how far I got before
getting roadblocked by Gradle. Feel free to use those bits if they're helpful
for this PR. If not, that's fine too :
junrao commented on code in PR #19167:
URL: https://github.com/apache/kafka/pull/19167#discussion_r2019483491
##
clients/src/main/java/org/apache/kafka/common/requests/FetchResponse.java:
##
@@ -258,6 +258,11 @@ private static FetchResponseData toMessage(Errors error,
srdo opened a new pull request, #19308:
URL: https://github.com/apache/kafka/pull/19308
…for JDK 23 (3.9 backport)
Cherry picked from commit a880c846ae3d786f8f3259b34dadfecf0b2d0d06
--
This is an automated message from the Apache Git Service.
To respond to the message, please lo
srdo opened a new pull request, #19309:
URL: https://github.com/apache/kafka/pull/19309
…ocessor and DistributedHerder) for JDK 23 (3.9 backport)
Cherry picked from commit 2353a7c5081b53402d5092afd255e2bdf7aa2d20
--
This is an automated message from the Apache Git Service.
To respon
srdo opened a new pull request, #19307:
URL: https://github.com/apache/kafka/pull/19307
cherry picked from commit 9cb49092f0865ae18487444be52aa1d03b915de3
--
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
[
https://issues.apache.org/jira/browse/KAFKA-16538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-16538:
---
Component/s: kraft
> Support UpdateFeatures for kraft.version so we
github-actions[bot] commented on PR #18489:
URL: https://github.com/apache/kafka/pull/18489#issuecomment-2739025039
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
srdo opened a new pull request, #19310:
URL: https://github.com/apache/kafka/pull/19310
Cherry picked from commit 078760a008fadcf524b31d079f8b08c9966c1139
--
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 t
mimaison commented on code in PR #19068:
URL: https://github.com/apache/kafka/pull/19068#discussion_r2018502560
##
clients/src/main/java/org/apache/kafka/server/quota/ClientQuotaCallback.java:
##
@@ -24,6 +24,10 @@
/**
* Quota callback interface for brokers and controllers
[
https://issues.apache.org/jira/browse/KAFKA-19049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-19049.
Fix Version/s: 4.1.0
Resolution: Fixed
> Remove the `@ExtendWith(ClusterTestExtensi
cadonna commented on code in PR #19275:
URL: https://github.com/apache/kafka/pull/19275#discussion_r2016429245
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java:
##
@@ -372,15 +371,13 @@ public static StreamThread create(final TopologyMetada
srdo commented on PR #19235:
URL: https://github.com/apache/kafka/pull/19235#issuecomment-2762114785
I was looking at doing this too, and want to share a few changes in case it
saves you work:
You likely need to upgrade to Scala 2.13.16
https://github.com/apache/kafka/compare/trunk..
Matthias J. Sax created KAFKA-19052:
---
Summary: Document how to query versioned stores/KTables
Key: KAFKA-19052
URL: https://issues.apache.org/jira/browse/KAFKA-19052
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939349#comment-17939349
]
Ao Li commented on KAFKA-17354:
---
Yes, the bug still appears. Here is the log I got from th
[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939350#comment-17939350
]
Ao Li commented on KAFKA-17354:
---
We recently released the Fray Gradle plugin, which allows
[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939350#comment-17939350
]
Ao Li edited comment on KAFKA-17354 at 3/28/25 11:49 PM:
-
We rec
[
https://issues.apache.org/jira/browse/KAFKA-19005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai resolved KAFKA-19005.
Fix Version/s: 4.1.0
Resolution: Fixed
> improve the docuemtnation of
> DescribeTo
[
https://issues.apache.org/jira/browse/KAFKA-17354?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939336#comment-17939336
]
Matthias J. Sax commented on KAFKA-17354:
-
I am wondering if [https://github.com
brandboat commented on code in PR #18510:
URL: https://github.com/apache/kafka/pull/18510#discussion_r2019674728
##
tools/src/test/java/org/apache/kafka/tools/consumer/group/share/ShareGroupStateMessageFormatterTest.java:
##
@@ -164,12 +164,16 @@ private static Stream exceptions
[
https://issues.apache.org/jira/browse/KAFKA-19048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17939364#comment-17939364
]
Jialun Peng commented on KAFKA-19048:
-
I don't know what's wrong with the editor. I
mingyen066 opened a new pull request, #19029:
URL: https://github.com/apache/kafka/pull/19029
Modify from https://github.com/apache/kafka/pull/16766
For now protocolConsumerGroupExecutor.close(); take too much which will
cause timeout. Still need to be fixed
--
This is an a
github-actions[bot] commented on PR #18811:
URL: https://github.com/apache/kafka/pull/18811#issuecomment-2763061007
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
github-actions[bot] commented on PR #18293:
URL: https://github.com/apache/kafka/pull/18293#issuecomment-2763069998
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
[
https://issues.apache.org/jira/browse/KAFKA-19051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kuan Po Tseng reassigned KAFKA-19051:
-
Assignee: Kuan Po Tseng
> Fix implicit acknowledgement cannot be overridden when
> Rec
DL1231 opened a new pull request, #19313:
URL: https://github.com/apache/kafka/pull/19313
In the current implementation, the `group.share.max.groups` is only used
when setting the `maxEntries` for the `ShareSessionCache`.
This PR throws an exception when processing a Heartbeat request if
jeqo commented on PR #19150:
URL: https://github.com/apache/kafka/pull/19150#issuecomment-2760932180
@junrao I've updated the PR with the latest fix. PTAL, many thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use t
mimaison commented on code in PR #19226:
URL: https://github.com/apache/kafka/pull/19226#discussion_r2018399561
##
server-common/src/main/java/org/apache/kafka/server/common/DelayedDeleteRecords.java:
##
@@ -0,0 +1,113 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
mimaison commented on code in PR #19226:
URL: https://github.com/apache/kafka/pull/19226#discussion_r2018399561
##
server-common/src/main/java/org/apache/kafka/server/common/DelayedDeleteRecords.java:
##
@@ -0,0 +1,113 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/KAFKA-18751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-18751:
---
Fix Version/s: 4.1.0
> Complete delayed FETCH request when HWM is in
Rancho-7 commented on PR #19299:
URL: https://github.com/apache/kafka/pull/19299#issuecomment-2761576823
> @Rancho-7 Can we also remove this line in Java doc? Thanks.
>
>
https://github.com/apache/kafka/blob/28de78bcbad605a3e906d085d2e59b441ae35212/test-common/test-common-runtime/src/
gongxuanzhang commented on code in PR #19226:
URL: https://github.com/apache/kafka/pull/19226#discussion_r2019096133
##
server-common/src/main/java/org/apache/kafka/server/common/DelayedDeleteRecords.java:
##
@@ -0,0 +1,113 @@
+/*
+ * Licensed to the Apache Software Foundation (
65 matches
Mail list logo
