[
https://issues.apache.org/jira/browse/KAFKA-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban updated KAFKA-10586:
-
Description:
KIP-382 introduced MirrorMaker 2.0. Because of scoping issues, the dedicated
[
https://issues.apache.org/jira/browse/KAFKA-10586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Daniel Urban updated KAFKA-10586:
-
Summary: Full support for distributed mode in dedicated MirrorMaker 2.0
clusters (was:
[
https://issues.apache.org/jira/browse/KAFKA-9914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271930#comment-17271930
]
Ravishankar S R commented on KAFKA-9914:
Hi [~qq619618919],
Thanks for your reply. I did try by
liusheng commented on pull request #9872:
URL: https://github.com/apache/kafka/pull/9872#issuecomment-767347463
Thanks for bringing this up, hope more and more Big-data projects can run on
ARM platform :)
This is an
wilkinsona commented on pull request #9968:
URL: https://github.com/apache/kafka/pull/9968#issuecomment-767337053
Thanks again.
This is an automated message from the Apache Git Service.
To respond to the message, please log
chia7712 commented on a change in pull request #9641:
URL: https://github.com/apache/kafka/pull/9641#discussion_r564260770
##
File path:
connect/runtime/src/main/resources/common/message/ConnectAssignment.json
##
@@ -0,0 +1,36 @@
+// Licensed to the Apache Software Foundation
dengziming commented on a change in pull request #9641:
URL: https://github.com/apache/kafka/pull/9641#discussion_r564255280
##
File path:
connect/runtime/src/main/resources/common/message/ConnectAssignment.json
##
@@ -0,0 +1,36 @@
+// Licensed to the Apache Software
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r564251634
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -2216,7 +2316,7 @@ public void complete() {
// These fields are
chia7712 commented on pull request #9971:
URL: https://github.com/apache/kafka/pull/9971#issuecomment-767317353
```logSegments``` is thread-safe so is the copy necessary in this case?
This is an automated message from the
Jason Gustafson created KAFKA-12238:
---
Summary: Implement DescribeProducers API
Key: KAFKA-12238
URL: https://issues.apache.org/jira/browse/KAFKA-12238
Project: Kafka
Issue Type: Sub-task
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r564245683
##
File path:
raft/src/test/java/org/apache/kafka/raft/KafkaRaftClientSnapshotTest.java
##
@@ -43,7 +44,59 @@
final public class
hachikuji commented on pull request #9268:
URL: https://github.com/apache/kafka/pull/9268#issuecomment-767316273
Closing this since clearly no one wants to review . I will split it up
into a set of smaller PRs.
This is an
hachikuji closed pull request #9268:
URL: https://github.com/apache/kafka/pull/9268
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
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r564244777
##
File path: raft/src/main/java/org/apache/kafka/raft/ReplicatedLog.java
##
@@ -106,6 +120,14 @@
*/
void updateHighWatermark(LogOffsetMetadata
chia7712 merged pull request #9966:
URL: https://github.com/apache/kafka/pull/9966
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
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r564243924
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -69,23 +82,55 @@ class KafkaMetadataLog(
val appendInfo =
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r564243709
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -69,23 +82,55 @@ class KafkaMetadataLog(
val appendInfo =
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r564243248
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -370,7 +375,9 @@ class Log(@volatile private var _dir: File,
throw new
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r564242549
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -16,28 +16,41 @@
*/
package kafka.raft
+import java.nio.file.Files
import
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r564242245
##
File path: core/src/main/scala/kafka/raft/KafkaMetadataLog.scala
##
@@ -69,23 +82,55 @@ class KafkaMetadataLog(
val appendInfo =
chia7712 commented on pull request #9970:
URL: https://github.com/apache/kafka/pull/9970#issuecomment-767313055
@dengziming Thanks for your patch.
Does this patch want to adjust "count" to make sure it is NOT out of bound
of file size? If so, it may be redundant as the "count" is
dengziming commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r564224916
##
File path: core/src/main/scala/kafka/server/KafkaApis.scala
##
@@ -1223,7 +1247,7 @@ class KafkaApis(val requestChannel: RequestChannel,
chia7712 commented on a change in pull request #9641:
URL: https://github.com/apache/kafka/pull/9641#discussion_r564213503
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/ConnectProtocol.java
##
@@ -43,96 +27,9 @@
* joining the group
dengziming commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r564222778
##
File path:
core/src/test/scala/integration/kafka/server/MetadataRequestBetweenDifferentIbpTest.scala
##
@@ -0,0 +1,125 @@
+/**
+ * Licensed to the
[
https://issues.apache.org/jira/browse/KAFKA-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17271863#comment-17271863
]
ASF GitHub Bot commented on KAFKA-8930:
---
miguno commented on a change in pull request #324:
URL:
ableegoldman commented on pull request #9968:
URL: https://github.com/apache/kafka/pull/9968#issuecomment-767284407
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
jsancio commented on a change in pull request #9816:
URL: https://github.com/apache/kafka/pull/9816#discussion_r564212153
##
File path: raft/src/main/java/org/apache/kafka/raft/KafkaRaftClient.java
##
@@ -963,49 +979,111 @@ private FetchResponseData tryCompleteFetchRequest(
ableegoldman merged pull request #9968:
URL: https://github.com/apache/kafka/pull/9968
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go
ableegoldman commented on pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#issuecomment-767286649
@garyrussell I just merged the 2.6 PR so we'll be ready to go if/when the
2.6.2 release is started. To be honest I'm not sure how likely it is for a
2.6.2 release to be
ijuma commented on pull request #9960:
URL: https://github.com/apache/kafka/pull/9960#issuecomment-766742269
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
bbejeck commented on pull request #9738:
URL: https://github.com/apache/kafka/pull/9738#issuecomment-766907703
ping @mdespriee feature freeze for 2.8 is approaching it would be great to
get this in.
This is an automated
jolshan commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r563861257
##
File path: core/src/main/scala/kafka/admin/TopicCommand.scala
##
@@ -313,42 +313,57 @@ object TopicCommand extends Logging {
}
override def
tombentley commented on pull request #9441:
URL: https://github.com/apache/kafka/pull/9441#issuecomment-766880511
Rebased for conflict.
@guozhangwang @cadonna @hachikuji please could one of you take a look?
This is
showuon commented on a change in pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#discussion_r563527151
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -109,16 +109,27 @@ public StateDirectory(final
kowshik commented on pull request #9966:
URL: https://github.com/apache/kafka/pull/9966#issuecomment-767042371
cc @junrao for review
This is an automated message from the Apache Git Service.
To respond to the message, please
ableegoldman merged pull request #9947:
URL: https://github.com/apache/kafka/pull/9947
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
kkonstantine commented on a change in pull request #9942:
URL: https://github.com/apache/kafka/pull/9942#discussion_r564046001
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/util/clusters/EmbeddedConnectCluster.java
##
@@ -157,6 +160,7 @@ public void
JimGalasyn commented on a change in pull request #9969:
URL: https://github.com/apache/kafka/pull/9969#discussion_r564106498
##
File path: docs/streams/architecture.html
##
@@ -110,6 +110,11 @@
garyrussell commented on pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#issuecomment-767150460
As I [commented on the JIRA
kkonstantine commented on pull request #9942:
URL: https://github.com/apache/kafka/pull/9942#issuecomment-767272618
Indeed @showuon
jdk8 and 15 are green. Thanks for the non-obvious fix.
LGTM
This is an automated
chia7712 commented on pull request #9943:
URL: https://github.com/apache/kafka/pull/9943#issuecomment-766622703
@hongshaoyang Thanks for your patch!
This is an automated message from the Apache Git Service.
To respond to the
kowshik commented on pull request #9971:
URL: https://github.com/apache/kafka/pull/9971#issuecomment-767252255
cc @junrao for review
This is an automated message from the Apache Git Service.
To respond to the message, please
hachikuji commented on a change in pull request #9739:
URL: https://github.com/apache/kafka/pull/9739#discussion_r563941848
##
File path: core/src/main/scala/kafka/log/Log.scala
##
@@ -1057,7 +1057,8 @@ class Log(@volatile private var _dir: File,
guozhangwang commented on pull request #9840:
URL: https://github.com/apache/kafka/pull/9840#issuecomment-767024409
I've just kicked another test. Please feel free to merge afterwards.
This is an automated message from the
g1geordie commented on a change in pull request #9906:
URL: https://github.com/apache/kafka/pull/9906#discussion_r563480062
##
File path:
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsBuilderTest.java
##
@@ -455,20 +460,19 @@ public void
ijuma commented on a change in pull request #9960:
URL: https://github.com/apache/kafka/pull/9960#discussion_r563524752
##
File path:
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultKafkaPrincipalBuilder.java
##
@@ -188,9 +185,7 @@ public
urbandan commented on pull request #9430:
URL: https://github.com/apache/kafka/pull/9430#issuecomment-766923270
@dajac Thank you for your review. Managed to work on this, and addressed
your points.
This is an automated
jolshan edited a comment on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-766972011
Thanks for the updates and all the hard work! I added a few comments. Mostly
just questions for clarification.
hachikuji commented on pull request #9958:
URL: https://github.com/apache/kafka/pull/9958#issuecomment-766599612
cc @dajac No hurry, but if you have time, please take a look.
This is an automated message from the Apache Git
twobeeb commented on pull request #9589:
URL: https://github.com/apache/kafka/pull/9589#issuecomment-766978261
Hi @ryannedolan @hachikuji
I'd like a definitive direction from you on this subject.
Once again, I reiterate on my personal preference as expressed previously by
wilkinsona commented on pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#issuecomment-766751169
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
jsancio commented on a change in pull request #9819:
URL: https://github.com/apache/kafka/pull/9819#discussion_r564124971
##
File path: clients/src/main/java/org/apache/kafka/common/utils/Utils.java
##
@@ -1098,6 +1099,29 @@ public static void writeFully(FileChannel channel,
ijuma merged pull request #9960:
URL: https://github.com/apache/kafka/pull/9960
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
chia7712 commented on pull request #9931:
URL: https://github.com/apache/kafka/pull/9931#issuecomment-766615980
```
org.apache.kafka.streams.integration.AdjustStreamThreadCountTest.shouldAddAndRemoveStreamThreadsWhileKeepingNamesCorrect
```
```
Build / JDK 11 /
wilkinsona commented on a change in pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#discussion_r563652131
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -109,16 +109,27 @@ public
chia7712 merged pull request #9931:
URL: https://github.com/apache/kafka/pull/9931
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
wcarlson5 commented on pull request #9720:
URL: https://github.com/apache/kafka/pull/9720#issuecomment-767090922
@mjsax it looks like there is one unrelated failure
`java.lang.RuntimeException: java.util.concurrent.ExecutionException:
org.apache.kafka.common.errors.TopicExistsException:
showuon edited a comment on pull request #9942:
URL: https://github.com/apache/kafka/pull/9942#issuecomment-766574155
@kkonstantine , thanks for the comments. Answer your questions below:
1. Have you noticed how often that happens (every time or occasionally)?
--> I'd say, it happens
ableegoldman commented on pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#issuecomment-767051785
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
hachikuji commented on a change in pull request #9819:
URL: https://github.com/apache/kafka/pull/9819#discussion_r563488709
##
File path: clients/src/main/java/org/apache/kafka/common/record/FileRecords.java
##
@@ -134,6 +134,16 @@ public void readInto(ByteBuffer buffer, int
chia7712 commented on a change in pull request #9961:
URL: https://github.com/apache/kafka/pull/9961#discussion_r563535369
##
File path:
clients/src/test/java/org/apache/kafka/common/message/MessageTest.java
##
@@ -1006,12 +977,6 @@ private void verifyWriteSucceeds(short
g1geordie commented on pull request #9950:
URL: https://github.com/apache/kafka/pull/9950#issuecomment-766586309
@sknop hello , It seems like there are some style error .
You can use `./gradlew checkstyleMain checkstyleTest` to cehck .
chia7712 commented on a change in pull request #9960:
URL: https://github.com/apache/kafka/pull/9960#discussion_r563481973
##
File path:
clients/src/main/java/org/apache/kafka/common/security/authenticator/DefaultKafkaPrincipalBuilder.java
##
@@ -188,9 +185,7 @@ public
ijuma commented on a change in pull request #9961:
URL: https://github.com/apache/kafka/pull/9961#discussion_r563528446
##
File path:
clients/src/test/java/org/apache/kafka/common/message/MessageTest.java
##
@@ -1006,12 +977,6 @@ private void verifyWriteSucceeds(short
chia7712 commented on a change in pull request #9906:
URL: https://github.com/apache/kafka/pull/9906#discussion_r563469378
##
File path:
clients/src/test/java/org/apache/kafka/common/record/MemoryRecordsBuilderTest.java
##
@@ -455,20 +460,19 @@ public void
dengziming commented on pull request #9970:
URL: https://github.com/apache/kafka/pull/9970#issuecomment-767242636
Hi, @junrao , PTAL.
This is changed in #2140 , also ping @chia7712 @hachikuji to check it.
This is an
chia7712 merged pull request #9943:
URL: https://github.com/apache/kafka/pull/9943
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
sknop commented on pull request #9950:
URL: https://github.com/apache/kafka/pull/9950#issuecomment-766939861
> @sknop hello , It seems like there are some style error .
> You can use `./gradlew checkstyleMain checkstyleTest` to cehck .
Thank you for your feedback. I have adjusted
C0urante commented on a change in pull request #9805:
URL: https://github.com/apache/kafka/pull/9805#discussion_r563760581
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java
##
@@ -50,7 +50,6 @@
* to workers.
*/
wilkinsona edited a comment on pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#issuecomment-766751169
I think all the review comments have now been addressed. Please let me know
if you'd like the commits to be squashed into one.
rajinisivaram commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r563620794
##
File path:
core/src/test/scala/integration/kafka/server/MetadataRequestBetweenDifferentIbpTest.scala
##
@@ -0,0 +1,117 @@
+/**
+ * Licensed to
ableegoldman commented on pull request #9671:
URL: https://github.com/apache/kafka/pull/9671#issuecomment-767278329
Ok I think I've gotten to the bottom of this hanging test, and pushed a fix.
Tests seem to be passing reliably for me locally. Aiming to get this merged in
the next day or
ableegoldman commented on a change in pull request #9863:
URL: https://github.com/apache/kafka/pull/9863#discussion_r563978428
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -612,11 +612,22 @@ public void
ableegoldman commented on a change in pull request #9947:
URL: https://github.com/apache/kafka/pull/9947#discussion_r563979615
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StateDirectory.java
##
@@ -109,16 +109,27 @@ public
dengziming edited a comment on pull request #9960:
URL: https://github.com/apache/kafka/pull/9960#issuecomment-766745732
Yes, #9766 is trying to replace Struct in`StickyAssignor`. I am not sure
about removing Struct class, I will try to check it, but we can remove
dengziming commented on a change in pull request #2140:
URL: https://github.com/apache/kafka/pull/2140#discussion_r563471404
##
File path: clients/src/main/java/org/apache/kafka/common/record/FileRecords.java
##
@@ -44,83 +53,435 @@ public FileRecords(File file,
dengziming commented on pull request #9965:
URL: https://github.com/apache/kafka/pull/9965#issuecomment-766857476
@guozhangwang , hello, PTAL.
This is an automated message from the Apache Git Service.
To respond to the
dengziming commented on a change in pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#discussion_r563708864
##
File path:
core/src/test/scala/integration/kafka/server/MetadataRequestBetweenDifferentIbpTest.scala
##
@@ -0,0 +1,117 @@
+/**
+ * Licensed to the
junrao commented on a change in pull request #2140:
URL: https://github.com/apache/kafka/pull/2140#discussion_r563909128
##
File path: clients/src/main/java/org/apache/kafka/common/record/FileRecords.java
##
@@ -44,83 +53,435 @@ public FileRecords(File file,
kkonstantine commented on a change in pull request #9805:
URL: https://github.com/apache/kafka/pull/9805#discussion_r563487426
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/WorkerCoordinator.java
##
@@ -50,7 +50,6 @@
* to workers.
dengziming commented on pull request #9960:
URL: https://github.com/apache/kafka/pull/9960#issuecomment-766736615
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
dengziming commented on a change in pull request #9819:
URL: https://github.com/apache/kafka/pull/9819#discussion_r563617104
##
File path: clients/src/main/resources/common/message/FetchSnapshotResponse.json
##
@@ -51,8 +51,8 @@
"about": "The total size of the
ijuma commented on pull request #9641:
URL: https://github.com/apache/kafka/pull/9641#issuecomment-766740318
cc @kkonstantine
This is an automated message from the Apache Git Service.
To respond to the message, please log on
urbandan commented on a change in pull request #9430:
URL: https://github.com/apache/kafka/pull/9430#discussion_r563667979
##
File path: core/src/main/scala/kafka/tools/GetOffsetShell.scala
##
@@ -33,15 +35,26 @@ object GetOffsetShell {
def main(args: Array[String]): Unit
kkonstantine merged pull request #9942:
URL: https://github.com/apache/kafka/pull/9942
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
wcarlson5 commented on pull request #9969:
URL: https://github.com/apache/kafka/pull/9969#issuecomment-767148249
@mjsax @JimGalasyn I took a stab at updating the docs for a couple of kips.
Let me know if there is anywhere I missed
chia7712 commented on pull request #9906:
URL: https://github.com/apache/kafka/pull/9906#issuecomment-766549241
@g1geordie Could you merge trunk to include the recent bug fixes?
This is an automated message from the Apache
guozhangwang commented on a change in pull request #9840:
URL: https://github.com/apache/kafka/pull/9840#discussion_r563952224
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java
##
@@ -123,9 +123,9 @@ public boolean
jolshan commented on pull request #9769:
URL: https://github.com/apache/kafka/pull/9769#issuecomment-766972011
I added a few comments. Mostly just questions for clarification.
This is an automated message from the Apache Git
dajac commented on pull request #9430:
URL: https://github.com/apache/kafka/pull/9430#issuecomment-766990569
@urbandan Thanks for the update. I will make another pass on it this week.
It seems that there are compilation error. Could you take a look please?
ijuma commented on a change in pull request #9912:
URL: https://github.com/apache/kafka/pull/9912#discussion_r563455980
##
File path: core/src/main/scala/kafka/network/RequestChannel.scala
##
@@ -371,9 +372,44 @@ class RequestChannel(val queueSize: Int,
showuon commented on pull request #9942:
URL: https://github.com/apache/kafka/pull/9942#issuecomment-766495717
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
luben commented on pull request #9957:
URL: https://github.com/apache/kafka/pull/9957#issuecomment-766429641
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
ijuma merged pull request #9957:
URL: https://github.com/apache/kafka/pull/9957
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
luben edited a comment on pull request #9957:
URL: https://github.com/apache/kafka/pull/9957#issuecomment-766508115
> BTW, are you going to implement zstd buffer pool by our buffer supplier
(even though #9229 is not merged)?
I think it would be good next step. I looked at Kafka's
ijuma commented on pull request #9957:
URL: https://github.com/apache/kafka/pull/9957#issuecomment-766439012
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
showuon commented on pull request #9627:
URL: https://github.com/apache/kafka/pull/9627#issuecomment-766499389
@abbccdda @guozhangwang , please help review this PR. I believe it impacts
some users. Thanks.
This is an
rgo edited a comment on pull request #9937:
URL: https://github.com/apache/kafka/pull/9937#issuecomment-763768428
@jeqo I've closed the old PR https://github.com/apache/kafka/pull/9387
because it was a mess with all the merge commits, rebased commits and conflicts
with latest changes.
g1geordie commented on a change in pull request #9954:
URL: https://github.com/apache/kafka/pull/9954#discussion_r563435977
##
File path:
clients/src/main/java/org/apache/kafka/common/utils/FilterByKeyIterator.java
##
@@ -0,0 +1,46 @@
+/*
+ * Licensed to the Apache Software
kkonstantine merged pull request #9942:
URL: https://github.com/apache/kafka/pull/9942
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
1 - 100 of 220 matches
Mail list logo
