showuon commented on PR #12729:
URL: https://github.com/apache/kafka/pull/12729#issuecomment-1338855328
@aglicacha , there is compile error, could you 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
UR
lihaosky commented on code in PR #12944:
URL: https://github.com/apache/kafka/pull/12944#discussion_r1040472261
##
streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java:
##
@@ -1088,6 +1088,28 @@ public void
shouldTriggerRecordingOfRocksDBMetricsIfRecordingLevelI
[
https://issues.apache.org/jira/browse/KAFKA-14440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643642#comment-17643642
]
Matthias J. Sax commented on KAFKA-14440:
-
What you observe is behavior by-desig
[
https://issues.apache.org/jira/browse/KAFKA-14440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax resolved KAFKA-14440.
-
Resolution: Duplicate
> Local state wipeout with EOS
>
>
>
showuon merged PR #12908:
URL: https://github.com/apache/kafka/pull/12908
--
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.
showuon commented on PR #12908:
URL: https://github.com/apache/kafka/pull/12908#issuecomment-1338657516
Failed tests are unrelated
```
Build / JDK 17 and Scala 2.13 /
org.apache.kafka.common.network.SslVersionsTransportLayerTest.tlsServerProtocol
= [TLSv1.2, TLSv1.3], tlsClientProtoco
cmccabe opened a new pull request, #12958:
URL: https://github.com/apache/kafka/pull/12958
Split out the logic for applying dynamic configurations to a KafkaConfig
object from BrokerMetadataPublisher into a new class, DynamicConfigPublisher.
This will allow the ControllerServer to also run
mjsax commented on code in PR #12944:
URL: https://github.com/apache/kafka/pull/12944#discussion_r1040281808
##
streams/src/test/java/org/apache/kafka/streams/KafkaStreamsTest.java:
##
@@ -1088,6 +1088,28 @@ public void
shouldTriggerRecordingOfRocksDBMetricsIfRecordingLevelIsDe
anatasiavela opened a new pull request, #12957:
URL: https://github.com/apache/kafka/pull/12957
Cherry-pick of
[ae45c59](https://github.com/apache/kafka/commit/ae45c59e61c34fcf1abb5d4731a99d400d2c79be).
This PR fixes the flaky
SocketServerTest.testClientDisconnectionUpdatesRequestMet
andymg3 commented on code in PR #12892:
URL: https://github.com/apache/kafka/pull/12892#discussion_r1037646348
##
metadata/src/main/java/org/apache/kafka/metadata/placement/PartitionAssignment.java:
##
@@ -0,0 +1,40 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) und
artemlivshits commented on code in PR #12956:
URL: https://github.com/apache/kafka/pull/12956#discussion_r1040244300
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/Fetcher.java:
##
@@ -1154,7 +1155,9 @@ Node selectReadReplica(TopicPartition partition, Node
artemlivshits opened a new pull request, #12956:
URL: https://github.com/apache/kafka/pull/12956
KAFKA-14379: consumer should refresh preferred read replica on update
metadata
The consumer (fetcher) used to refresh the preferred read replica on
three conditions:
1. t
ableegoldman commented on code in PR #12903:
URL: https://github.com/apache/kafka/pull/12903#discussion_r1040224575
##
streams/src/main/java/org/apache/kafka/streams/state/internals/ThreadCache.java:
##
@@ -81,9 +85,11 @@ public synchronized void resize(final long
newCacheSizeB
A. Sophie Blee-Goldman created KAFKA-1:
--
Summary: Simplify user experience of customizing partitioning
strategy in Streams
Key: KAFKA-1
URL: https://issues.apache.org/jira/browse/KAFKA-1
[
https://issues.apache.org/jira/browse/KAFKA-14438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643596#comment-17643596
]
Philip Nee commented on KAFKA-14438:
I think we could un-support the groupId="" afte
[
https://issues.apache.org/jira/browse/KAFKA-14438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643592#comment-17643592
]
Kirk True commented on KAFKA-14438:
---
[~pnee] - is this something you want to provide a
[
https://issues.apache.org/jira/browse/KAFKA-14438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643591#comment-17643591
]
Kirk True commented on KAFKA-14438:
---
+1
> Stop supporting empty consumer groupId
> --
andymg3 commented on code in PR #12892:
URL: https://github.com/apache/kafka/pull/12892#discussion_r1037481276
##
metadata/src/main/java/org/apache/kafka/metadata/placement/TopicAssignment.java:
##
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under o
andymg3 commented on code in PR #12892:
URL: https://github.com/apache/kafka/pull/12892#discussion_r1037646184
##
metadata/src/main/java/org/apache/kafka/metadata/placement/TopicAssignment.java:
##
@@ -0,0 +1,39 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under o
divijvaidya commented on PR #12940:
URL: https://github.com/apache/kafka/pull/12940#issuecomment-1338178759
I am moving this PR to draft mode. Please hold the review.
I need to add a proof here that the when we relax synchronisation amongst
operations in this class by allowing concurr
[
https://issues.apache.org/jira/browse/KAFKA-14398?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Proven Provenzano resolved KAFKA-14398.
---
Resolution: Resolved
> Update EndToEndAuthorizerTest.scala to test with ZK and KRAFT
OmniaGM commented on code in PR #12955:
URL: https://github.com/apache/kafka/pull/12955#discussion_r1040002739
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java:
##
@@ -159,8 +159,11 @@ Collection listConsumerGroups()
}
pr
OmniaGM commented on code in PR #12955:
URL: https://github.com/apache/kafka/pull/12955#discussion_r1040002739
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointConnector.java:
##
@@ -159,8 +159,11 @@ Collection listConsumerGroups()
}
pr
gharris1727 commented on PR #12955:
URL: https://github.com/apache/kafka/pull/12955#issuecomment-1337986105
cc @OmniaGM @tombentley @mimaison
This is a regression introduced in #12577 and should be merged to all
branches which have that feature (AFAIU, only trunk presently.)
--
Thi
gharris1727 opened a new pull request, #12955:
URL: https://github.com/apache/kafka/pull/12955
The MirrorCheckpointConnector, MirrorHeartbeatConnector, and
MirrorSourceConnector all create internal topics, but leak the Admin client
used to do so. Instead, this Admin client should be persist
Greg Harris created KAFKA-14443:
---
Summary: Mirror Maker Connectors leak admin clients used for topic
creation
Key: KAFKA-14443
URL: https://issues.apache.org/jira/browse/KAFKA-14443
Project: Kafka
ijuma commented on PR #12948:
URL: https://github.com/apache/kafka/pull/12948#issuecomment-1337904630
Interesting failure with Java 19:
> 09:03:40 Gradle Test Run :core:integrationTest > Gradle Test Executor 166
> DynamicBrokerReconfigurationTest > testTrustStoreAlter(String) >
kafk
[
https://issues.apache.org/jira/browse/KAFKA-14439?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643491#comment-17643491
]
David Jacot commented on KAFKA-14439:
-
+1 for having supported errors in the protoco
yashmayya commented on code in PR #12800:
URL: https://github.com/apache/kafka/pull/12800#discussion_r1039917846
##
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java:
##
@@ -329,6 +329,60 @@ public void testGetSetNull() throws Except
gharris1727 commented on PR #12937:
URL: https://github.com/apache/kafka/pull/12937#issuecomment-1337868192
@C0urante Could you take a look at this? TIA!
--
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
ijuma commented on PR #12939:
URL: https://github.com/apache/kafka/pull/12939#issuecomment-1337848624
Well spotted, thanks.
--
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-12671?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17643477#comment-17643477
]
Justine Olshan commented on KAFKA-12671:
KIP-890 should be able to help with thi
mimaison commented on code in PR #12366:
URL: https://github.com/apache/kafka/pull/12366#discussion_r1039892964
##
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorSourceConnector.java:
##
@@ -69,6 +75,8 @@ public class MirrorSourceConnector extends SourceConne
dajac commented on code in PR #12954:
URL: https://github.com/apache/kafka/pull/12954#discussion_r1039862483
##
clients/src/test/java/org/apache/kafka/clients/consumer/internals/ConsumerProtocolTest.java:
##
@@ -56,7 +56,7 @@ public void serializeDeserializeSubscriptionAllVersio
C0urante commented on code in PR #12802:
URL: https://github.com/apache/kafka/pull/12802#discussion_r1039787775
##
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java:
##
@@ -1645,6 +1646,8 @@ private void startAndStop(Collection>
c
dajac commented on code in PR #12914:
URL: https://github.com/apache/kafka/pull/12914#discussion_r1039767650
##
clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java:
##
@@ -76,43 +88,145 @@ private Map>
consumersPerTopic(Map> topicToConsumers = new HashMap
rajinisivaram commented on code in PR #12914:
URL: https://github.com/apache/kafka/pull/12914#discussion_r1039763712
##
clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java:
##
@@ -76,43 +88,145 @@ private Map>
consumersPerTopic(Map> topicToConsumers = new
dajac merged PR #12939:
URL: https://github.com/apache/kafka/pull/12939
--
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
cadonna commented on PR #12935:
URL: https://github.com/apache/kafka/pull/12935#issuecomment-1337593210
@lucasbru Actually, I didn't want to approve. Could you please answer my
questions before I merge?
--
This is an automated message from the Apache Git Service.
To respond to the message
cadonna commented on code in PR #12935:
URL: https://github.com/apache/kafka/pull/12935#discussion_r1039754929
##
streams/src/main/java/org/apache/kafka/streams/state/internals/RocksDBStore.java:
##
@@ -526,6 +521,9 @@ public synchronized void close() {
fOptions.close()
C0urante commented on code in PR #12800:
URL: https://github.com/apache/kafka/pull/12800#discussion_r1039745954
##
connect/runtime/src/test/java/org/apache/kafka/connect/storage/KafkaOffsetBackingStoreTest.java:
##
@@ -329,6 +329,60 @@ public void testGetSetNull() throws Excepti
jonathan-albrecht-ibm commented on code in PR #12343:
URL: https://github.com/apache/kafka/pull/12343#discussion_r1039745728
##
clients/src/main/java/org/apache/kafka/common/utils/Java.java:
##
@@ -44,6 +44,10 @@ public static boolean isIbmJdk() {
return System.getPrope
rajinisivaram commented on code in PR #12914:
URL: https://github.com/apache/kafka/pull/12914#discussion_r1039723313
##
clients/src/main/java/org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor.java:
##
@@ -84,13 +110,65 @@ protected static List partitions(Stri
C0urante commented on code in PR #12947:
URL: https://github.com/apache/kafka/pull/12947#discussion_r1039714073
##
connect/runtime/src/main/java/org/apache/kafka/connect/cli/ConnectStandalone.java:
##
@@ -21,41 +21,51 @@
import org.apache.kafka.common.utils.Utils;
import
org.
ijuma commented on PR #12951:
URL: https://github.com/apache/kafka/pull/12951#issuecomment-1337534591
> It would be very useful to new contributors if you could add this
information (about package structure/ownership) to
https://kafka.apache.org/coding-guide or a package info file.
W
ijuma commented on code in PR #12343:
URL: https://github.com/apache/kafka/pull/12343#discussion_r1039711882
##
clients/src/test/java/org/apache/kafka/common/utils/JavaTest.java:
##
@@ -46,9 +49,22 @@ public void testIsIBMJdk() {
assertTrue(Java.isIbmJdk());
}
+
jonathan-albrecht-ibm commented on code in PR #12343:
URL: https://github.com/apache/kafka/pull/12343#discussion_r1039696317
##
clients/src/test/java/org/apache/kafka/common/utils/JavaTest.java:
##
@@ -46,9 +49,22 @@ public void testIsIBMJdk() {
assertTrue(Java.isIbmJdk
rajinisivaram closed pull request #12914: KAFKA-14352: Rack-aware consumer
partition assignment (KIP-881)
URL: https://github.com/apache/kafka/pull/12914
--
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
rajinisivaram commented on PR #12914:
URL: https://github.com/apache/kafka/pull/12914#issuecomment-1337488793
@dajac Opened https://github.com/apache/kafka/pull/12954 with just the
protocol changes. Please take a look when you have time. I will close this PR.
Thank you!
--
This is an aut
C0urante merged PR #12846:
URL: https://github.com/apache/kafka/pull/12846
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache
ijuma commented on code in PR #12343:
URL: https://github.com/apache/kafka/pull/12343#discussion_r1039681666
##
clients/src/main/java/org/apache/kafka/common/utils/Java.java:
##
@@ -44,6 +44,10 @@ public static boolean isIbmJdk() {
return System.getProperty("java.vendor
ijuma commented on code in PR #12343:
URL: https://github.com/apache/kafka/pull/12343#discussion_r1039681666
##
clients/src/main/java/org/apache/kafka/common/utils/Java.java:
##
@@ -44,6 +44,10 @@ public static boolean isIbmJdk() {
return System.getProperty("java.vendor
ijuma commented on code in PR #12343:
URL: https://github.com/apache/kafka/pull/12343#discussion_r1039680283
##
clients/src/test/java/org/apache/kafka/common/utils/JavaTest.java:
##
@@ -46,9 +49,22 @@ public void testIsIBMJdk() {
assertTrue(Java.isIbmJdk());
}
+
rajinisivaram opened a new pull request, #12954:
URL: https://github.com/apache/kafka/pull/12954
Protocol changes for KIP-881 to support rack-aware partition assignment for
consumers. Default assignors will be updated in subsequent PRs to use racks to
improve locality.
### Committer
C0urante commented on code in PR #12846:
URL: https://github.com/apache/kafka/pull/12846#discussion_r1039679491
##
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java:
##
@@ -174,4 +153,84 @@ public void handle(C
C0urante commented on code in PR #12846:
URL: https://github.com/apache/kafka/pull/12846#discussion_r1039679491
##
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java:
##
@@ -174,4 +153,84 @@ public void handle(C
[
https://issues.apache.org/jira/browse/KAFKA-14405?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashmeet Lamba reassigned KAFKA-14405:
-
Assignee: Ashmeet Lamba
> Log a warning when users attempt to set a config controlled b
ijuma commented on PR #12953:
URL: https://github.com/apache/kafka/pull/12953#issuecomment-1337450974
JDK 11 and 17 passed, JDK 8 had 4 unrelated failures:
> Build / JDK 8 and Scala 2.12 /
org.apache.kafka.connect.mirror.integration.MirrorConnectorsWithCustomForwardingAdminIntegration
ijuma merged PR #12953:
URL: https://github.com/apache/kafka/pull/12953
--
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 merged PR #12950:
URL: https://github.com/apache/kafka/pull/12950
--
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
dengziming commented on PR #12946:
URL: https://github.com/apache/kafka/pull/12946#issuecomment-1337436123
Thanks for this PR @mumrah , I have added this to my review backlog and will
take a look this week.
--
This is an automated message from the Apache Git Service.
To respond to the mes
rajinisivaram commented on PR #12914:
URL: https://github.com/apache/kafka/pull/12914#issuecomment-1337328993
@dajac Makes sense, will do that.
--
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
dajac commented on PR #12914:
URL: https://github.com/apache/kafka/pull/12914#issuecomment-1337323399
@rajinisivaram Would it make sense to split into three pull requests? One
for the protocol changes, one for the range and another one for the sticky
assignor. I think that we could definite
rajinisivaram commented on PR #12914:
URL: https://github.com/apache/kafka/pull/12914#issuecomment-1337313522
@dajac Thanks for reviewing the PR. I was thinking of splitting the PR
earlier to include the protocol changes and RangeAssignor changes in the first
PR and move sticky assignor cha
dajac commented on PR #12933:
URL: https://github.com/apache/kafka/pull/12933#issuecomment-1337296109
Merged to trunk. @divijvaidya Thanks for the patch!
--
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
dajac merged PR #12933:
URL: https://github.com/apache/kafka/pull/12933
--
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
divijvaidya commented on PR #12951:
URL: https://github.com/apache/kafka/pull/12951#issuecomment-1337275148
> core should only be used for legacy cli tools and tools that don't require
access to core classes instead of communicating via the kafka protocol
(typically by using the client
cadonna merged PR #12931:
URL: https://github.com/apache/kafka/pull/12931
--
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.
divijvaidya commented on code in PR #12228:
URL: https://github.com/apache/kafka/pull/12228#discussion_r1039472517
##
clients/src/main/java/org/apache/kafka/common/network/Selector.java:
##
@@ -809,6 +810,13 @@ private void maybeCloseOldestConnection(long
currentTimeNanos) {
divijvaidya commented on PR #12228:
URL: https://github.com/apache/kafka/pull/12228#issuecomment-1337176412
Rebased from trunk to fix 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 to th
patrik-marton commented on code in PR #12846:
URL: https://github.com/apache/kafka/pull/12846#discussion_r1039449554
##
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java:
##
@@ -174,4 +153,84 @@ public void han
divijvaidya commented on PR #12590:
URL: https://github.com/apache/kafka/pull/12590#issuecomment-1337141200
@ijuma would you please take a look when you get a chance?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
divijvaidya commented on PR #12228:
URL: https://github.com/apache/kafka/pull/12228#issuecomment-1337140082
@ijuma what are your thoughts on this one? I would either like to discard it
or have it merged since it is pending for a long time! Let me know your
thoughts.
--
This is an automat
patrik-marton commented on code in PR #12846:
URL: https://github.com/apache/kafka/pull/12846#discussion_r1039441717
##
connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilterTest.java:
##
@@ -211,6 +214,18 @@ public void
patrik-marton commented on code in PR #12846:
URL: https://github.com/apache/kafka/pull/12846#discussion_r1039441425
##
connect/basic-auth-extension/src/test/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilterTest.java:
##
@@ -211,6 +214,18 @@ public void
patrik-marton commented on code in PR #12846:
URL: https://github.com/apache/kafka/pull/12846#discussion_r1039440782
##
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java:
##
@@ -174,4 +153,85 @@ public void han
patrik-marton commented on code in PR #12846:
URL: https://github.com/apache/kafka/pull/12846#discussion_r1039440440
##
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java:
##
@@ -174,4 +153,85 @@ public void han
patrik-marton commented on code in PR #12846:
URL: https://github.com/apache/kafka/pull/12846#discussion_r1039439925
##
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java:
##
@@ -174,4 +153,85 @@ public void han
patrik-marton commented on code in PR #12846:
URL: https://github.com/apache/kafka/pull/12846#discussion_r1039439337
##
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java:
##
@@ -174,4 +153,85 @@ public void han
patrik-marton commented on code in PR #12846:
URL: https://github.com/apache/kafka/pull/12846#discussion_r1039438953
##
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java:
##
@@ -174,4 +153,85 @@ public void han
patrik-marton commented on code in PR #12846:
URL: https://github.com/apache/kafka/pull/12846#discussion_r1039438778
##
connect/basic-auth-extension/src/main/java/org/apache/kafka/connect/rest/basic/auth/extension/JaasBasicAuthFilter.java:
##
@@ -174,4 +153,84 @@ public void han
divijvaidya commented on PR #12940:
URL: https://github.com/apache/kafka/pull/12940#issuecomment-1337109469
Thank you for your review @ijuma. I see that you back to reviewing PRs after
a bit of break :)
I did not understand your comment about weaker semantics. I believe that the
sem
Gergo L��p created KAFKA-14442:
--
Summary: GlobalKTable restoration waits requestTimeout during
application restart
Key: KAFKA-14442
URL: https://issues.apache.org/jira/browse/KAFKA-14442
Project: Kafka
vamossagar12 commented on code in PR #12803:
URL: https://github.com/apache/kafka/pull/12803#discussion_r1039384220
##
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java:
##
@@ -459,12 +461,23 @@ private List
rebuildMetadataForSingleTop
omkreddy closed pull request #12812: MINOR: Fix
SaslPlainSslEndToEndAuthorizationTest
URL: https://github.com/apache/kafka/pull/12812
--
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 com
Anuragkillswitch commented on PR #12950:
URL: https://github.com/apache/kafka/pull/12950#issuecomment-1336957971
@ijuma I can see multiple tests failing
https://user-images.githubusercontent.com/70265851/205591295-28e1740b-a57e-42c2-9463-70bca1e53ed9.png";>
e.g.
https://user-images.
dajac merged PR #12850:
URL: https://github.com/apache/kafka/pull/12850
--
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
87 matches
Mail list logo
