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
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] 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 #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 #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
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
[
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
> ---
>
>
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
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
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
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
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
[
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
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
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
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
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
[
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
[
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-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-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
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-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
>
[
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:
---
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:
---
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-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-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-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-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
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
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
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
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
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
=
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
[
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
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
[
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)
>
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
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
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
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
[
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
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
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).
+#
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
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
[
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
> --
[
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:
-
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
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.
[
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
> ---
[
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
> -
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
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
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
[
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)
[
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
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
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;
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
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
[
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 `
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
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
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_r2036379689
##
streams/src/test/java/org/apache/kafka/streams/state/internals/ChangeLoggingKeyValueBytesStoreTest.java:
##
@@ -89,8 +95,81 @@ public class ChangeLoggingKeyValueBy
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
[
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
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
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
[
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
> ---
>
>
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
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
[
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
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,
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
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
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
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.
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
[
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
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
[
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
>
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
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
[
https://issues.apache.org/jira/browse/KAFKA-14056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942106#comment-17942106
]
Luke Chen commented on KAFKA-14056:
---
Changing the target version to 3.9.2. We can alwa
[
https://issues.apache.org/jira/browse/KAFKA-17996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-17996:
--
Fix Version/s: (was: 3.9.1)
> kafka-metadata-quorum.sh add-controller cause the new added controll
wernerdv commented on code in PR #19387:
URL: https://github.com/apache/kafka/pull/19387#discussion_r2034641102
##
storage/src/main/java/org/apache/kafka/storage/internals/log/CleanedTransactionMetadata.java:
##
@@ -0,0 +1,155 @@
+/*
+ * Licensed to the Apache Software Foundatio
[
https://issues.apache.org/jira/browse/KAFKA-14056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Luke Chen updated KAFKA-14056:
--
Fix Version/s: 3.9.2
(was: 3.9.1)
> Test reading of old messages formats in ZK-
[
https://issues.apache.org/jira/browse/KAFKA-19110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942112#comment-17942112
]
Bruno Cadonna commented on KAFKA-19110:
---
[~yangpoan] Thanks for your interest!
For
[
https://issues.apache.org/jira/browse/KAFKA-19110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bruno Cadonna reassigned KAFKA-19110:
-
Assignee: Bruno Cadonna
> Add missing unit test for Streams-consumer integration
> ---
1 - 100 of 133 matches
Mail list logo
