vvcephei commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r416280171
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/FallbackPriorTaskAssignor.java
##
@@ -0,0 +1,49 @@
+/*
+ *
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-620359124
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-620370010
Java 11:
org.apache.kafka.streams.examples.wordcount.WordCountDemoTest.testOneWord
ivanyu commented on pull request #8196:
URL: https://github.com/apache/kafka/pull/8196#issuecomment-620371657
@jtrenholm-jask that's pretty much the only workaround I've found so far
This is an automated message from the
vvcephei commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r416283374
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -713,23 +713,18 @@ private boolean
vvcephei commented on pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-620376298
Just to be sure we don't break the system tests upon merging, I've kicked
off the branch-builder:
https://jenkins.confluent.io/job/system-test-kafka-branch-builder/3919/console
guozhangwang commented on a change in pull request #8568:
URL: https://github.com/apache/kafka/pull/8568#discussion_r416327335
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/utils/IntegrationTestUtils.java
##
@@ -210,16 +210,21 @@ public static void
kkonstantine commented on a change in pull request #8560:
URL: https://github.com/apache/kafka/pull/8560#discussion_r416289639
##
File path: docs/design.html
##
@@ -366,7 +366,7 @@ Replicated Logs: Q
There are a rich variety of algorithms in this family including
showuon commented on a change in pull request #8560:
URL: https://github.com/apache/kafka/pull/8560#discussion_r416291423
##
File path: docs/design.html
##
@@ -366,7 +366,7 @@ Replicated Logs: Q
There are a rich variety of algorithms in this family including
vvcephei commented on pull request #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-620359206
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 #8564:
URL: https://github.com/apache/kafka/pull/8564#issuecomment-620359460
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 #8540:
URL: https://github.com/apache/kafka/pull/8540#issuecomment-620359273
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please
vvcephei commented on pull request #8564:
URL: https://github.com/apache/kafka/pull/8564#issuecomment-620359328
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and
bseenu commented on pull request #7577:
URL: https://github.com/apache/kafka/pull/7577#issuecomment-620363500
@thspinto Thanks, I tried to test it today. And see the case where consumer
group not existing at the target site works fine, But if it exists but has no
active members does not
guozhangwang opened a new pull request #8568:
URL: https://github.com/apache/kafka/pull/8568
This PR fixes and improves two major issues:
1. When calling `KafkaStreams#store` we can always get an
InvalidStateStoreException, and even waiting for Streams state to become
RUNNING is
cmccabe opened a new pull request #8569:
URL: https://github.com/apache/kafka/pull/8569
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
kkonstantine commented on pull request #8561:
URL: https://github.com/apache/kafka/pull/8561#issuecomment-620345871
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log
vvcephei commented on a change in pull request #8541:
URL: https://github.com/apache/kafka/pull/8541#discussion_r416297248
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsPartitionAssignor.java
##
@@ -712,31 +712,32 @@ private boolean
vvcephei commented on a change in pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#discussion_r416313567
##
File path:
streams/src/main/java/org/apache/kafka/streams/kstream/internals/KTableSource.java
##
@@ -108,7 +126,9 @@ public void process(final K key,
bseenu edited a comment on pull request #7577:
URL: https://github.com/apache/kafka/pull/7577#issuecomment-620363500
@thspinto Thanks, I tried to test it today. And see the case where consumer
group not existing at the target site works fine, But if it exists but has no
active members
kkonstantine commented on pull request #8559:
URL: https://github.com/apache/kafka/pull/8559#issuecomment-620391246
ok to test
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 #8556:
URL: https://github.com/apache/kafka/pull/8556#discussion_r415539913
##
File path:
generator/src/main/java/org/apache/kafka/message/MessageDataGenerator.java
##
@@ -2112,6 +2131,83 @@ private void
chia7712 opened a new pull request #8557:
URL: https://github.com/apache/kafka/pull/8557
**transation** -> **transaction**
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ]
zhaohaidao opened a new pull request #8550:
URL: https://github.com/apache/kafka/pull/8550
Tickets: KAFKA-9850
Move some repartition operator validation to topology.build()
This is an automated message from
omkreddy commented on a change in pull request #8184:
URL: https://github.com/apache/kafka/pull/8184#discussion_r415020856
##
File path: core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala
##
@@ -424,12 +483,33 @@ class ConfigCommandTest extends ZooKeeperTestHarness
omkreddy commented on a change in pull request #8184:
URL: https://github.com/apache/kafka/pull/8184#discussion_r415015661
##
File path: core/src/test/scala/unit/kafka/admin/ConfigCommandTest.scala
##
@@ -40,8 +41,8 @@ import org.junit.Assert._
import org.junit.Test
import
tombentley opened a new pull request #8571:
URL: https://github.com/apache/kafka/pull/8571
Fix all existing javac warnings about use of raw types in Kafka Connect add
-Xlint:rawtypes to the connect the javac options in build.gradle. This
addresses part of KAFKA-7613, but further work will
tombentley commented on pull request #8571:
URL: https://github.com/apache/kafka/pull/8571#issuecomment-620496101
@ijuma and @ewencp could one of you take a look at this?
This is an automated message from the Apache Git
leonardge commented on pull request #8566:
URL: https://github.com/apache/kafka/pull/8566#issuecomment-620445718
Is this due to flaky tests?
The failed test is:
kafka.api.PlaintextAdminIntegrationTest.testCreatePartitions
Hangleton commented on a change in pull request #8569:
URL: https://github.com/apache/kafka/pull/8569#discussion_r416391699
##
File path: core/src/main/scala/kafka/metrics/LinuxIoMetricsCollector.scala
##
@@ -0,0 +1,96 @@
+/**
+ * Licensed to the Apache Software Foundation
ijuma commented on pull request #8533:
URL: https://github.com/apache/kafka/pull/8533#issuecomment-619696479
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
mateuszjadczykDna commented on a change in pull request #8553:
URL: https://github.com/apache/kafka/pull/8553#discussion_r416421730
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskFailOverIntegrationTest.java
##
@@ -0,0 +1,283 @@
+/*
+ *
tombentley commented on pull request #8312:
URL: https://github.com/apache/kafka/pull/8312#issuecomment-620478691
Rebased for conflict.
This is an automated message from the Apache Git Service.
To respond to the message,
tombentley commented on pull request #8204:
URL: https://github.com/apache/kafka/pull/8204#issuecomment-620481500
@kkonstantine any change of merging this?
This is an automated message from the Apache Git Service.
To respond
mateuszjadczykDna commented on a change in pull request #8553:
URL: https://github.com/apache/kafka/pull/8553#discussion_r416422911
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskFailOverIntegrationTest.java
##
@@ -0,0 +1,283 @@
+/*
+ *
mateuszjadczykDna commented on a change in pull request #8553:
URL: https://github.com/apache/kafka/pull/8553#discussion_r416423660
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskFailOverIntegrationTest.java
##
@@ -0,0 +1,283 @@
+/*
+ *
mateuszjadczykDna commented on a change in pull request #8553:
URL: https://github.com/apache/kafka/pull/8553#discussion_r416423943
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/StandbyTaskFailOverIntegrationTest.java
##
@@ -0,0 +1,283 @@
+/*
+ *
bseenu commented on a change in pull request #7577:
URL: https://github.com/apache/kafka/pull/7577#discussion_r416436144
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorCheckpointTask.java
##
@@ -190,4 +227,103 @@ public void
leonardge opened a new pull request #8570:
URL: https://github.com/apache/kafka/pull/8570
*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.*
*Summary of
jiangchuan-java commented on pull request #8583:
URL: https://github.com/apache/kafka/pull/8583#issuecomment-621550649
When a record triggers a retry exception and the retry is processed
successfully, its offset does not commit
jiangchuan-java removed a comment on pull request #8583:
URL: https://github.com/apache/kafka/pull/8583#issuecomment-621551646
This is an automated message from the Apache Git Service.
To respond to the message, please log on
jiangchuan-java commented on pull request #8583:
URL: https://github.com/apache/kafka/pull/8583#issuecomment-621571077
> @jiangchuan-java what's the purpose of this PR?
>
> You'll need to keep only the relevant commits and target your PR against
`trunk`
When a record triggers
jiangchuan-java commented on pull request #8583:
URL: https://github.com/apache/kafka/pull/8583#issuecomment-621576489
> @jiangchuan-java what's the purpose of this PR?
>
> You'll need to keep only the relevant commits and target your PR against
`trunk`
jiangchuan-java removed a comment on pull request #8583:
URL: https://github.com/apache/kafka/pull/8583#issuecomment-621576489
> @jiangchuan-java what's the purpose of this PR?
>
> You'll need to keep only the relevant commits and target your PR against
`trunk`
wj1918 commented on pull request #8563:
URL: https://github.com/apache/kafka/pull/8563#issuecomment-621584636
duplicate with #8587
This is an automated message from the Apache Git Service.
To respond to the message, please
vvcephei opened a new pull request #8588:
URL: https://github.com/apache/kafka/pull/8588
Add validation that task assignment is always balanced after convergence.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test
vvcephei edited a comment on pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#issuecomment-621590516
Oh, and just to put it out there, I know I need to fix the messy diff
computations. I just stamped out something quick to see what you thought about
the approach.
vvcephei commented on pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#issuecomment-621590516
Oh, and just to put it out there, I know I need to fix the diff
computations. I just stamped out something quick to see what you thought about
the approach.
kkonstantine commented on pull request #8554:
URL: https://github.com/apache/kafka/pull/8554#issuecomment-621592493
Only flaky failures in unrelated tests:
`GlobalKTableIntegrationTest` failed in all builds and
`PlaintextConsumerTest.testLowMaxFetchSizeForRequestAndPartition` failed
mjsax commented on a change in pull request #8496:
URL: https://github.com/apache/kafka/pull/8496#discussion_r417738801
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -0,0 +1,1123 @@
+/*
+ * Licensed to the
mjsax commented on a change in pull request #8496:
URL: https://github.com/apache/kafka/pull/8496#discussion_r417739068
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -0,0 +1,1123 @@
+/*
+ * Licensed to the
kkonstantine commented on pull request #8036:
URL: https://github.com/apache/kafka/pull/8036#issuecomment-621630861
Merged to `trunk`, `2.5` and `2.4`
This is an automated message from the Apache Git Service.
To respond to
showuon commented on a change in pull request #8581:
URL: https://github.com/apache/kafka/pull/8581#discussion_r417773241
##
File path: docs/ops.html
##
@@ -676,7 +676,7 @@ 6.4 Java Version
From a security perspective, we recommend you use the latest released
version of
Maatary commented on pull request #6428:
URL: https://github.com/apache/kafka/pull/6428#issuecomment-621618656
Would be nice to have someone resume on this. Feature is very critical and
important. It would solve a rather very critical scenario, especially if
implemented together with
showuon commented on pull request #8581:
URL: https://github.com/apache/kafka/pull/8581#issuecomment-621625513
Hi @kkonstantine , if you have time, would you please help review this small
PR? Thank you.
This is an automated
feyman2016 opened a new pull request #8589:
URL: https://github.com/apache/kafka/pull/8589
This PR is mainly to enhance
https://issues.apache.org/jira/browse/KAFKA-9146.
- `KafkaAdminClient#removeMembersFromConsumerGroup` now support "removeAll"
members in a given group
- New
kkonstantine commented on a change in pull request #8581:
URL: https://github.com/apache/kafka/pull/8581#discussion_r417767601
##
File path: docs/ops.html
##
@@ -676,7 +676,7 @@ 6.4 Java Version
From a security perspective, we recommend you use the latest released
mjsax commented on a change in pull request #8496:
URL: https://github.com/apache/kafka/pull/8496#discussion_r417738371
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -1064,14 +1071,16 @@ private void
mjsax commented on a change in pull request #8496:
URL: https://github.com/apache/kafka/pull/8496#discussion_r417738073
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -388,6 +388,7 @@ public void
mjsax commented on a change in pull request #8496:
URL: https://github.com/apache/kafka/pull/8496#discussion_r417738193
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -881,6 +882,10 @@ public void close() { }
mjsax commented on a change in pull request #8496:
URL: https://github.com/apache/kafka/pull/8496#discussion_r417739843
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -0,0 +1,1123 @@
+/*
+ * Licensed to the
ConcurrencyPractitioner commented on pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-621530837
@vvcephei Looks like I forgot to push. You can retrigger the tests after
this one.
This is an
kkonstantine commented on a change in pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#discussion_r417687040
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/standalone/StandaloneHerder.java
##
@@ -191,32 +192,71 @@ public
kkonstantine commented on a change in pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#discussion_r377915173
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java
##
@@ -808,38 +813,45 @@ public ConnectMetrics metrics() {
kkonstantine commented on a change in pull request #8069:
URL: https://github.com/apache/kafka/pull/8069#discussion_r377915173
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java
##
@@ -808,38 +813,45 @@ public ConnectMetrics metrics() {
showuon opened a new pull request #8587:
URL: https://github.com/apache/kafka/pull/8587
The `href` attribute missed the starting double quote, so the hyperlink is
interpreted as `https://docs.oracle.com/.../agent.html"`, with a redundant
tailing double quote. Add the missing starting
kkonstantine commented on pull request #8583:
URL: https://github.com/apache/kafka/pull/8583#issuecomment-621577922
If your intention is to report an issue, my recommendation would be to first
open a jira ticket in:
https://issues.apache.org/jira/projects/KAFKA/issues
Then, if
vvcephei commented on pull request #8588:
URL: https://github.com/apache/kafka/pull/8588#issuecomment-621589430
Hey @ableegoldman @cadonna ,
I thought it would be good to add verification that the converged assignment
is actually balanced to our randomized test. Really, I had
mjsax commented on a change in pull request #8496:
URL: https://github.com/apache/kafka/pull/8496#discussion_r417740290
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -0,0 +1,1123 @@
+/*
+ * Licensed to the
mjsax commented on pull request #8496:
URL: https://github.com/apache/kafka/pull/8496#issuecomment-621599022
Updated this PR. Call for review.
This is an automated message from the Apache Git Service.
To respond to the
kkonstantine commented on pull request #8583:
URL: https://github.com/apache/kafka/pull/8583#issuecomment-621535084
@jiangchuan-java what's the purpose of this PR?
You'll need to keep only the relevant commits and target your PR against
`trunk`
jiangchuan-java commented on pull request #8583:
URL: https://github.com/apache/kafka/pull/8583#issuecomment-621572060
> @jiangchuan-java what's the purpose of this PR?
>
> You'll need to keep only the relevant commits and target your PR against
`trunk`
my kafka version :
ConcurrencyPractitioner commented on pull request #8254:
URL: https://github.com/apache/kafka/pull/8254#issuecomment-621583048
@vvcephei Alright, all tests passed (looks like there were some flakies) and
all comments addressed.
mjsax commented on a change in pull request #8496:
URL: https://github.com/apache/kafka/pull/8496#discussion_r417739443
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosBetaUpgradeIntegrationTest.java
##
@@ -0,0 +1,1123 @@
+/*
+ * Licensed to the
hachikuji commented on a change in pull request #8586:
URL: https://github.com/apache/kafka/pull/8586#discussion_r417688549
##
File path: core/src/test/scala/unit/kafka/server/SimpleFetchTest.scala
##
@@ -1,206 +0,0 @@
-/**
- * Licensed to the Apache Software Foundation (ASF)
jiangchuan-java commented on pull request #8583:
URL: https://github.com/apache/kafka/pull/8583#issuecomment-621551646
if (msgs.count() > 0)
origOffsets.clear();
Solve the problem
This is an automated message
jiangchuan-java commented on pull request #8583:
URL: https://github.com/apache/kafka/pull/8583#issuecomment-621576206
> @jiangchuan-java what's the purpose of this PR?
>
> You'll need to keep only the relevant commits and target your PR against
`trunk`
log detail
mjsax commented on a change in pull request #8496:
URL: https://github.com/apache/kafka/pull/8496#discussion_r417737952
##
File path: streams/src/main/java/org/apache/kafka/streams/StreamsConfig.java
##
@@ -1283,9 +1284,6 @@ private void
viktorsomogyi commented on pull request #6011:
URL: https://github.com/apache/kafka/pull/6011#issuecomment-621716362
Closing this as the discussions on the related kip resulted in delaying the
related work.
This is an
vvcephei commented on pull request #8578:
URL: https://github.com/apache/kafka/pull/8578#issuecomment-621425603
Thanks, @guozhangwang !
This is an automated message from the Apache Git Service.
To respond to the message,
kkonstantine commented on pull request #7082:
URL: https://github.com/apache/kafka/pull/7082#issuecomment-621703287
retest this please
This is an automated message from the Apache Git Service.
To respond to the message,
kkonstantine commented on pull request #8204:
URL: https://github.com/apache/kafka/pull/8204#issuecomment-621707808
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub
viktorsomogyi commented on pull request #7716:
URL: https://github.com/apache/kafka/pull/7716#issuecomment-621710869
Hey folks, I'm closing this PR due to the lack of interest. If anyone
interested, please feel free to pick up the related jira.
feyman2016 commented on pull request #8020:
URL: https://github.com/apache/kafka/pull/8020#issuecomment-621709849
Hi, all, sorry for the delay, I have created another PR, and request for
review, thanks! https://github.com/apache/kafka/pull/8589/files
feyman2016 edited a comment on pull request #8020:
URL: https://github.com/apache/kafka/pull/8020#issuecomment-621709849
Hi, @abbccdda, sorry for the delay, I have created another PR, and request
for review, thanks! https://github.com/apache/kafka/pull/8589/files
feyman2016 removed a comment on pull request #8020:
URL: https://github.com/apache/kafka/pull/8020#issuecomment-621224680
@abbccdda, I haven't pushed my local change after we have updated the
KIP-571, will still update in this PR.
viktorsomogyi commented on pull request #5620:
URL: https://github.com/apache/kafka/pull/5620#issuecomment-621715924
@ijuma @cmccabe any opinions if this can get merged in if I rebase it?
I'm trying to clean up my open PR list so if you guys think this one is
useful and something that
kkonstantine commented on a change in pull request #7950:
URL: https://github.com/apache/kafka/pull/7950#discussion_r417807918
##
File path:
clients/src/main/java/org/apache/kafka/common/utils/CircularIterator.java
##
@@ -14,36 +14,89 @@
* See the License for the specific
kkonstantine commented on pull request #5824:
URL: https://github.com/apache/kafka/pull/5824#issuecomment-621673142
This is no more applicable, after https://github.com/apache/kafka/pull/7964
Closing without merging
This
kkonstantine commented on pull request #4958:
URL: https://github.com/apache/kafka/pull/4958#issuecomment-621681282
Closing this PR in favor of https://github.com/apache/kafka/pull/7491 which
seems to have fixed the issue.
tombentley commented on pull request #8204:
URL: https://github.com/apache/kafka/pull/8204#issuecomment-621697783
@kkonstantine I should have run all the tests. Lesson learned, and sorry for
wasting your time. Now fixed (and tested).
jeqo opened a new pull request #8584:
URL: https://github.com/apache/kafka/pull/8584
nit. `baseTimestamp` is used when `firstTimestamp` is defined on the on-disk
format and implementation.
This is an automated message from
cadonna commented on pull request #8157:
URL: https://github.com/apache/kafka/pull/8157#issuecomment-621743226
@pierDipi Thank you for the updates. I will try to review it next week.
This is an automated message from the
WJL edited a comment on pull request #5519:
URL: https://github.com/apache/kafka/pull/5519#issuecomment-621137606
i think this patch can also save a lot of memory
This is an automated message from the Apache Git Service.
WJL commented on pull request #5519:
URL: https://github.com/apache/kafka/pull/5519#issuecomment-621137606
i think this patch can also save a lot of memory usage
This is an automated message from the Apache Git Service.
cadonna commented on pull request #8590:
URL: https://github.com/apache/kafka/pull/8590#issuecomment-621796799
Call for review: @ableegoldman @vvcephei
This is an automated message from the Apache Git Service.
To respond to
cadonna opened a new pull request #8590:
URL: https://github.com/apache/kafka/pull/8590
Since we cannot guarantee to reassign the correct number of
stand-by tasks when reusing the previous assignment and the
reassignment is rather a micro-optimization, it is removed
to keep the
mimaison commented on issue #8224:
URL: https://github.com/apache/kafka/pull/8224#issuecomment-618536956
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log on
bseenu edited a comment on pull request #7577:
URL: https://github.com/apache/kafka/pull/7577#issuecomment-618596724
@thspinto @ning2008wisc i am trying this , but i do not see the consumer
offsets being populated on the target side, my consumer group is not dead i am
polling for messages
abbccdda commented on pull request #8326:
URL: https://github.com/apache/kafka/pull/8326#issuecomment-618627112
Test only fails the flaky test:
kafka.api.ConsumerBounceTest.testRollingBrokerRestartsWithSmallerMaxGroupSizeConfigDisruptsBigGroup
901 - 1000 of 51425 matches
Mail list logo
