chia7712 commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2093347402
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,220 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mor
mingyen066 commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2093356280
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,220 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
chia7712 commented on code in PR #19724:
URL: https://github.com/apache/kafka/pull/19724#discussion_r2093356674
##
core/src/main/scala/kafka/server/KafkaApis.scala:
##
@@ -384,15 +385,15 @@ class KafkaApis(val requestChannel: RequestChannel,
/**
* Handle a produce request
AndrewJSchofield merged PR #19708:
URL: https://github.com/apache/kafka/pull/19708
--
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...@kafk
FrankYang0529 opened a new pull request, #19743:
URL: https://github.com/apache/kafka/pull/19743
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 som
LoganZhuZzz commented on code in PR #19728:
URL: https://github.com/apache/kafka/pull/19728#discussion_r2093371056
##
clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java:
##
@@ -66,7 +66,8 @@ public KafkaFuture>> all() {
}
/**
-
chia7712 commented on code in PR #19687:
URL: https://github.com/apache/kafka/pull/19687#discussion_r2093369859
##
server/src/main/java/org/apache/kafka/server/LoggingController.java:
##
@@ -0,0 +1,211 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
Bill Bejeck created KAFKA-19292:
---
Summary: Introduce soft state for StreamsGroup
Key: KAFKA-19292
URL: https://issues.apache.org/jira/browse/KAFKA-19292
Project: Kafka
Issue Type: Sub-task
Kirk True created KAFKA-19295:
-
Summary: Remove AsyncKafkaConsumer event ID generation
Key: KAFKA-19295
URL: https://issues.apache.org/jira/browse/KAFKA-19295
Project: Kafka
Issue Type: Improveme
ahuang98 opened a new pull request, #19747:
URL: https://github.com/apache/kafka/pull/19747
Replaces exponential backoff for candidate state after losing election with
waiting rest of election timeout.
We don't need an exponential backoff after PreVote was implemented since
candidates t
kirktrue closed pull request #19725: KAFKA-18847: Refactor OAuth layer to
improve reusability 2/N
URL: https://github.com/apache/kafka/pull/19725
--
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
artemlivshits commented on code in PR #19714:
URL: https://github.com/apache/kafka/pull/19714#discussion_r2093786302
##
clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java:
##
@@ -884,6 +884,50 @@ public void abortTransaction() throws
ProducerFencedExcept
kirktrue closed pull request #18912: [WIP] JWT bearer grant type support
URL: https://github.com/apache/kafka/pull/18912
--
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 unsu
[
https://issues.apache.org/jira/browse/KAFKA-19295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-19295:
--
Description: The {{AsyncKafkaConsumer}} uses an event queue-based mechanism
to communicate between the
[
https://issues.apache.org/jira/browse/KAFKA-19295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-19295:
--
Fix Version/s: 4.1.0
> Remove AsyncKafkaConsumer event ID generation
> ---
Kirk True created KAFKA-19296:
-
Summary: Revise AsyncKafkaConsumer event wakeup approach
Key: KAFKA-19296
URL: https://issues.apache.org/jira/browse/KAFKA-19296
Project: Kafka
Issue Type: Improve
Rancho-7 commented on code in PR #19728:
URL: https://github.com/apache/kafka/pull/19728#discussion_r2093810937
##
clients/src/main/java/org/apache/kafka/clients/admin/ListShareGroupOffsetsResult.java:
##
@@ -66,7 +66,8 @@ public KafkaFuture>> all() {
}
/**
- * R
[
https://issues.apache.org/jira/browse/KAFKA-19296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-19296:
--
Description: The {{AsyncKafkaConsumer}} uses an event queue-based mechanism
to communicate between the
dajac opened a new pull request, #19744:
URL: https://github.com/apache/kafka/pull/19744
This patch updates the OffsetFetch API to ensure that a committed offset is
returned iff the requested topic id matches the persisted one; the invalid
offset is returned otherwise.
--
This is an
dajac commented on code in PR #19744:
URL: https://github.com/apache/kafka/pull/19744#discussion_r2093524420
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java:
##
@@ -906,7 +907,7 @@ public OffsetFetchResponseData.OffsetFetchRespons
dajac commented on code in PR #19744:
URL: https://github.com/apache/kafka/pull/19744#discussion_r2093526281
##
core/src/test/scala/unit/kafka/server/OffsetFetchRequestTest.scala:
##
@@ -527,4 +527,88 @@ class OffsetFetchRequestTest(cluster: ClusterInstance)
extends GroupCoordi
lianetm commented on code in PR #19669:
URL: https://github.com/apache/kafka/pull/19669#discussion_r2093503258
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -1842,12 +1845,12 @@ public void testOffsetOfPausedPartitions(GroupProtocol
gr
lianetm commented on code in PR #19669:
URL: https://github.com/apache/kafka/pull/19669#discussion_r2093503258
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -1842,12 +1845,12 @@ public void testOffsetOfPausedPartitions(GroupProtocol
gr
dajac commented on PR #19744:
URL: https://github.com/apache/kafka/pull/19744#issuecomment-2887451144
@lianetm @squah-confluent @dongnuo123 Could you please review it?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use th
David Jacot created KAFKA-19293:
---
Summary: Consolidate writes within
GroupCoordinatorService#onPartitionsDeleted
Key: KAFKA-19293
URL: https://issues.apache.org/jira/browse/KAFKA-19293
Project: Kafka
lucasbru commented on code in PR #19722:
URL: https://github.com/apache/kafka/pull/19722#discussion_r2093604576
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/streams/topics/ConfiguredSubtopology.java:
##
@@ -58,4 +64,6 @@ public StreamsGroupDescribeRespon
bbejeck merged PR #19691:
URL: https://github.com/apache/kafka/pull/19691
--
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.
rreddy-22 opened a new pull request, #19746:
URL: https://github.com/apache/kafka/pull/19746
The test incorrectly used force-terminate instead of
forceTerminateTransaction
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and u
jolshan commented on code in PR #19714:
URL: https://github.com/apache/kafka/pull/19714#discussion_r2093701791
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -1332,6 +1332,7 @@ private void completeTransaction() {
new
rreddy-22 commented on code in PR #19714:
URL: https://github.com/apache/kafka/pull/19714#discussion_r2093739425
##
clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java:
##
@@ -1332,6 +1332,7 @@ private void completeTransaction() {
n
AndrewJSchofield commented on code in PR #19611:
URL: https://github.com/apache/kafka/pull/19611#discussion_r2093435595
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/modern/SubscribedTopicDescriberImpl.java:
##
@@ -19,41 +19,42 @@
import org.apache.kafka
bbejeck commented on code in PR #19700:
URL: https://github.com/apache/kafka/pull/19700#discussion_r2093435225
##
tests/kafkatest/tests/streams/streams_eos_test.py:
##
@@ -160,10 +168,16 @@ def abort_streams(self, keep_alive_processor1,
keep_alive_processor2, processor_
bbejeck commented on PR #19691:
URL: https://github.com/apache/kafka/pull/19691#issuecomment-2887358874
@lucasbru latest comment addressed and ready for another pass
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
josefk31 commented on code in PR #19664:
URL: https://github.com/apache/kafka/pull/19664#discussion_r2093579035
##
clients/src/main/resources/common/message/GetReplicaLogInfoRequest.json:
##
@@ -0,0 +1,32 @@
+// Licensed to the Apache Software Foundation (ASF) under one or more
lucasbru commented on code in PR #19700:
URL: https://github.com/apache/kafka/pull/19700#discussion_r2093593120
##
streams/src/test/java/org/apache/kafka/streams/tests/EosTestDriver.java:
##
@@ -248,21 +250,33 @@ public static void verify(final String kafka, final
boolean withR
lucasbru commented on code in PR #19700:
URL: https://github.com/apache/kafka/pull/19700#discussion_r2093593434
##
tests/kafkatest/tests/streams/streams_eos_test.py:
##
@@ -160,10 +168,16 @@ def abort_streams(self, keep_alive_processor1,
keep_alive_processor2, processor_
bbejeck commented on PR #19700:
URL: https://github.com/apache/kafka/pull/19700#issuecomment-2887305270
Seems the checkstyle check is related.
Also, can you post a link for the successful system test run?
--
This is an automated message from the Apache Git Service.
To respond to the
lucasbru commented on code in PR #19717:
URL: https://github.com/apache/kafka/pull/19717#discussion_r2093505491
##
storage/src/main/java/org/apache/kafka/storage/internals/log/UnifiedLog.java:
##
@@ -671,8 +672,9 @@ private LogOffsetMetadata fetchLastStableOffsetMetadata()
thro
lucasbru commented on PR #19717:
URL: https://github.com/apache/kafka/pull/19717#issuecomment-2887408768
Thanks for the review @mimaison. Ready for re-review
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL abov
junrao commented on code in PR #19371:
URL: https://github.com/apache/kafka/pull/19371#discussion_r2093536869
##
core/src/test/scala/unit/kafka/log/LogConfigTest.scala:
##
@@ -52,8 +52,13 @@ class LogConfigTest {
assertTrue(LogConfig.configNames.asScala
.filter(confi
Colin McCabe created KAFKA-19294:
Summary: Fix BrokerLifecycleManager RPC timeouts
Key: KAFKA-19294
URL: https://issues.apache.org/jira/browse/KAFKA-19294
Project: Kafka
Issue Type: Bug
cmccabe opened a new pull request, #19745:
URL: https://github.com/apache/kafka/pull/19745
Previously, we could wait for up to half of the broker session timeout for
an RPC to complete, and then delay by up to half of the broker session timeout.
When taken together, these two delays could l
junrao commented on PR #19371:
URL: https://github.com/apache/kafka/pull/19371#issuecomment-2887628228
It's useful to check if metadata.log.segment.min.bytes is used in any
ducktape tests.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log o
lucasbru commented on PR #19700:
URL: https://github.com/apache/kafka/pull/19700#issuecomment-2887638598
https://confluent-open-source-kafka-branch-builder-system-test-results.s3-us-west-2.amazonaws.com/trunk/2025-05-16--001.f96ee1ad-1206-44da-ac81-5ba99ca2fb17--1747427122--lucasbru--system_
[
https://issues.apache.org/jira/browse/KAFKA-19141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-19141.
-
Fix Version/s: 4.1.0
Resolution: Fixed
> Persist topic id in OffsetCommit record
> --
lianetm commented on code in PR #19577:
URL: https://github.com/apache/kafka/pull/19577#discussion_r2093194584
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -730,7 +739,10 @@ public NetworkClientDelegate.UnsentRequest
toUn
Kirk True created KAFKA-19297:
-
Summary: Refactor AsyncKafkaConsumer's use of Java Streams APIs in
critical sections
Key: KAFKA-19297
URL: https://issues.apache.org/jira/browse/KAFKA-19297
Project: Kafka
m1a2st commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2093814638
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,214 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
[
https://issues.apache.org/jira/browse/KAFKA-18573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-18573:
--
Labels: OAuth2 kip-1139 (was: OAuth2 kip-1139 needs-kip)
> Add support for OAuth jwt-bearer grant typ
kirktrue opened a new pull request, #19748:
URL: https://github.com/apache/kafka/pull/19748
WIP
--
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
m1a2st commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2093812751
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,214 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
[
https://issues.apache.org/jira/browse/KAFKA-18139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-18139:
--
Labels: consumer-threading-refactor performance (was: )
> AsyncKafkaConsumer's ConsumerNetworkThread
mjsax commented on code in PR #19669:
URL: https://github.com/apache/kafka/pull/19669#discussion_r2093828163
##
clients/src/test/java/org/apache/kafka/clients/consumer/KafkaConsumerTest.java:
##
@@ -1959,17 +1963,19 @@ public void testCloseShouldBeIdempotent(GroupProtocol
group
[
https://issues.apache.org/jira/browse/KAFKA-18573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kirk True updated KAFKA-18573:
--
Description: The current OAuth implementation allows for only
{{client_credentials}} grant types. This
mingyen066 commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2093854538
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,214 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
chia7712 commented on code in PR #19371:
URL: https://github.com/apache/kafka/pull/19371#discussion_r2093848474
##
core/src/test/scala/unit/kafka/log/LogConfigTest.scala:
##
@@ -52,8 +52,13 @@ class LogConfigTest {
assertTrue(LogConfig.configNames.asScala
.filter(con
chia7712 commented on code in PR #19687:
URL: https://github.com/apache/kafka/pull/19687#discussion_r2093853688
##
server/src/main/java/org/apache/kafka/server/logging/Log4jCoreController.java:
##
@@ -0,0 +1,96 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under on
Chia-Ping Tsai created KAFKA-19298:
--
Summary: Move RuntimeLoggerManager to server module
Key: KAFKA-19298
URL: https://issues.apache.org/jira/browse/KAFKA-19298
Project: Kafka
Issue Type: Su
mingyen066 commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2093356280
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,220 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
[
https://issues.apache.org/jira/browse/KAFKA-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17952316#comment-17952316
]
Colt McNealy commented on KAFKA-1:
--
> If the task wasn't caught up on this host
m1a2st commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2093859165
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,214 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
m1a2st commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2093859165
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,214 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
m1a2st commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2093865114
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,215 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
github-actions[bot] commented on PR #19455:
URL: https://github.com/apache/kafka/pull/19455#issuecomment-2888016488
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
m1a2st commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2093859165
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,214 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
mingyen066 commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2093871881
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,214 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
smjn opened a new pull request, #19739:
URL: https://github.com/apache/kafka/pull/19739
* A bug in `TargetAssignmentBuilder.java` was preventing
`SubscribedTopicDescriber.assignablePartitions` from returning set of all
partitions the input topicId for non-share groups.
* This was because
chirag-wadhwa5 commented on code in PR #19701:
URL: https://github.com/apache/kafka/pull/19701#discussion_r2088357326
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -4824,6 +4824,42 @@ class KafkaApisTest extends Logging {
assertEquals(Errors.INVALID_SH
bbejeck commented on code in PR #19691:
URL: https://github.com/apache/kafka/pull/19691#discussion_r2093198358
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java:
##
@@ -1983,18 +1985,24 @@ private CoordinatorResult stream
St
AndrewJSchofield merged PR #19707:
URL: https://github.com/apache/kafka/pull/19707
--
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...@kafk
AndrewJSchofield commented on code in PR #19708:
URL: https://github.com/apache/kafka/pull/19708#discussion_r2092562245
##
tests/kafkatest/services/console_consumer.py:
##
@@ -313,4 +313,3 @@ def wait_for_offset_reset(self, node, topic,
num_partitions):
wait_until(
frankvicky merged PR #19727:
URL: https://github.com/apache/kafka/pull/19727
--
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.apac
[
https://issues.apache.org/jira/browse/KAFKA-19290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17952080#comment-17952080
]
Andrew Schofield commented on KAFKA-19290:
--
Absolutely. That would help a lot.
[
https://issues.apache.org/jira/browse/KAFKA-19290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Andrew Schofield reassigned KAFKA-19290:
Assignee: PoAn Yang
> Exploit mapKey optimisation in protocol requests and respon
m1a2st commented on code in PR #19681:
URL: https://github.com/apache/kafka/pull/19681#discussion_r2093294639
##
storage/src/test/java/org/apache/kafka/admin/RemoteTopicCrudTest.java:
##
@@ -0,0 +1,694 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
m1a2st commented on code in PR #19738:
URL: https://github.com/apache/kafka/pull/19738#discussion_r2093274004
##
core/src/test/scala/unit/kafka/server/ListOffsetsRequestTest.scala:
##
@@ -214,13 +214,7 @@ class ListOffsetsRequestTest extends BaseRequestTest {
TestUtils.prod
janchilling commented on PR #19275:
URL: https://github.com/apache/kafka/pull/19275#issuecomment-2887091400
Hi @cadonna ,
I think I have completed all, sorry for the delay though.
Only one problem remainins. Which is the
`StreamThreadTest#testNamedTopologyWithStreamsProtocol` a
[
https://issues.apache.org/jira/browse/KAFKA-19282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Mahsa Seifikar updated KAFKA-19282:
---
Description: In kafka.server.ClientQuotaManager class, quotaTypesEnabled is
not updated when
MahsaSeifikar opened a new pull request, #19742:
URL: https://github.com/apache/kafka/pull/19742
In `kafka.server.ClientQuotaManager` class, `quotaTypesEnabled` is not
updated when a quota is removed via `removeQuota` method in
`DefaultQuotaCallback` class. This field is set when quotas are
Abhinav Dixit created KAFKA-19291:
-
Summary: Increase the timeout of remote storage share fetch
requests in purgatory
Key: KAFKA-19291
URL: https://issues.apache.org/jira/browse/KAFKA-19291
Project: K
dajac opened a new pull request, #19713:
URL: https://github.com/apache/kafka/pull/19713
Group Coordinator Shards are not unloaded when `__consumer_offsets` topic is
deleted. The unloading is scheduled but it is ignored because the epoch is
equal to the current epoch:
```
[2025-05
dajac commented on PR #19523:
URL: https://github.com/apache/kafka/pull/19523#issuecomment-2879230830
@FrankYang0529 Thanks for the update. Could you please also update the
description of the PR?
--
This is an automated message from the Apache Git Service.
To respond to the message, pleas
AndrewJSchofield commented on PR #19715:
URL: https://github.com/apache/kafka/pull/19715#issuecomment-2879257695
> > @apoorvmittal10 , In KafkaApis, I think you're referring to this
[check](https://github.com/apache/kafka/blob/trunk/core/src/main/scala/kafka/server/KafkaApis.scala#L3995)
`c
lucasbru commented on code in PR #19691:
URL: https://github.com/apache/kafka/pull/19691#discussion_r2087438125
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/StreamsRebalanceData.java:
##
@@ -355,6 +357,9 @@ public Map subtopologies() {
return sub
dajac commented on code in PR #19523:
URL: https://github.com/apache/kafka/pull/19523#discussion_r2088351150
##
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/Utils.java:
##
@@ -324,4 +329,98 @@ static void throwIfRegularExpressionIsInvalid(
chia7712 merged PR #19579:
URL: https://github.com/apache/kafka/pull/19579
--
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
mingyen066 commented on code in PR #19741:
URL: https://github.com/apache/kafka/pull/19741#discussion_r2093388713
##
server/src/test/java/org/apache/kafka/api/EndToEndClusterIdTest.java:
##
@@ -0,0 +1,220 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or m
chia7712 commented on code in PR #19651:
URL: https://github.com/apache/kafka/pull/19651#discussion_r2093375272
##
clients/clients-integration-tests/src/test/java/org/apache/kafka/clients/consumer/BaseConsumerTest.java:
##
@@ -0,0 +1,247 @@
+/*
+ * Licensed to the Apache Softwar
chia7712 commented on PR #19582:
URL: https://github.com/apache/kafka/pull/19582#issuecomment-2887236918
@m1a2st could you 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 t
YutaLin opened a new pull request, #19749:
URL: https://github.com/apache/kafka/pull/19749
As title
Reviewers:
PoAn Yang [pay...@apache.org](mailto:pay...@apache.org),
Ken Huang [s7133...@gmail.com](mailto:s7133...@gmail.com),
TengYao Chi [frankvi...@apache.org](mailto:fran
dajac commented on PR #19749:
URL: https://github.com/apache/kafka/pull/19749#issuecomment-2888134965
@YutaLin Thanks for the patch. If I remember correctly, there is a section
for group coordinator metrics. Are those missing there?
--
This is an automated message from the Apache Git Serv
apalan60 commented on code in PR #19681:
URL: https://github.com/apache/kafka/pull/19681#discussion_r2093905499
##
storage/src/test/java/org/apache/kafka/admin/RemoteTopicCrudTest.java:
##
@@ -0,0 +1,694 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or mo
[
https://issues.apache.org/jira/browse/KAFKA-19298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Cheng Yi Chang reassigned KAFKA-19298:
--
Assignee: Cheng Yi Chang (was: Chia-Ping Tsai)
> Move RuntimeLoggerManager to server
[
https://issues.apache.org/jira/browse/KAFKA-19044?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17952033#comment-17952033
]
Lucas Brutschy commented on KAFKA-19044:
https://github.com/apache/kafka/pull/19
Andrew Schofield created KAFKA-19290:
Summary: Exploit mapKey optimisation in protocol requests and
responses
Key: KAFKA-19290
URL: https://issues.apache.org/jira/browse/KAFKA-19290
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-19290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17952042#comment-17952042
]
PoAn Yang commented on KAFKA-19290:
---
Hi [~schofielaj], if you're not working on this,
96 matches
Mail list logo
