IndeedSi commented on pull request #8079:
URL: https://github.com/apache/kafka/pull/8079#issuecomment-635145896
@vvcephei @ableegoldman Hi, I'm seeing large amount of this WARN log every
time our instances restart. I think it's just the same case as described in the
[mail
list](http://m
kkonstantine commented on pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#issuecomment-635143830
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, pleas
kkonstantine merged pull request #8720:
URL: https://github.com/apache/kafka/pull/8720
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 pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#issuecomment-635139703
2/3 builds are green. Merging now to allow for other PRs to resolve
conflicts sooner rather than later, if needed.
-
kkonstantine commented on a change in pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#discussion_r431612737
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporter.java
##
@@ -0,0 +1,172 @@
+/*
+ * Licen
hachikuji commented on a change in pull request #8238:
URL: https://github.com/apache/kafka/pull/8238#discussion_r431607959
##
File path: clients/src/main/resources/common/message/ListGroupsRequest.json
##
@@ -20,8 +20,14 @@
// Version 1 and 2 are the same as version 0.
/
hachikuji commented on a change in pull request #8238:
URL: https://github.com/apache/kafka/pull/8238#discussion_r431596763
##
File path: clients/src/main/resources/common/message/ListGroupsResponse.json
##
@@ -34,7 +36,9 @@
{ "name": "GroupId", "type": "string", "versio
jiameixie commented on pull request #8446:
URL: https://github.com/apache/kafka/pull/8446#issuecomment-635122648
Call for review @huxihx
This is an automated message from the Apache Git Service.
To respond to the message, ple
guozhangwang commented on pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#issuecomment-635119117
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
ijuma commented on a change in pull request #8695:
URL: https://github.com/apache/kafka/pull/8695#discussion_r431587702
##
File path:
clients/src/test/java/org/apache/kafka/common/network/SslTransportLayerTest.java
##
@@ -622,6 +619,81 @@ public void testUnsupportedTLSVersion(
guozhangwang commented on pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#issuecomment-635118880
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please
ijuma commented on a change in pull request #8705:
URL: https://github.com/apache/kafka/pull/8705#discussion_r431583127
##
File path: clients/src/main/java/org/apache/kafka/common/network/Selector.java
##
@@ -804,7 +804,33 @@ private void maybeCloseOldestConnection(long
curren
ijuma commented on a change in pull request #8705:
URL: https://github.com/apache/kafka/pull/8705#discussion_r431581763
##
File path: core/src/test/scala/unit/kafka/network/SocketServerTest.scala
##
@@ -1807,6 +1817,7 @@ class SocketServerTest {
currentPollValues ++=
ijuma commented on a change in pull request #8705:
URL: https://github.com/apache/kafka/pull/8705#discussion_r431581508
##
File path: core/src/test/scala/unit/kafka/network/SocketServerTest.scala
##
@@ -1875,6 +1889,14 @@ class SocketServerTest {
cachedCompletedReceiv
ijuma commented on pull request #7956:
URL: https://github.com/apache/kafka/pull/7956#issuecomment-635095707
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
ijuma commented on a change in pull request #8644:
URL: https://github.com/apache/kafka/pull/8644#discussion_r431576336
##
File path: clients/src/main/java/org/apache/kafka/clients/ClientDnsLookup.java
##
@@ -22,7 +22,8 @@
DEFAULT("default"),
USE_ALL_DNS_IPS("use_al
ijuma commented on a change in pull request #8644:
URL: https://github.com/apache/kafka/pull/8644#discussion_r431576336
##
File path: clients/src/main/java/org/apache/kafka/clients/ClientDnsLookup.java
##
@@ -22,7 +22,8 @@
DEFAULT("default"),
USE_ALL_DNS_IPS("use_al
ijuma commented on a change in pull request #8644:
URL: https://github.com/apache/kafka/pull/8644#discussion_r431576017
##
File path: clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
##
@@ -108,10 +108,11 @@ public static ChannelBuilder
createChannelBuilder(Abst
ijuma commented on a change in pull request #8644:
URL: https://github.com/apache/kafka/pull/8644#discussion_r431576164
##
File path: clients/src/main/java/org/apache/kafka/clients/ClientDnsLookup.java
##
@@ -22,7 +22,8 @@
DEFAULT("default"),
USE_ALL_DNS_IPS("use_al
ijuma commented on a change in pull request #8644:
URL: https://github.com/apache/kafka/pull/8644#discussion_r431574455
##
File path: clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
##
@@ -108,10 +108,11 @@ public static ChannelBuilder
createChannelBuilder(Abst
ijuma commented on a change in pull request #8644:
URL: https://github.com/apache/kafka/pull/8644#discussion_r431574455
##
File path: clients/src/main/java/org/apache/kafka/clients/ClientUtils.java
##
@@ -108,10 +108,11 @@ public static ChannelBuilder
createChannelBuilder(Abst
ableegoldman commented on a change in pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#discussion_r431571947
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java
##
@@ -551,6 +551,7 @@ void runLoop() {
ijuma commented on a change in pull request #8644:
URL: https://github.com/apache/kafka/pull/8644#discussion_r431571756
##
File path: clients/src/main/java/org/apache/kafka/clients/ClientDnsLookup.java
##
@@ -22,7 +22,8 @@
DEFAULT("default"),
USE_ALL_DNS_IPS("use_al
kkonstantine merged pull request #8735:
URL: https://github.com/apache/kafka/pull/8735
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 a change in pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#discussion_r431571493
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java
##
@@ -90,24 +96,21 @@ public static String getTaskP
ableegoldman opened a new pull request #8738:
URL: https://github.com/apache/kafka/pull/8738
Fixes the admin client timeout supplied to `future.get(timeout)` to always
time out based on the configured `default.api.timeout.ms`
---
ableegoldman commented on a change in pull request #8738:
URL: https://github.com/apache/kafka/pull/8738#discussion_r431571250
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -44,12 +45,6 @@
private final st
rhauch commented on pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#issuecomment-635086497
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
rhauch commented on pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#issuecomment-635085234
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
rhauch commented on pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#issuecomment-635085420
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
rhauch commented on pull request #8735:
URL: https://github.com/apache/kafka/pull/8735#issuecomment-635085072
The test failures appear to be unrelated to Connect and are known to be
flaky.
This is an automated message from t
ijuma merged pull request #8728:
URL: https://github.com/apache/kafka/pull/8728
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
ijuma commented on pull request #8728:
URL: https://github.com/apache/kafka/pull/8728#issuecomment-635083240
Unrelated flaky failures:
>
org.apache.kafka.streams.integration.EosBetaUpgradeIntegrationTest.shouldUpgradeFromEosAlphaToEosBeta[true]
>
org.apache.kafka.streams.integrat
[
https://issues.apache.org/jira/browse/KAFKA-9802?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-9802.
Fix Version/s: 2.5.1
Resolution: Fixed
> Fix flaky system test `TransactionsTest.tes
ijuma commented on pull request #8732:
URL: https://github.com/apache/kafka/pull/8732#issuecomment-635081822
Thanks for doing this. This test has been incredibly unstable.
This is an automated message from the Apache Git Serv
hachikuji merged pull request #8736:
URL: https://github.com/apache/kafka/pull/8736
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
rhauch commented on pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#issuecomment-635081325
Jenkins jobs were never associated with this PR (see
[INFRA-20344](https://issues.apache.org/jira/browse/INFRA-20344)), but here are
the jobs for the latest commit:
* https://bu
ijuma merged pull request #8731:
URL: https://github.com/apache/kafka/pull/8731
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
aakashnshah commented on a change in pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#discussion_r431564671
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporter.java
##
@@ -0,0 +1,172 @@
+/*
+ * Licens
rhauch commented on pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#issuecomment-635077545
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118262#comment-17118262
]
Matthias J. Sax commented on KAFKA-8011:
We can also create a new ticket. I don't
rhauch edited a comment on pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#issuecomment-635072158
Builds were all aborted: `Aborted by user anonymous`
* https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/2554/
* https://builds.apache.org/job/kafka-pr-jdk11-scala2.
rhauch commented on pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#issuecomment-635072158
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 #8712:
URL: https://github.com/apache/kafka/pull/8712#issuecomment-635071774
Thanks, @ableegoldman . Take your time. :)
This is an automated message from the Apache Git Service.
To respond to
rhauch commented on pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#issuecomment-635071561
Three green builds of commit `126b04`:
* https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/2552/
* https://builds.apache.org/job/kafka-pr-jdk14-scala2.13/710/
* https://
kkonstantine commented on a change in pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#discussion_r431557717
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/InternalSinkRecord.java
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apach
ableegoldman commented on pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#issuecomment-635065576
Hey @showuon, thanks for the PR! I'm pretty busy at the moment, especially
with the 2.6 deadline, but it's on my todo list to review.
--
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-8011:
---
Attachment:
org.apache.kafka.streams.integration.RegexSourceIntegrationTest.html
> F
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118245#comment-17118245
]
Sophie Blee-Goldman commented on KAFKA-8011:
Attaching the output from local
rhauch commented on a change in pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#discussion_r431544842
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/InternalSinkRecord.java
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apache Soft
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r431542322
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -183,12 +180,15 @@ public void handleAssignmen
kkonstantine commented on a change in pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#discussion_r431542321
##
File path:
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/isolation/PluginUtilsTest.java
##
@@ -128,6 +131,10 @@ public void testAl
dbtucker commented on pull request #2880:
URL: https://github.com/apache/kafka/pull/2880#issuecomment-635049359
At the time I wrote this, the combination of Extract Field and Flatten was
too limiting for some filtering tasks. Happy to have it land in ExtractField
if that is the quicker op
kkonstantine commented on a change in pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#discussion_r431512019
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/InternalSinkRecord.java
##
@@ -0,0 +1,77 @@
+/*
+ * Licensed to the Apach
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118222#comment-17118222
]
Sophie Blee-Goldman commented on KAFKA-8011:
[~mjsax] should we create a sepa
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-8011:
---
Priority: Blocker (was: Critical)
> Flaky Test RegexSourceIntegrationTest#testRegexM
[
https://issues.apache.org/jira/browse/KAFKA-8011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-8011:
---
Fix Version/s: 2.6.0
> Flaky Test RegexSourceIntegrationTest#testRegexMatchesTopicsAW
abbccdda commented on pull request #8706:
URL: https://github.com/apache/kafka/pull/8706#issuecomment-635042381
```
15:01:33 [ant:checkstyle] [ERROR]
/home/jenkins/jenkins-slave/workspace/kafka-pr-jdk11-scala2.13/streams/src/test/java/org/apache/kafka/streams/integration/StoreQueryIntegr
abbccdda commented on pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#issuecomment-635041609
Great work, @feyman2016 @mjsax !
This is an automated message from the Apache Git Service.
To respond to the mess
mjsax commented on pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#issuecomment-635041171
Thanks for the KIP and PR @feyman2016!
This is an automated message from the Apache Git Service.
To respond to the m
mjsax merged pull request #8589:
URL: https://github.com/apache/kafka/pull/8589
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
rhauch commented on pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#issuecomment-635034899
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
hachikuji commented on a change in pull request #8736:
URL: https://github.com/apache/kafka/pull/8736#discussion_r431530519
##
File path: tests/kafkatest/tests/core/transactions_test.py
##
@@ -47,7 +47,7 @@ def __init__(self, test_context):
self.num_output_partitions =
[
https://issues.apache.org/jira/browse/KAFKA-9960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-9960.
--
Resolution: Fixed
Merged the PR to the `trunk` branch for inclusion in the AK 2.6.0 release.
>
rhauch merged pull request #8691:
URL: https://github.com/apache/kafka/pull/8691
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
[
https://issues.apache.org/jira/browse/KAFKA-8930?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118200#comment-17118200
]
Rodrigo Alejandro Loza Lucero commented on KAFKA-8930:
--
Sorry for th
feyman2016 commented on pull request #8589:
URL: https://github.com/apache/kafka/pull/8589#issuecomment-635025385
Finally, jenkins cooperated :)
This is an automated message from the Apache Git Service.
To respond to the mess
vinothchandar opened a new pull request #8737:
URL: https://github.com/apache/kafka/pull/8737
- Fixed command line arg checking
- Added unit test cases
- Local testing with a multi node Kafka cluster
### Committer Checklist (excluded from commit message)
- [ ] Verify desig
rhauch commented on pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#issuecomment-635013768
Not sure what's happening, but here are some finally-running builds from
previous commit (0e40):
* https://builds.apache.org/job/kafka-pr-jdk8-scala2.12/2548/
* https://builds
bob-barrett commented on a change in pull request #8736:
URL: https://github.com/apache/kafka/pull/8736#discussion_r431512735
##
File path: tests/kafkatest/tests/core/transactions_test.py
##
@@ -47,7 +47,7 @@ def __init__(self, test_context):
self.num_output_partitions
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r431513482
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -811,17 +812,41 @@ private void prepa
hachikuji commented on pull request #8736:
URL: https://github.com/apache/kafka/pull/8736#issuecomment-635012334
Thanks, it was just a copy/paste bug I think. I tweaked the output a little.
This is an automated message from t
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r431513230
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -811,17 +812,41 @@ private void prepa
rhauch commented on pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#issuecomment-635007497
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
rhauch commented on pull request #8699:
URL: https://github.com/apache/kafka/pull/8699#issuecomment-635007361
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use
rhauch commented on pull request #8691:
URL: https://github.com/apache/kafka/pull/8691#issuecomment-635006306
One seemingly unrelated failure on JDK11 with a known [flaky
test](https://issues.apache.org/jira/browse/KAFKA-9516):
```
kafka.api.PlaintextProducerSendTest.testNonBlockingPr
vvcephei commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r431505723
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -811,17 +812,41 @@ private void prepareCh
showuon commented on pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#issuecomment-635002983
Hi @abbccdda @ableegoldman , please help review this PR. Thanks
This is an automated message from the Apache Git S
hachikuji opened a new pull request #8736:
URL: https://github.com/apache/kafka/pull/8736
We have been seeing increased flakiness in transaction system tests. I
believe the cause might be due to KIP-537, which increased the default zk
session timeout from 6s to 18s and the default replica
[
https://issues.apache.org/jira/browse/KAFKA-9298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bill Bejeck updated KAFKA-9298:
---
Fix Version/s: 2.5.1
> Reuse of a mapped stream causes an Invalid Topology
>
[
https://issues.apache.org/jira/browse/KAFKA-9298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118162#comment-17118162
]
Bill Bejeck commented on KAFKA-9298:
cherry-picked to 2.5
> Reuse of a mapped stream
bbejeck commented on pull request #8504:
URL: https://github.com/apache/kafka/pull/8504#issuecomment-634997680
cherry-picked to 2.5
This is an automated message from the Apache Git Service.
To respond to the message, please l
[
https://issues.apache.org/jira/browse/KAFKA-6145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman resolved KAFKA-6145.
Fix Version/s: 2.6.0
Resolution: Fixed
> Warm up new KS instances before mig
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r431484939
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -189,38 +190,52 @@ private void prepareClose(f
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r431482714
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -272,6 +274,30 @@ public void handleAssignment
[
https://issues.apache.org/jira/browse/KAFKA-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17118154#comment-17118154
]
Rodrigo Alejandro Loza Lucero commented on KAFKA-9376:
--
I had the sa
ableegoldman commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r431481812
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StoreChangelogReader.java
##
@@ -811,17 +812,41 @@ private void prepa
[
https://issues.apache.org/jira/browse/KAFKA-9937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton updated KAFKA-9937:
-
Component/s: (was: KafkaConnect)
> Unable to start Kafka broker using python script
> ---
rhauch commented on a change in pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#discussion_r431474116
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/InternalSinkRecord.java
##
@@ -0,0 +1,79 @@
+/*
+ * Licensed to the Apache Soft
Matthias J. Sax created KAFKA-10055:
---
Summary: Add shared internal utility class
Key: KAFKA-10055
URL: https://issues.apache.org/jira/browse/KAFKA-10055
Project: Kafka
Issue Type: Improveme
rhauch commented on pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#issuecomment-634970649
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
rhauch commented on pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#issuecomment-634970551
retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
kkonstantine commented on pull request #8735:
URL: https://github.com/apache/kafka/pull/8735#issuecomment-634968253
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on
kkonstantine opened a new pull request #8735:
URL: https://github.com/apache/kafka/pull/8735
A recently added assertion in Connect integration tests uses
`consumer#partitionsFor` to verify that a topic was created with the expected
number of partitions and replicas. However, probably becau
vvcephei commented on a change in pull request #8248:
URL: https://github.com/apache/kafka/pull/8248#discussion_r431251657
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StandbyTask.java
##
@@ -189,38 +190,52 @@ private void prepareClose(final
[
https://issues.apache.org/jira/browse/KAFKA-9952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson resolved KAFKA-9952.
Fix Version/s: 2.6.0
Resolution: Fixed
> Reconsider immediate propagation of hw when
[
https://issues.apache.org/jira/browse/KAFKA-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Konstantine Karantasis reassigned KAFKA-10052:
--
Assignee: Konstantine Karantasis
> Flaky Test
> InternalTopicsIntegr
rhauch commented on pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#issuecomment-634957589
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
hachikuji merged pull request #8709:
URL: https://github.com/apache/kafka/pull/8709
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
rhauch commented on pull request #8720:
URL: https://github.com/apache/kafka/pull/8720#issuecomment-634957054
ok to test
This is an automated message from the Apache Git Service.
To respond to the message, please log on to Gi
1 - 100 of 318 matches
Mail list logo
