avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412015236
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/PartitionGroup.java
##
@@ -50,7 +53,7 @@
*/
public class PartitionGroup
leonardge opened a new pull request #8524:
URL: https://github.com/apache/kafka/pull/8524
…ync.
*More detailed description of your change,
if necessary. The PR title and PR message become
the squashed commit message, so use a separate
comment to ping reviewers.*
stanislavkozlovski commented on a change in pull request #8524:
URL: https://github.com/apache/kafka/pull/8524#discussion_r412014026
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1066,6 +1066,7 @@ class KafkaController(val config: KafkaConfig,
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412055008
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -305,6 +297,12 @@ public void resume() {
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412178952
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java
##
@@ -179,6 +179,44 @@ public void
dajac commented on a change in pull request #8238:
URL: https://github.com/apache/kafka/pull/8238#discussion_r412182105
##
File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
##
@@ -1553,6 +1554,50 @@ class KafkaApisTest {
avalsa commented on issue #8221:
URL: https://github.com/apache/kafka/pull/8221#issuecomment-61720
> I saw that the stream time update codepath is missing, could we add it
back? I was thinking about a simpler approach here: since we could not
decrement the stream-time, no matter we
cadonna commented on a change in pull request #8497:
URL: https://github.com/apache/kafka/pull/8497#discussion_r412047332
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ValidClientsByTaskLoadQueue.java
##
@@ -0,0 +1,106 @@
+/*
+ *
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412099165
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -115,7 +115,7 @@ public void suspend() {
}
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412178952
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java
##
@@ -179,6 +179,44 @@ public void
avalsa commented on a change in pull request #8221:
URL: https://github.com/apache/kafka/pull/8221#discussion_r412178952
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/RegexSourceIntegrationTest.java
##
@@ -179,6 +179,44 @@ public void
dajac commented on issue #8509:
URL: https://github.com/apache/kafka/pull/8509#issuecomment-617137684
@apovzner Yeah, you're right. It does not increase the overall coverage.
I spent quite some time in the `KafkaApis` recently and I noticed that its
unit test coverage is quite low.
chia7712 commented on a change in pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#discussion_r412279368
##
File path: core/src/main/scala/kafka/utils/DelayedItem.scala
##
@@ -21,24 +21,24 @@ import java.util.concurrent._
import
chia7712 commented on a change in pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#discussion_r412284404
##
File path: core/src/main/scala/kafka/utils/DelayedItem.scala
##
@@ -21,24 +21,23 @@ import java.util.concurrent._
import
tombentley commented on a change in pull request #8417:
URL: https://github.com/apache/kafka/pull/8417#discussion_r412287986
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java
##
@@ -57,6 +59,10 @@ public ByteBuffer serialize(ApiKeys
bbejeck commented on issue #8504:
URL: https://github.com/apache/kafka/pull/8504#issuecomment-616620722
ping @mjsax and @vvcephei, I know you guys are busy, but do you mind having
a look?
This is an automated message from
vvcephei commented on issue #8497:
URL: https://github.com/apache/kafka/pull/8497#issuecomment-617265836
Test this, please.
This is an automated message from the Apache Git Service.
To respond to the message, please log on
mjsax commented on issue #8508:
URL: https://github.com/apache/kafka/pull/8508#issuecomment-617266065
Java 8 and Java 11 passed.
Java 14: failed with unknown error...
This is an automated message from the Apache Git
vvcephei commented on issue #8497:
URL: https://github.com/apache/kafka/pull/8497#issuecomment-617266153
Test this, please.
This is an automated message from the Apache Git Service.
To respond to the message, please log on
lbradstreet commented on a change in pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#discussion_r412305902
##
File path: core/src/main/scala/kafka/utils/DelayedItem.scala
##
@@ -21,24 +21,23 @@ import java.util.concurrent._
import
vvcephei commented on issue #8497:
URL: https://github.com/apache/kafka/pull/8497#issuecomment-617264248
Test this, please.
This is an automated message from the Apache Git Service.
To respond to the message, please log on
ijuma commented on a change in pull request #8417:
URL: https://github.com/apache/kafka/pull/8417#discussion_r412309101
##
File path:
clients/src/main/java/org/apache/kafka/common/requests/AbstractResponse.java
##
@@ -57,6 +59,10 @@ public ByteBuffer serialize(ApiKeys apiKey,
lbradstreet commented on a change in pull request #8517:
URL: https://github.com/apache/kafka/pull/8517#discussion_r412313524
##
File path: core/src/main/scala/kafka/utils/DelayedItem.scala
##
@@ -21,24 +21,23 @@ import java.util.concurrent._
import
jiameixie opened a new pull request #8559:
URL: https://github.com/apache/kafka/pull/8559
Class kafka.examples.SimpleConsumerDemo was removed. But the
java-simple-consumer-demo.sh
was not removed and README was not updated.
Change-Id: Iff057ce91454b493859ace6c6959e674048e9678
lkokhreidze opened a new pull request #8558:
URL: https://github.com/apache/kafka/pull/8558
Added KIP-221 documentation
https://user-images.githubusercontent.com/8927925/80348679-d5a37800-8876-11ea-90a6-b5e30576efbe.png;>
leonardge commented on pull request #8533:
URL: https://github.com/apache/kafka/pull/8533#issuecomment-619813438
The tests that are failing doesn't seem to be relevant to my change which
are the following:
- kafka.api.TransactionsTest.testBumpTransactionalEpoch
-
tombentley commented on a change in pull request #8311:
URL: https://github.com/apache/kafka/pull/8311#discussion_r415618607
##
File path:
clients/src/test/java/org/apache/kafka/clients/admin/KafkaAdminClientTest.java
##
@@ -3382,6 +3388,70 @@ public void
jiameixie commented on pull request #8559:
URL: https://github.com/apache/kafka/pull/8559#issuecomment-619838295
@hachikuji @guozhangwang Call for review
This is an automated message from the Apache Git Service.
To respond
scoopex opened a new pull request #8573:
URL: https://github.com/apache/kafka/pull/8573
Provides the possibility to append connection infos to all executed commands:
```
$ export KAFKA_OPTS="--bootstrap-server
10.1.1.1:9092,10.1.1.1:9092,10.1.1.1:9092"
kafka-topics.sh --create
jeqo opened a new pull request #8572:
URL: https://github.com/apache/kafka/pull/8572
nit. Protocol docs describe partition numbers as follows:
> Topic partitions themselves are just ordered "commit logs" numbered 0, 1,
..., P.
I assume this is a typo, as partition numbers
bbejeck commented on pull request #8504:
URL: https://github.com/apache/kafka/pull/8504#issuecomment-619376755
>I'm on the fence about whether this is an "optimization" or "reasonable
behavior". It sort of feels like the latter, and the only reason we needed to
introduce the
dengziming opened a new pull request #8552:
URL: https://github.com/apache/kafka/pull/8552
Modify the java docs of ZkReplicaStateMachine, the java docs is not in
agreement with `OfflineReplica.validPreviousStates` and
`OnlineReplica.validPreviousStates`
### Committer Checklist
chia7712 opened a new pull request #8551:
URL: https://github.com/apache/kafka/pull/8551
https://issues.apache.org/jira/browse/KAFKA-9918
the default implementation (**DefaultSslEngineFactory**) does not have any
releasable object so we didn't notice this issue. However, it would be
MikeSchlosser16 commented on pull request #8427:
URL: https://github.com/apache/kafka/pull/8427#issuecomment-619409886
Thanks and noted, @ijuma. I will work on getting one created shortly.
This is an automated message from
chia7712 commented on a change in pull request #8551:
URL: https://github.com/apache/kafka/pull/8551#discussion_r415040205
##
File path:
clients/src/main/java/org/apache/kafka/common/security/ssl/SslFactory.java
##
@@ -230,6 +231,11 @@ public SslEngineFactory
leonardge commented on pull request #8533:
URL: https://github.com/apache/kafka/pull/8533#issuecomment-619397708
Hi @ijuma it will be great if you can re start the tests. Thanks!
This is an automated message from the Apache
leonardge commented on a change in pull request #8524:
URL: https://github.com/apache/kafka/pull/8524#discussion_r415085874
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1068,12 +1068,23 @@ class KafkaController(val config: KafkaConfig,
abbccdda opened a new pull request #8553:
URL: https://github.com/apache/kafka/pull/8553
This integration test is trying to mimic the scenario where the active task
writes an invalid record while the standby task replicates it under
at_least_once. For EOS, it should not happen because the
cadonna commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r415797071
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -713,23 +713,18 @@ private boolean
leonardge edited a comment on pull request #8533:
URL: https://github.com/apache/kafka/pull/8533#issuecomment-620047615
QueryableStateIntegrationTest.shouldAllowConcurrentAccesses JIRA:
https://issues.apache.org/jira/browse/KAFKA-9798
omkreddy commented on pull request #8184:
URL: https://github.com/apache/kafka/pull/8184#issuecomment-620048310
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
tombentley commented on pull request #8450:
URL: https://github.com/apache/kafka/pull/8450#issuecomment-620014014
@ijuma done & rebased for conflict.
This is an automated message from the Apache Git Service.
To
tombentley commented on pull request #8311:
URL: https://github.com/apache/kafka/pull/8311#issuecomment-619986596
Rebased for conflict.
@dajac thanks for the review. I agree about the case of the unexpected
partition. The only way it could happen would be a bug in either the client
showuon opened a new pull request #8560:
URL: https://github.com/apache/kafka/pull/8560
Update the raft introduction link. The old link is not accessible now.
Update to the official usenix conference link where the raft paper published.
It also contains the paper introduction, paper pdf,
leonardge commented on pull request #8533:
URL: https://github.com/apache/kafka/pull/8533#issuecomment-620047615
QueryableStateIntegrationTest.shouldAllowConcurrentAccesses JIRA:
https://issues.apache.org/jira/browse/KAFKA-9798
WanderingStar commented on pull request #8184:
URL: https://github.com/apache/kafka/pull/8184#issuecomment-620043557
Thanks for your review, @omkreddy! I've rebased and incorporated your
feedback.
This is an automated
steverod commented on pull request #8543:
URL: https://github.com/apache/kafka/pull/8543#issuecomment-620710529
> @steverod : There seems to be compilation errors in JDK 8 test?
Hi @junrao -- Yes, there are, but they aren't mine (!!). No, really.
> @steverod : There seems to
pan3793 opened a new pull request #8575:
URL: https://github.com/apache/kafka/pull/8575
https://issues.apache.org/jira/browse/KAFKA-8713
https://cwiki.apache.org/confluence/display/KAFKA/KIP-581:+Value+of+optional+null+field+which+has+default+value
### Committer Checklist
guozhangwang commented on pull request #8564:
URL: https://github.com/apache/kafka/pull/8564#issuecomment-620783397
Also cherry-picked to 2.5.
This is an automated message from the Apache Git Service.
To respond to the
junrao commented on a change in pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#discussion_r416760588
##
File path:
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala
##
@@ -243,9 +245,9 @@ class ReplicaAlterLogDirsThreadTest {
junrao commented on pull request #8566:
URL: https://github.com/apache/kafka/pull/8566#issuecomment-620701631
@leonardge : The failed test seems unrelated to the PR. Could you file a
separate PR to track that?
This is an
vvcephei opened a new pull request #8574:
URL: https://github.com/apache/kafka/pull/8574
* ensure that pseudo-topics get correctly prefixed with the app id at run
time
* update test to expect the app id prefix
### Committer Checklist (excluded from commit message)
- [ ] Verify
ableegoldman commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416814163
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java
##
@@ -158,8 +158,9 @@ public void
guozhangwang commented on pull request #8574:
URL: https://github.com/apache/kafka/pull/8574#issuecomment-620787049
cc @abbccdda @mjsax to take a look?
This is an automated message from the Apache Git Service.
To respond to
kkonstantine commented on pull request #8204:
URL: https://github.com/apache/kafka/pull/8204#issuecomment-620795402
retest this please
This is an automated message from the Apache Git Service.
To respond to the message,
leonardge commented on pull request #8566:
URL: https://github.com/apache/kafka/pull/8566#issuecomment-620716514
Sure will do.
This is an automated message from the Apache Git Service.
To respond to the message, please log
cadonna commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r416761719
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignorTest.java
##
@@ -41,132 +54,107 @@
hachikuji commented on pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#issuecomment-620749823
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please
hachikuji commented on pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#issuecomment-620749686
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on
hachikuji commented on pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#issuecomment-620749977
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please
ableegoldman commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416809469
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/OptimizedKTableIntegrationTest.java
##
@@ -163,8 +159,10 @@ public void
kkonstantine commented on pull request #8204:
URL: https://github.com/apache/kafka/pull/8204#issuecomment-620803829
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log
pan3793 commented on pull request #7112:
URL: https://github.com/apache/kafka/pull/7112#issuecomment-620746182
I do a new implement at https://github.com/apache/kafka/pull/8575 follow the
ableegoldman commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r416810713
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignorTest.java
##
@@ -41,132
hachikuji commented on a change in pull request #8562:
URL: https://github.com/apache/kafka/pull/8562#discussion_r416760519
##
File path:
core/src/test/scala/unit/kafka/server/ReplicaAlterLogDirsThreadTest.scala
##
@@ -243,9 +245,9 @@ class ReplicaAlterLogDirsThreadTest {
vvcephei commented on a change in pull request #8574:
URL: https://github.com/apache/kafka/pull/8574#discussion_r416764158
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/foreignkeyjoin/SubscriptionWrapperSerde.java
##
@@ -76,6 +78,10 @@ public
leonardge commented on pull request #8566:
URL: https://github.com/apache/kafka/pull/8566#issuecomment-620735042
JIRA [here](https://issues.apache.org/jira/browse/KAFKA-9926).
This is an automated message from the Apache Git
junrao commented on pull request #8524:
URL: https://github.com/apache/kafka/pull/8524#issuecomment-620110244
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to
steverod opened a new pull request #8562:
URL: https://github.com/apache/kafka/pull/8562
What
Earlier log test changes went into trunk (for KAFKA-9807, KAFKA-9838) and
were cherry-picked to 2.4, but they broke the Scala 2.11 build.
This change cherry-picks the fixes needed to
omkreddy commented on pull request #8184:
URL: https://github.com/apache/kafka/pull/8184#issuecomment-620145498
JDK 8, 11 tests passed. JDK 14 test failures are not related. Merging to
trunk.
This is an automated message
lkokhreidze commented on pull request #8558:
URL: https://github.com/apache/kafka/pull/8558#issuecomment-620101449
call for review @vvcephei @mjsax
This is an automated message from the Apache Git Service.
To respond to the
ableegoldman commented on a change in pull request #8548:
URL: https://github.com/apache/kafka/pull/8548#discussion_r415991034
##
File path:
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java
##
@@ -1231,13 +1235,13 @@ public void
jeffwidman opened a new pull request #8561:
URL: https://github.com/apache/kafka/pull/8561
Fix typo in mirrormaker 2 configs:
`stoage` --> `storage`
This is an automated message from the Apache Git Service.
To respond to
jeffwidman edited a comment on pull request #2394:
URL: https://github.com/apache/kafka/pull/2394#issuecomment-612325594
That sounds reasonable, created
[KIP-592](https://cwiki.apache.org/confluence/display/KAFKA/KIP-592%3A+MirrorMaker+should+replicate+topics+from+earliest)
and I'll send
ableegoldman commented on pull request #8548:
URL: https://github.com/apache/kafka/pull/8548#issuecomment-620144298
Flaky test failures:
`QueryableStateIntegrationTest.shouldAllowConcurrentAccesses`
jtrenholm-jask commented on pull request #8196:
URL: https://github.com/apache/kafka/pull/8196#issuecomment-620121750
I've found when we restart the kafka leader or remove /controller in zk,
this will usually kick the reassignment and it will continue for a while before
stopping again. Is
ableegoldman commented on a change in pull request #8546:
URL: https://github.com/apache/kafka/pull/8546#discussion_r415994385
##
File path: tests/README.md
##
@@ -36,6 +36,10 @@
TC_PATHS="tests/kafkatest/tests/client/pluggable_test.py::PluggableConsumerTest"
```
mjsax commented on pull request #8564:
URL: https://github.com/apache/kafka/pull/8564#issuecomment-620235837
Makes sense to me. +1
Curious to hear what @guozhangwang @vvcephei think?
This is an automated message from
mjsax commented on pull request #8564:
URL: https://github.com/apache/kafka/pull/8564#issuecomment-620235547
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-620243830
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-620243639
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
junrao commented on a change in pull request #8524:
URL: https://github.com/apache/kafka/pull/8524#discussion_r416164863
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1068,12 +1068,23 @@ class KafkaController(val config: KafkaConfig,
vvcephei commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r416168944
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -713,23 +713,18 @@ private boolean
abbccdda commented on a change in pull request #8549:
URL: https://github.com/apache/kafka/pull/8549#discussion_r416057712
##
File path: core/src/test/scala/unit/kafka/server/KafkaApisTest.scala
##
@@ -297,46 +298,271 @@ class KafkaApisTest {
val topic = "topic"
ableegoldman opened a new pull request #8564:
URL: https://github.com/apache/kafka/pull/8564
These two options are essentially incompatible, as caching will do nothing
to reduce downstream traffic and writes when it has to allow non-unique keys
(skipping records where the value is also
vvcephei commented on pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#issuecomment-620251131
The system tests passed, by the way:
vvcephei commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r416161091
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/HighAvailabilityTaskAssignor.java
##
@@ -16,49 +16,50 @@
*/
bdbyrne commented on a change in pull request #7982:
URL: https://github.com/apache/kafka/pull/7982#discussion_r416110108
##
File path:
clients/src/test/java/org/apache/kafka/clients/producer/internals/BufferPoolTest.java
##
@@ -416,6 +418,10 @@ public Void call() throws
ijuma commented on a change in pull request #8524:
URL: https://github.com/apache/kafka/pull/8524#discussion_r416151605
##
File path: core/src/main/scala/kafka/controller/KafkaController.scala
##
@@ -1068,12 +1068,23 @@ class KafkaController(val config: KafkaConfig,
guozhangwang opened a new pull request #8565:
URL: https://github.com/apache/kafka/pull/8565
Comparing all other test cases, the `shouldAllowConcurrentAccesses` starts
an async producer sending records throughout the test other than just
synchronously sent and acked a few records before
wj1918 opened a new pull request #8563:
URL: https://github.com/apache/kafka/pull/8563
The "Monitoring and Management Using JMX Technology" link on the operations
page is broken because of a missing double quote in the html a tag.
ijuma commented on pull request #7982:
URL: https://github.com/apache/kafka/pull/7982#issuecomment-620205559
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
guozhangwang commented on pull request #8565:
URL: https://github.com/apache/kafka/pull/8565#issuecomment-620242776
@mjsax @cadonna to take a look.
This is an automated message from the Apache Git Service.
To respond to the
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-620846265
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-620846462
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
vvcephei commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416921971
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
##
@@ -810,21 +808,9 @@ private void
junrao commented on pull request #8543:
URL: https://github.com/apache/kafka/pull/8543#issuecomment-620879490
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
cmccabe commented on a change in pull request #8569:
URL: https://github.com/apache/kafka/pull/8569#discussion_r416961523
##
File path: core/src/main/scala/kafka/metrics/LinuxIoMetricsCollector.scala
##
@@ -0,0 +1,96 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF)
ijuma commented on pull request #8567:
URL: https://github.com/apache/kafka/pull/8567#issuecomment-620887867
2 jobs passed, 1 unrelated flaky test failed:
>
org.apache.kafka.streams.integration.QueryableStateIntegrationTest.shouldAllowConcurrentAccesses
guozhangwang commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416910725
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/GlobalKTableEOSIntegrationTest.java
##
@@ -158,8 +158,9 @@ public void
101 - 200 of 51425 matches
Mail list logo
