Chia-Ping Tsai created KAFKA-19123:
--
Summary: the buffer of forwarded request should be released after
receiving the reponse from controller
Key: KAFKA-19123
URL: https://issues.apache.org/jira/browse/KAFKA-19123
lucasbru commented on code in PR #19425:
URL: https://github.com/apache/kafka/pull/19425#discussion_r2036636589
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java:
##
@@ -140,6 +140,13 @@ public EmbeddedKafkaCluster(fi
lucasbru commented on PR #19425:
URL: https://github.com/apache/kafka/pull/19425#issuecomment-2791744850
@bbejeck Thanks for the review. Comment addressed, ready for rereview.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/KAFKA-19123?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942372#comment-17942372
]
Chia-Ping Tsai commented on KAFKA-19123:
Maybe we should release the buffer by `
chirag-wadhwa5 opened a new pull request, #19431:
URL: https://github.com/apache/kafka/pull/19431
Currently, in the deleteShareGroupOffsets method in GroupCoordinatorService,
the user request was simply forwarded to the persister without checking if the
requested share partitions were initi
DL1231 opened a new pull request, #19430:
URL: https://github.com/apache/kafka/pull/19430
For records which are automatically released as a result of closing a share
session normally, the delivery count should not be incremented. These records
were fetched but they were not actually deliver
github-actions[bot] closed pull request #15312: KAFKA-15867: Should
ConsumerNetworkThread wrap the exception and notify the polling thread?
URL: https://github.com/apache/kafka/pull/15312
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
github-actions[bot] commented on PR #18300:
URL: https://github.com/apache/kafka/pull/18300#issuecomment-2791469655
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
github-actions[bot] commented on PR #16664:
URL: https://github.com/apache/kafka/pull/16664#issuecomment-2791469517
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
github-actions[bot] closed pull request #18070: KAFKA-18167 - Disable TLS
session ticket extension
URL: https://github.com/apache/kafka/pull/18070
--
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
github-actions[bot] commented on PR #15312:
URL: https://github.com/apache/kafka/pull/15312#issuecomment-2791469443
This PR has been closed since it has not had any activity in 120 days. If
you feel like this
was a mistake, or you would like to continue working on it, please feel free
to
github-actions[bot] commented on PR #18070:
URL: https://github.com/apache/kafka/pull/18070#issuecomment-2791469591
This PR has been closed since it has not had any activity in 120 days. If
you feel like this
was a mistake, or you would like to continue working on it, please feel free
to
github-actions[bot] commented on PR #19346:
URL: https://github.com/apache/kafka/pull/19346#issuecomment-2791447082
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
Yunyung commented on code in PR #19419:
URL: https://github.com/apache/kafka/pull/19419#discussion_r2036424966
##
metadata/src/main/java/org/apache/kafka/metadata/util/SnapshotFileReader.java:
##
@@ -96,12 +96,16 @@ private void handleNextBatch() {
return;
mimaison commented on code in PR #19387:
URL: https://github.com/apache/kafka/pull/19387#discussion_r2031926411
##
build.gradle:
##
@@ -3737,6 +3737,7 @@ project(':connect:mirror') {
testImplementation project(':core')
testImplementation project(':test-common:test-comm
[
https://issues.apache.org/jira/browse/KAFKA-19103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-19103:
---
Priority: Trivial (was: Major)
> Remove OffsetConfig
> ---
>
>
leaf-soba commented on code in PR #18816:
URL: https://github.com/apache/kafka/pull/18816#discussion_r2036378149
##
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.java:
##
@@ -89,8 +95,81 @@ public class ChangeLoggingKeyValueBy
leaf-soba commented on code in PR #18816:
URL: https://github.com/apache/kafka/pull/18816#discussion_r2036379689
##
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.java:
##
@@ -89,8 +95,81 @@ public class ChangeLoggingKeyValueBy
leaf-soba commented on code in PR #18816:
URL: https://github.com/apache/kafka/pull/18816#discussion_r2036375532
##
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.java:
##
@@ -111,29 +190,38 @@ public void after() {
}
leaf-soba commented on code in PR #18816:
URL: https://github.com/apache/kafka/pull/18816#discussion_r2036372806
##
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.java:
##
@@ -62,18 +63,23 @@
import static org.hamcrest.CoreMat
[
https://issues.apache.org/jira/browse/KAFKA-18991?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942320#comment-17942320
]
José Armando García Sancio commented on KAFKA-18991:
I cherry picked
showuon commented on PR #19188:
URL: https://github.com/apache/kafka/pull/19188#issuecomment-2791265676
Thank you @ableegoldman !
--
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
[
https://issues.apache.org/jira/browse/KAFKA-19118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-19118:
Component/s: streams
unit tests
> Enable KIP-1071 in existing streams int
mjsax commented on PR #19188:
URL: https://github.com/apache/kafka/pull/19188#issuecomment-2791211401
Thanks all! Great to see this getting merged and making the 3.9.1 cut!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
ahuang98 commented on code in PR #19296:
URL: https://github.com/apache/kafka/pull/19296#discussion_r2036240858
##
metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java:
##
@@ -353,10 +353,10 @@ public ControllerResult
registerBroker(
if (existi
rreddy-22 opened a new pull request, #19429:
URL: https://github.com/apache/kafka/pull/19429
This is part of the client side changes required to enable 2PC for KIP-939
**Producer Config:**
transaction.two.phase.commit.enable The default would be ‘false’. If set to
‘true’, the brok
cmccabe commented on PR #19428:
URL: https://github.com/apache/kafka/pull/19428#issuecomment-2791166073
I don’t see why a broker being fenced or not should have an effect on this.
Removing the session seems reasonable actually.
It’s a bit messy, changing that part of the code is
ahuang98 commented on PR #19428:
URL: https://github.com/apache/kafka/pull/19428#issuecomment-2791164065
It doesn't seem worth to try removing sessions preemptively, e.g. in
ReplicationControlManager#processBrokerHeartbeat skipping broker session touch
if `states.current().equals(CONTROLLED
[
https://issues.apache.org/jira/browse/KAFKA-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942319#comment-17942319
]
José Armando García Sancio commented on KAFKA-19114:
[~chia7712] I a
[
https://issues.apache.org/jira/browse/KAFKA-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio resolved KAFKA-19114.
Resolution: Fixed
> Backport KAFKA-18991 to 4.0 and 3.9
>
[
https://issues.apache.org/jira/browse/KAFKA-18991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-18991:
---
Fix Version/s: 3.9.1
> AbstractFetcherThread should verify the curre
[
https://issues.apache.org/jira/browse/KAFKA-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio reassigned KAFKA-19114:
--
Assignee: José Armando García Sancio (was: Chia-Ping Tsai)
>
[
https://issues.apache.org/jira/browse/KAFKA-19103?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17941677#comment-17941677
]
Bolin Lin edited comment on KAFKA-19103 at 4/7/25 5:44 PM:
---
Hi
rreddy-22 commented on code in PR #19364:
URL: https://github.com/apache/kafka/pull/19364#discussion_r2036224264
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -1520,6 +1520,10 @@ class KafkaApis(val requestChannel: RequestChannel,
requestHelper.sendErrorRes
apoorvmittal10 commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2036147271
##
core/src/main/java/kafka/server/share/SharePartition.java:
##
@@ -2475,6 +2496,192 @@ private long startOffsetDuringInitialization(long
partitionDataStartOff
ahuang98 opened a new pull request, #19428:
URL: https://github.com/apache/kafka/pull/19428
https://github.com/confluentinc/ce-kafka/pull/20044 fails to account that
brokers finishing controlled shutdown eventually become fenced and clear their
inControlledShutdown bool.
--
This is an au
Rancho-7 commented on PR #19384:
URL: https://github.com/apache/kafka/pull/19384#issuecomment-2787964810
> @Rancho-7 could you please following code too?
>
>
https://github.com/apache/kafka/blob/2f086d188fe42db290d7037e83f552075e8bfcaa/core/src/main/scala/kafka/server/KafkaRequestHand
mimaison commented on PR #19426:
URL: https://github.com/apache/kafka/pull/19426#issuecomment-2789840026
The `ApiVersionManager` implementation used by brokers,
`DefaultApiVersionManager`, can't be moved yet as it still depends on
`kafka.server.ForwardingManager`.
--
This is an automated
johnny94 commented on code in PR #19420:
URL: https://github.com/apache/kafka/pull/19420#discussion_r2034509289
##
trogdor/README.md:
##
@@ -6,9 +6,9 @@ Trogdor can run benchmarks and other workloads. Trogdor can
also inject faults i
Quickstart
=
ableegoldman commented on PR #19188:
URL: https://github.com/apache/kafka/pull/19188#issuecomment-2790946266
cherrypicked to 4.0 and 3.9 cc @showuon
--
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
ableegoldman commented on PR #19188:
URL: https://github.com/apache/kafka/pull/19188#issuecomment-2790900582
@showuon merged to trunk
--
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
adixitconfluent commented on code in PR #19261:
URL: https://github.com/apache/kafka/pull/19261#discussion_r2031745262
##
core/src/test/java/kafka/server/share/SharePartitionTest.java:
##
@@ -6671,15 +6693,441 @@ private String assertionFailedMessage(SharePartition
sharePartiti
[
https://issues.apache.org/jira/browse/KAFKA-18962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-18962:
Fix Version/s: 4.1.0
3.9.1
4.0.1
> StateRestoreListe
ableegoldman merged PR #19188:
URL: https://github.com/apache/kafka/pull/19188
--
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.ap
ableegoldman commented on PR #19188:
URL: https://github.com/apache/kafka/pull/19188#issuecomment-2790896198
@showuon I think this PR is pretty much ready. I'll give it another quick
pass right now and then merge to unblock 3.9.1
--
This is an automated message from the Apache Git Service
splett2 commented on code in PR #19296:
URL: https://github.com/apache/kafka/pull/19296#discussion_r2036067232
##
metadata/src/main/java/org/apache/kafka/controller/ClusterControlManager.java:
##
@@ -353,10 +353,10 @@ public ControllerResult
registerBroker(
if (existin
[
https://issues.apache.org/jira/browse/KAFKA-19103?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bolin Lin reassigned KAFKA-19103:
-
Assignee: Bolin Lin (was: Chia-Ping Tsai)
> Remove OffsetConfig
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-19110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942234#comment-17942234
]
Bruno Cadonna commented on KAFKA-19110:
---
That would be great!
> Add missing unit
mimaison opened a new pull request, #19426:
URL: https://github.com/apache/kafka/pull/19426
(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
Parkerhiphop commented on code in PR #19374:
URL: https://github.com/apache/kafka/pull/19374#discussion_r2035827481
##
core/src/main/scala/kafka/network/SocketServer.scala:
##
@@ -97,7 +97,7 @@ class SocketServer(
private val memoryPool = if (config.queuedMaxBytes > 0) new
S
[
https://issues.apache.org/jira/browse/KAFKA-14777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot deleted KAFKA-14777:
> Add support of topic id for OffsetCommitRequests in CommitRequestManager
>
AndrewJSchofield commented on PR #19363:
URL: https://github.com/apache/kafka/pull/19363#issuecomment-2789224695
This operation is also susceptible to
https://issues.apache.org/jira/browse/KAFKA-19116.
--
This is an automated message from the Apache Git Service.
To respond to the message,
[
https://issues.apache.org/jira/browse/KAFKA-19116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942211#comment-17942211
]
Sushant Mahajan commented on KAFKA-19116:
-
The issue occurs due to SharePartitio
chia7712 commented on PR #19371:
URL: https://github.com/apache/kafka/pull/19371#issuecomment-2790393621
Maybe we can add a internal config to allow tests to define small size?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub a
[
https://issues.apache.org/jira/browse/KAFKA-19037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-19037.
---
Resolution: Fixed
> Integrate consumer-side code with Streams
> ---
[
https://issues.apache.org/jira/browse/KAFKA-18991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-18991:
---
Fix Version/s: 4.0.1
> AbstractFetcherThread should verify the curre
[
https://issues.apache.org/jira/browse/KAFKA-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-19114:
---
Summary: Backport KAFKA-18991 to 4.0 and 3.9 (was: Backport KAFKA-18
[
https://issues.apache.org/jira/browse/KAFKA-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942241#comment-17942241
]
José Armando García Sancio commented on KAFKA-19114:
[~chia7712] , I
[
https://issues.apache.org/jira/browse/KAFKA-19122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-19122:
---
Fix Version/s: 4.1.0
4.0.1
> updateClusterMetadata receives multiples Par
[
https://issues.apache.org/jira/browse/KAFKA-19122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-19122:
---
Priority: Critical (was: Major)
> updateClusterMetadata receives multiples PartitionInfo
>
[
https://issues.apache.org/jira/browse/KAFKA-19122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-19122:
---
Summary: updateClusterMetadata receives multiples PartitionInfo (was:
updateClusterMetadata
[
https://issues.apache.org/jira/browse/KAFKA-19122?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-19122:
---
Affects Version/s: 4.0.0
> updateClusterMetadata receives multiples PartitionInfo
>
Chia-Ping Tsai created KAFKA-19122:
--
Summary: updateClusterMetadata receives duplicate PartitionInfo
Key: KAFKA-19122
URL: https://issues.apache.org/jira/browse/KAFKA-19122
Project: Kafka
Is
[
https://issues.apache.org/jira/browse/KAFKA-19114?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942242#comment-17942242
]
Chia-Ping Tsai commented on KAFKA-19114:
[~jsancio] thanks for response. Please
[
https://issues.apache.org/jira/browse/KAFKA-18287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna reopened KAFKA-18287:
---
> Add support for kafka-streams-groups.sh --list
> -
[
https://issues.apache.org/jira/browse/KAFKA-18287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna resolved KAFKA-18287.
---
Resolution: Fixed
> Add support for kafka-streams-groups.sh --list
> ---
cadonna merged PR #19422:
URL: https://github.com/apache/kafka/pull/19422
--
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.
smjn commented on PR #19363:
URL: https://github.com/apache/kafka/pull/19363#issuecomment-2790191018
Thanks for the review, @AndrewJSchofield
Incorporated all comments.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
lucasbru commented on PR #19425:
URL: https://github.com/apache/kafka/pull/19425#issuecomment-2789605788
PTAL @aliehsaeedii
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
JimmyWang6 commented on PR #18929:
URL: https://github.com/apache/kafka/pull/18929#issuecomment-2790154133
@AndrewJSchofield
Thanks for your feedback! I'll start by referencing the implementation in
[#19328](https://github.com/apache/kafka/pull/19328) to implement a first
version. I'll
[
https://issues.apache.org/jira/browse/KAFKA-18723?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
José Armando García Sancio updated KAFKA-18723:
---
Fix Version/s: (was: 3.8.2)
(was: 3.7.3)
OmniaGM commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r2035180146
##
core/src/test/scala/integration/kafka/api/ProducerSendWhileDeletionTest.scala:
##
@@ -85,4 +85,83 @@ class ProducerSendWhileDeletionTest extends
IntegrationTestHarn
AndrewJSchofield commented on code in PR #19363:
URL: https://github.com/apache/kafka/pull/19363#discussion_r2035285341
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorRecordHelpers.java:
##
@@ -814,6 +814,19 @@ public static CoordinatorReco
yx9o opened a new pull request, #19427:
URL: https://github.com/apache/kafka/pull/19427
Fix docker_release example.
--
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
[
https://issues.apache.org/jira/browse/KAFKA-19116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942211#comment-17942211
]
Sushant Mahajan edited comment on KAFKA-19116 at 4/9/25 2:36 PM:
-
Chia-Ping Tsai created KAFKA-19121:
--
Summary: Move AddPartitionsToTxnConfig,
TransactionStateManagerConfig, and QuorumConfig out of KafkaConfig
Key: KAFKA-19121
URL: https://issues.apache.org/jira/browse/KAFKA-19
bbejeck commented on code in PR #19425:
URL: https://github.com/apache/kafka/pull/19425#discussion_r2035488915
##
streams/integration-tests/src/test/java/org/apache/kafka/streams/integration/utils/EmbeddedKafkaCluster.java:
##
@@ -140,6 +140,13 @@ public EmbeddedKafkaCluster(fin
Mickael Maison created KAFKA-19119:
--
Summary: Move ApiVersionManager/SimpleApiVersionManager
Key: KAFKA-19119
URL: https://issues.apache.org/jira/browse/KAFKA-19119
Project: Kafka
Issue Type
David Jacot created KAFKA-19120:
---
Summary: Consider whether we could subscribe using topic ids
instead of names
Key: KAFKA-19120
URL: https://issues.apache.org/jira/browse/KAFKA-19120
Project: Kafka
cadonna commented on code in PR #19422:
URL: https://github.com/apache/kafka/pull/19422#discussion_r2035229373
##
tools/src/test/java/org/apache/kafka/tools/streams/StreamsGroupCommandUnitTest.java:
##
Review Comment:
As far as I can see in the code base we tend to name int
[
https://issues.apache.org/jira/browse/KAFKA-19115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sushant Mahajan updated KAFKA-19115:
Summary: Utilize initialized topics info to verify delete share group
offsets (was: Utili
[
https://issues.apache.org/jira/browse/KAFKA-19090?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mickael Maison resolved KAFKA-19090.
Fix Version/s: 4.1.0
Resolution: Fixed
> Move DelayedFuture and DelayedFuturePurgat
Yunyung commented on code in PR #19420:
URL: https://github.com/apache/kafka/pull/19420#discussion_r2034520490
##
README.md:
##
@@ -263,10 +267,28 @@ default. See
https://www.lightbend.com/blog/scala-inliner-optimizer for more det
See [tests/README.md](tests/README.md).
+#
wernerdv commented on code in PR #19387:
URL: https://github.com/apache/kafka/pull/19387#discussion_r2035323732
##
storage/src/main/java/org/apache/kafka/storage/internals/log/Cleaner.java:
##
@@ -0,0 +1,762 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one o
cadonna opened a new pull request, #19421:
URL: https://github.com/apache/kafka/pull/19421
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 comm
lucasbru opened a new pull request, #19425:
URL: https://github.com/apache/kafka/pull/19425
KIP-1071 creates internal topics broker-side, so this test checks whether,
when KIP-1071 is enabled, basically the same topics are created.
It also adds a little helper method in `EmbeddedKafka
cadonna commented on code in PR #19422:
URL: https://github.com/apache/kafka/pull/19422#discussion_r2035283403
##
tools/src/test/java/org/apache/kafka/tools/streams/StreamsGroupCommandUnitTest.java:
##
@@ -0,0 +1,170 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) un
gongxuanzhang commented on PR #19319:
URL: https://github.com/apache/kafka/pull/19319#issuecomment-2788850360
@chia7712 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 the specific comment.
[
https://issues.apache.org/jira/browse/KAFKA-19118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Brutschy reassigned KAFKA-19118:
--
Assignee: Lucas Brutschy
> Enable KIP-1071 in existing streams integration tests
> --
OmniaGM commented on code in PR #15968:
URL: https://github.com/apache/kafka/pull/15968#discussion_r2035179030
##
clients/src/test/java/org/apache/kafka/common/requests/ProduceRequestTest.java:
##
@@ -112,6 +115,27 @@ public void testBuildWithCurrentMessageFormat() {
as
aliehsaeedii commented on code in PR #19422:
URL: https://github.com/apache/kafka/pull/19422#discussion_r2035257657
##
tools/src/test/java/org/apache/kafka/tools/streams/StreamsGroupCommandUnitTest.java:
##
@@ -0,0 +1,170 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
aliehsaeedii commented on code in PR #19422:
URL: https://github.com/apache/kafka/pull/19422#discussion_r2035258165
##
tools/src/test/java/org/apache/kafka/tools/streams/StreamsGroupCommandUnitTest.java:
##
@@ -0,0 +1,170 @@
+/*
+ * Licensed to the Apache Software Foundation (AS
FrankYang0529 opened a new pull request, #19424:
URL: https://github.com/apache/kafka/pull/19424
1. Migrate DelegationTokenManager to server module.
2. Rewrite DelegationTokenManager in Java.
3. Move DelegationTokenManagerConfigs out of KafkaConfig.
Jira: KAFKA-19113, KAFKA-15853
[
https://issues.apache.org/jira/browse/KAFKA-19117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ravi Kalasapur updated KAFKA-19117:
---
Summary: Client Throttling Log messages should be of log level - WARN (Java
client) (was: C
aliehsaeedii commented on code in PR #19422:
URL: https://github.com/apache/kafka/pull/19422#discussion_r2035223030
##
tools/src/test/java/org/apache/kafka/tools/streams/StreamsGroupCommandUnitTest.java:
##
Review Comment:
We already have a `StreamsGroupCommandTest` in the
lucasbru commented on PR #19423:
URL: https://github.com/apache/kafka/pull/19423#issuecomment-2789442906
PTAL @aliehsaeedii
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
lucasbru opened a new pull request, #19423:
URL: https://github.com/apache/kafka/pull/19423
Add support for streams groups in kafka-groups.sh.
The change adds command-line options `--streams` to list only streams
groups, and value `--group-type streams`. Those two options are mutually
cadonna commented on code in PR #19422:
URL: https://github.com/apache/kafka/pull/19422#discussion_r2035110087
##
tools/src/test/java/org/apache/kafka/tools/streams/StreamsGroupCommandUnitTest.java:
##
Review Comment:
Could you please rename this file and class to `StreamsG
[
https://issues.apache.org/jira/browse/KAFKA-19110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942141#comment-17942141
]
Bruno Cadonna commented on KAFKA-19110:
---
[~yangpoan] I checked the planned refacto
[
https://issues.apache.org/jira/browse/KAFKA-17996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Omnia Ibrahim resolved KAFKA-17996.
---
Resolution: Fixed
> kafka-metadata-quorum.sh add-controller cause the new added controller t
1 - 100 of 133 matches
Mail list logo
