dajac merged PR #13357:
URL: https://github.com/apache/kafka/pull/13357
--
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.or
dajac commented on PR #13357:
URL: https://github.com/apache/kafka/pull/13357#issuecomment-1459679650
> Sorry if I missed it somewhere/forgot, but is this saying we will only
allow the new group coordinator for kraft? Or do we have an alternative for ZK?
That's right. At the moment, w
dajac commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1129066723
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java:
##
@@ -1352,8 +1370,22 @@ public void handle(OffsetCommitResponse commitRes
rohits64 opened a new pull request, #13361:
URL: https://github.com/apache/kafka/pull/13361
Here WorkThread dies if any unexpected exception is encountered. Resumed the
WorkThread by creating another thread and offset reading continues. Added test
for this, although the test can be included
[
https://issues.apache.org/jira/browse/KAFKA-14218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697723#comment-17697723
]
Ganesh Sahu commented on KAFKA-14218:
-
Thanks [~showuon] for the prompt reply
> re
[
https://issues.apache.org/jira/browse/KAFKA-4969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax reassigned KAFKA-4969:
--
Assignee: Bill Bejeck
> State-store workload-aware StreamsPartitionAssignor
>
[
https://issues.apache.org/jira/browse/KAFKA-14218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697705#comment-17697705
]
Luke Chen commented on KAFKA-14218:
---
No need to raise a KIP. You can start with some t
[
https://issues.apache.org/jira/browse/KAFKA-14218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697695#comment-17697695
]
Ganesh Sahu edited comment on KAFKA-14218 at 3/8/23 3:00 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-14218?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697695#comment-17697695
]
Ganesh Sahu commented on KAFKA-14218:
-
Greetings team, as no specific members have b
[
https://issues.apache.org/jira/browse/KAFKA-14218?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ganesh Sahu reassigned KAFKA-14218:
---
Assignee: Ganesh Sahu
> replace temp file handler with JUnit 5 Temporary Directory Support
kirktrue commented on code in PR #12813:
URL: https://github.com/apache/kafka/pull/12813#discussion_r1128855661
##
clients/src/main/java/org/apache/kafka/clients/NetworkClient.java:
##
@@ -1279,9 +1283,10 @@ public ClientResponse completed(AbstractResponse
response, long timeMs
[
https://issues.apache.org/jira/browse/KAFKA-14752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee reopened KAFKA-14752:
> improve kafka examples under examples package
> -
>
>
[
https://issues.apache.org/jira/browse/KAFKA-14753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-14753.
Resolution: Fixed
> improve producer under example package
> -
[
https://issues.apache.org/jira/browse/KAFKA-14754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-14754.
Resolution: Fixed
> improve consumer under example package
> -
[
https://issues.apache.org/jira/browse/KAFKA-14752?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Philip Nee resolved KAFKA-14752.
Resolution: Fixed
> improve kafka examples under examples package
> --
guozhangwang merged PR #13354:
URL: https://github.com/apache/kafka/pull/13354
--
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
junrao commented on code in PR #13275:
URL: https://github.com/apache/kafka/pull/13275#discussion_r1128778509
##
storage/src/main/java/org/apache/kafka/storage/internals/log/RemoteIndexCache.java:
##
@@ -0,0 +1,399 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) unde
guozhangwang merged PR #13353:
URL: https://github.com/apache/kafka/pull/13353
--
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
guozhangwang commented on code in PR #13300:
URL: https://github.com/apache/kafka/pull/13300#discussion_r1128785406
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java:
##
@@ -986,6 +987,11 @@ private void prepareChangelogs(final
Set
guozhangwang commented on code in PR #13300:
URL: https://github.com/apache/kafka/pull/13300#discussion_r1128784726
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java:
##
@@ -457,15 +457,9 @@ public long restore(final Map tasks) {
guozhangwang commented on code in PR #13300:
URL: https://github.com/apache/kafka/pull/13300#discussion_r1128784269
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java:
##
@@ -986,6 +987,11 @@ private void prepareChangelogs(final
Set
guozhangwang merged PR #13303:
URL: https://github.com/apache/kafka/pull/13303
--
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
guozhangwang commented on code in PR #13303:
URL: https://github.com/apache/kafka/pull/13303#discussion_r1128780569
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##
@@ -83,12 +92,23 @@
private final Metrics metrics;
p
guozhangwang commented on PR #13303:
URL: https://github.com/apache/kafka/pull/13303#issuecomment-1459067328
> @guozhangwang - Regarding testing the commit results, can we defer this to
the subsequent PR, i.e. verify it once committed() is implemented.
SGTM.
--
This is an automated
guozhangwang commented on code in PR #13318:
URL: https://github.com/apache/kafka/pull/13318#discussion_r1128773556
##
streams/src/test/java/org/apache/kafka/streams/processor/internals/RackAwarenessStreamsPartitionAssignorTest.java:
##
@@ -169,26 +166,6 @@ private void createMo
[
https://issues.apache.org/jira/browse/KAFKA-14792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma resolved KAFKA-14792.
-
Fix Version/s: 3.5.0
Resolution: Fixed
> Race condition in LazyIndex.get()
>
ijuma merged PR #13359:
URL: https://github.com/apache/kafka/pull/13359
--
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.or
ijuma commented on PR #13359:
URL: https://github.com/apache/kafka/pull/13359#issuecomment-1459049434
2 builds passed, 1 failed with 2 unrelated tests:
> Build / JDK 17 and Scala 2.13 /
org.apache.kafka.clients.consumer.internals.CooperativeConsumerCoordinatorTest.testOutdatedCoordina
CalvinConfluent commented on PR #13323:
URL: https://github.com/apache/kafka/pull/13323#issuecomment-1459027103
Changing the old ReplicaId field default value to -1. In this way, we can
easily extract the replicaId from the FetchRequest without knowing the API
version. Simple and minimal wo
CalvinConfluent commented on code in PR #13323:
URL: https://github.com/apache/kafka/pull/13323#discussion_r1128713441
##
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java:
##
@@ -337,8 +362,27 @@ public AbstractResponse getErrorResponse(int
throttleTimeM
CalvinConfluent commented on code in PR #13323:
URL: https://github.com/apache/kafka/pull/13323#discussion_r1128713021
##
clients/src/main/java/org/apache/kafka/common/requests/FetchRequest.java:
##
@@ -302,6 +315,18 @@ public String toString() {
}
}
+public
CalvinConfluent commented on code in PR #13323:
URL: https://github.com/apache/kafka/pull/13323#discussion_r1128712574
##
raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java:
##
@@ -936,13 +937,13 @@ private CompletableFuture
handleFetchRequest(
RaftRequest.I
jolshan commented on code in PR #13357:
URL: https://github.com/apache/kafka/pull/13357#discussion_r1128706720
##
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala:
##
@@ -271,19 +271,28 @@ class BrokerMetadataPublisher(
})
} c
jolshan commented on PR #13357:
URL: https://github.com/apache/kafka/pull/13357#issuecomment-1458991438
Sorry if I missed it somewhere/forgot, but is this saying we will only allow
the new group coordinator for kraft? Or do we have an alternative for ZK?
--
This is an automated message fr
cmccabe opened a new pull request, #13360:
URL: https://github.com/apache/kafka/pull/13360
Fix a bug with authorizer reconfiguration in KRaft mode. The bug happened
because we were invoking DynamicBrokerConfig.addReconfigurables before
initializing BrokerServer.authorizer. Add a test of rec
mumrah commented on code in PR #13337:
URL: https://github.com/apache/kafka/pull/13337#discussion_r1128359363
##
core/src/main/scala/kafka/server/metadata/BrokerMetadataPublisher.scala:
##
@@ -213,7 +213,7 @@ class BrokerMetadataPublisher(
}
// Apply configuratio
philipnee commented on PR #13303:
URL: https://github.com/apache/kafka/pull/13303#issuecomment-1458974950
@guozhangwang - Regarding testing the commit results, can we defer this to
the subsequent PR, i.e. verify it once committed() is implemented.
--
This is an automated message from the
vcrfxia commented on code in PR #13340:
URL: https://github.com/apache/kafka/pull/13340#discussion_r1128682440
##
streams/src/test/java/org/apache/kafka/streams/integration/VersionedKeyValueStoreIntegrationTest.java:
##
@@ -0,0 +1,592 @@
+/*
+ * Licensed to the Apache Software F
cmccabe closed pull request #13332: KAFKA-14057: Support dynamic
reconfiguration in KRaft remote controllers
URL: https://github.com/apache/kafka/pull/13332
--
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
cmccabe commented on PR #13332:
URL: https://github.com/apache/kafka/pull/13332#issuecomment-1458957347
Superseded by #13116
--
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.
cmccabe commented on PR #13337:
URL: https://github.com/apache/kafka/pull/13337#issuecomment-1458906783
rebase on 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 comment.
To u
ijuma commented on code in PR #13359:
URL: https://github.com/apache/kafka/pull/13359#discussion_r1128578938
##
storage/src/main/java/org/apache/kafka/storage/internals/log/LazyIndex.java:
##
@@ -166,20 +166,25 @@ public File file() {
@SuppressWarnings("unchecked")
p
ijuma commented on code in PR #13359:
URL: https://github.com/apache/kafka/pull/13359#discussion_r1128576277
##
storage/src/main/java/org/apache/kafka/storage/internals/log/LazyIndex.java:
##
@@ -166,20 +166,25 @@ public File file() {
@SuppressWarnings("unchecked")
p
ijuma opened a new pull request, #13359:
URL: https://github.com/apache/kafka/pull/13359
`LazyIndex.get()` has a race condition that can result in a
ClassCastException being thrown in some cases.
This was introduced when it was rewritten from Scala to Java.
### Committer Checkl
[
https://issues.apache.org/jira/browse/KAFKA-14792?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ismael Juma updated KAFKA-14792:
Description:
`LazyIndex.get()` has a race condition that can result in a ClassCastException
being
Ismael Juma created KAFKA-14792:
---
Summary: Race condition in LazyIndex.get()
Key: KAFKA-14792
URL: https://issues.apache.org/jira/browse/KAFKA-14792
Project: Kafka
Issue Type: Bug
R
[
https://issues.apache.org/jira/browse/KAFKA-14351?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ron Dagostino resolved KAFKA-14351.
---
Fix Version/s: 3.5.0
Resolution: Fixed
> Implement controller mutation quotas in KRaf
Andrew Grant created KAFKA-14791:
Summary: Create a builder class for PartitionRegistration
Key: KAFKA-14791
URL: https://issues.apache.org/jira/browse/KAFKA-14791
Project: Kafka
Issue Type:
vcrfxia commented on code in PR #13340:
URL: https://github.com/apache/kafka/pull/13340#discussion_r1128550162
##
streams/src/test/java/org/apache/kafka/streams/integration/VersionedKeyValueStoreIntegrationTest.java:
##
@@ -0,0 +1,592 @@
+/*
+ * Licensed to the Apache Software F
philipnee commented on PR #13303:
URL: https://github.com/apache/kafka/pull/13303#issuecomment-1458731526
Hey @rajinisivaram - Thanks! To your comments
`I thought we have those methods on the existing Consumer interface. Anyway,
that doesn't impact this PR.` : The current consumer uses ka
rajinisivaram commented on code in PR #13303:
URL: https://github.com/apache/kafka/pull/13303#discussion_r1128444212
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##
@@ -226,11 +246,20 @@ public void commitAsync(OffsetCommitCal
cmccabe merged PR #13116:
URL: https://github.com/apache/kafka/pull/13116
--
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.
cmccabe commented on PR #13116:
URL: https://github.com/apache/kafka/pull/13116#issuecomment-1458687762
Yes. It is frustrating that we have so many flaky tests. @mumrah is fixing
the `KafkaServerKRaftRegistrationTest`. We may need to fix `SocketServerTest`
too in the near future since it se
rondagostino commented on PR #13116:
URL: https://github.com/apache/kafka/pull/13116#issuecomment-1458662433
There were several test failures (SelectorTest, Tls12SelectorTest,
KafkaServerKRaftRegistrationTest, ListOffsetsRequestWithRemoteStoreTest,
SocketServerTest) but I have seen them in
[
https://issues.apache.org/jira/browse/KAFKA-14786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697567#comment-17697567
]
Yash Mayya commented on KAFKA-14786:
Hi [~ChrisEgerton], I'm assigning this ticket t
[
https://issues.apache.org/jira/browse/KAFKA-14786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yash Mayya reassigned KAFKA-14786:
--
Assignee: Yash Mayya
> Implement connector offset write/reset internal logic
> --
[
https://issues.apache.org/jira/browse/KAFKA-14780?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697562#comment-17697562
]
Kirk True commented on KAFKA-14780:
---
[~adupriez] Yes, that seems like something we sho
lucasbru commented on PR #13318:
URL: https://github.com/apache/kafka/pull/13318#issuecomment-1458578634
I triggered one now:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/5554/console
--
This is an automated message from the Apache Git Service.
To respond to the m
guozhangwang commented on PR #13318:
URL: https://github.com/apache/kafka/pull/13318#issuecomment-1458570328
@lucasbru did you happen to have triggered a system test for this branch as
well?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log
[
https://issues.apache.org/jira/browse/KAFKA-14640?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Justine Olshan resolved KAFKA-14640.
Resolution: Fixed
> Update AddPartitionsToTxn protocol to batch and handle verifyOnly requ
jolshan commented on PR #13231:
URL: https://github.com/apache/kafka/pull/13231#issuecomment-1458557507
for follow ups: https://issues.apache.org/jira/browse/KAFKA-14790
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
Justine Olshan created KAFKA-14790:
--
Summary: Add more AddPartitionsToTxn tests in KafkaApis and
Authorizer tests
Key: KAFKA-14790
URL: https://issues.apache.org/jira/browse/KAFKA-14790
Project: Kafk
jolshan merged PR #13231:
URL: https://github.com/apache/kafka/pull/13231
--
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.
Greg Harris created KAFKA-14789:
---
Summary: Plugin ServiceLoader visibility from isolated plugins is
inconsistent
Key: KAFKA-14789
URL: https://issues.apache.org/jira/browse/KAFKA-14789
Project: Kafka
urbandan commented on PR #10566:
URL: https://github.com/apache/kafka/pull/10566#issuecomment-1458499533
@C0urante Thanks for the prototype, went through the change and left a few
comments. Overall, I think your solution would solve this issue as well. On the
other hand, I still think that
dajac commented on code in PR #13240:
URL: https://github.com/apache/kafka/pull/13240#discussion_r1128110858
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/CommitRequestManager.java:
##
@@ -199,7 +199,8 @@ public NetworkClientDelegate.UnsentRequest
toUnsen
jolshan commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1128156639
##
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala:
##
@@ -231,7 +231,7 @@ class AuthorizerIntegrationTest extends BaseRequestTest {
re
jolshan commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1128154589
##
core/src/test/scala/integration/kafka/api/AuthorizerIntegrationTest.scala:
##
@@ -231,7 +231,7 @@ class AuthorizerIntegrationTest extends BaseRequestTest {
re
Hangleton commented on code in PR #13352:
URL: https://github.com/apache/kafka/pull/13352#discussion_r1128143723
##
clients/src/main/java/org/apache/kafka/common/requests/OffsetFetchRequest.java:
##
@@ -253,38 +284,15 @@ public
List groups() {
}
}
-public Ma
[
https://issues.apache.org/jira/browse/KAFKA-14520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697509#comment-17697509
]
Sagar Rao commented on KAFKA-14520:
---
hi [~waleedfateem] , thanks for filing this. Time
[
https://issues.apache.org/jira/browse/KAFKA-14368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697508#comment-17697508
]
Yash Mayya commented on KAFKA-14368:
Hi [~ChrisEgerton], thanks for updating the tic
dajac commented on code in PR #13231:
URL: https://github.com/apache/kafka/pull/13231#discussion_r1128091331
##
core/src/test/scala/unit/kafka/server/KafkaApisTest.scala:
##
@@ -2030,13 +2032,87 @@ class KafkaApisTest {
val response = capturedResponse.getValue
if
rondagostino commented on code in PR #13116:
URL: https://github.com/apache/kafka/pull/13116#discussion_r1128069250
##
core/src/test/scala/unit/kafka/server/DynamicBrokerConfigTest.scala:
##
@@ -479,6 +489,42 @@ class DynamicBrokerConfigTest {
assertEquals("User:admin", aut
[
https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697387#comment-17697387
]
Andy Coates edited comment on KAFKA-6035 at 3/7/23 3:07 PM:
I
rondagostino commented on PR #13116:
URL: https://github.com/apache/kafka/pull/13116#issuecomment-1458306158
There were 6 test failures across 3 separate builds. All tests pass locally.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on t
C0urante opened a new pull request, #13358:
URL: https://github.com/apache/kafka/pull/13358
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgr
Chia-Ping Tsai created KAFKA-14788:
--
Summary: Add TopicsToDeleteCount and ReplicasToDeleteCount to
QuorumController
Key: KAFKA-14788
URL: https://issues.apache.org/jira/browse/KAFKA-14788
Project: Ka
tinaselenge commented on PR #13102:
URL: https://github.com/apache/kafka/pull/13102#issuecomment-1458147611
@jsancio thank you for catching this and reverting the change!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
hudeqi commented on PR #13348:
URL: https://github.com/apache/kafka/pull/13348#issuecomment-1458087082
Can someone take a look?
--
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 commen
[
https://issues.apache.org/jira/browse/KAFKA-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17697387#comment-17697387
]
Andy Coates commented on KAFKA-6035:
I've had a couple of instances now where I've ha
mimaison commented on code in PR #10244:
URL: https://github.com/apache/kafka/pull/10244#discussion_r1127686145
##
bin/kafka-run-class.sh:
##
@@ -222,6 +234,7 @@ fi
# Log4j settings
if [ -z "$KAFKA_LOG4J_OPTS" ]; then
+ echo "DEPRECATED: using log4j 1.x configuration. To us
jlprat commented on code in PR #13223:
URL: https://github.com/apache/kafka/pull/13223#discussion_r1127673459
##
core/src/main/scala/kafka/server/KafkaRaftServer.scala:
##
@@ -89,7 +89,7 @@ class KafkaRaftServer(
Some(new ControllerServer(
sharedServer,
KafkaR
mimaison commented on code in PR #13351:
URL: https://github.com/apache/kafka/pull/13351#discussion_r1127673083
##
connect/mirror/src/test/java/org/apache/kafka/connect/mirror/MirrorSourceConnectorTest.java:
##
@@ -149,6 +158,51 @@ public void testAclTransformation() {
[
https://issues.apache.org/jira/browse/KAFKA-14770?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Rajini Sivaram resolved KAFKA-14770.
Reviewer: Manikumar
Resolution: Fixed
> Allow dynamic keystore update for brokers if
rajinisivaram merged PR #13346:
URL: https://github.com/apache/kafka/pull/13346
--
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.a
rajinisivaram commented on PR #13346:
URL: https://github.com/apache/kafka/pull/13346#issuecomment-1457851382
@omkreddy @kpatelatwork Thanks for the reviews, test failures not related,
merging to trunk.
--
This is an automated message from the Apache Git Service.
To respond to the message
Hangleton commented on PR #13352:
URL: https://github.com/apache/kafka/pull/13352#issuecomment-1457837585
Hi, Justine (@jolshan), thanks for your help. There is another PR with the
same purpose as this one for the `OffsetCommit` API:
[PR-13240](https://github.com/apache/kafka/pull/13240). P
dajac opened a new pull request, #13357:
URL: https://github.com/apache/kafka/pull/13357
The new group coordinator needs to access cluster metadata (e.g. topics,
partitions, etc.) and it needs a mechanism to be notified when the metadata
changes (e.g. to trigger a rebalance). In KRaft clust
dajac merged PR #13329:
URL: https://github.com/apache/kafka/pull/13329
--
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.or
89 matches
Mail list logo