[
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
Mirro
[
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: MirrorMa
[
https://issues.apache.org/jira/browse/KAFKA-9914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271930#comment-17271930
]
Ravishankar S R commented on KAFKA-9914:
Hi [~qq619618919],
Thanks for your repl
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 automate
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 o
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 Foundatio
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 v
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 Apa
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 KafkaRaftClientSnapshot
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 o
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 t
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 = log.appendAsLeader(
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 = log.appendAsLeader(
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 KafkaStorageExcept
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 ja
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 = log.appendAsLeader(
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 max
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,
Set.
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 A
[
https://issues.apache.org/jira/browse/KAFKA-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17271863#comment-17271863
]
ASF GitHub Bot commented on KAFKA-8930:
---
miguno commented on a change in pull reque
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 a
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 rushe
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 mess
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 d
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 an
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 S
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 stop
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
issue](https://issues.apache.org/jira/browse/KAFKA-12190?focusedCommentId=17267959&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabp
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 mess
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,
leaderEpo
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 Ap
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 buildUsingCreateTim
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 KafkaPrinc
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 messa
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 S
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
@r
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 and
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,
B
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 /
kafka.api.Pl
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 StateDirectory(fina
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 t
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: To
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 a
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 po
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 versi
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 KafkaPr
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 version,
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 buildUsingCreateTime
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 automa
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 t
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 t
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 th
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 so
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 setStreamsUnca
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 StateDirectory(fi
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
serialization/deserializa
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,
this.c
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 messag
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 A
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,
this.chann
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 and
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 snapsh
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 Gi
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 readyToProc
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,
requestQueue.put(re
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 us
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 Buf
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 automat
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.
S
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 Fo
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 222 matches
Mail list logo