satishbellapu commented on pull request #8921:
URL: https://github.com/apache/kafka/pull/8921#issuecomment-648602105
@omkreddy cc
This is an automated message from the Apache Git Service.
To respond to the message, please
skaundinya15 commented on a change in pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#discussion_r444631685
##
File path:
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
##
@@ -84,6 +84,9 @@
public static final String
skaundinya15 commented on a change in pull request #8846:
URL: https://github.com/apache/kafka/pull/8846#discussion_r444631685
##
File path:
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
##
@@ -84,6 +84,9 @@
public static final String
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124340#comment-17124340
]
Sanjana Kaundinya edited comment on KAFKA-9800 at 6/24/20, 4:24 AM:
[
https://issues.apache.org/jira/browse/KAFKA-9800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17124340#comment-17124340
]
Sanjana Kaundinya edited comment on KAFKA-9800 at 6/24/20, 4:24 AM:
[
https://issues.apache.org/jira/browse/KAFKA-9678?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sanjana Kaundinya resolved KAFKA-9678.
--
Resolution: Duplicate
> Introduce bounded exponential backoff in clients
>
[
https://issues.apache.org/jira/browse/KAFKA-9678?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143505#comment-17143505
]
Sanjana Kaundinya commented on KAFKA-9678:
--
The work for this is being done by [~d8tltanc] in
[
https://issues.apache.org/jira/browse/KAFKA-10177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10177:
Description:
There's an existing – but seemingly unused – implementation of
[
https://issues.apache.org/jira/browse/KAFKA-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming updated KAFKA-10195:
---
Description:
ConsumerCoordinator has 2 main functions:
# partitions assignment
# offset
[
https://issues.apache.org/jira/browse/KAFKA-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming updated KAFKA-10195:
---
Description:
ConsumerCoordinator has 2 main functions:
# partitions assignment
# offset
[
https://issues.apache.org/jira/browse/KAFKA-10177?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10177:
Summary: Replace/improve Percentiles metrics (was: Replace/improve/remove
[
https://issues.apache.org/jira/browse/KAFKA-10195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
dengziming updated KAFKA-10195:
---
Attachment: image-2020-06-24-10-47-44-733.png
> Move offset management codes from
jiamei xie created KAFKA-10196:
--
Summary: Add missing '--version' option to Kafka command
producer-performance
Key: KAFKA-10196
URL: https://issues.apache.org/jira/browse/KAFKA-10196
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-10175?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143453#comment-17143453
]
Chia-Ping Tsai commented on KAFKA-10175:
just curious, does it cause exception on production?
>
[
https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143449#comment-17143449
]
Chia-Ping Tsai commented on KAFKA-10140:
It seems to me users should be aware of the config they
mjsax commented on pull request #8919:
URL: https://github.com/apache/kafka/pull/8919#issuecomment-648534515
Merged to `2.5` and cherry-picked to `2.4`.
It's fixed in `trunk` and `2.6` via #8900
This is an automated
mjsax merged pull request #8919:
URL: https://github.com/apache/kafka/pull/8919
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-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143437#comment-17143437
]
Sophie Blee-Goldman commented on KAFKA-9846:
I think we can just leave it open and maybe
ableegoldman commented on pull request #8919:
URL: https://github.com/apache/kafka/pull/8919#issuecomment-648526072
Wow, all tests passed on the first try! cc @mjsax
This is an automated message from the Apache Git Service.
guozhangwang commented on pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#issuecomment-648525527
Merged to trunk and cherry-picked to 2.6
This is an automated message from the Apache Git Service.
To
guozhangwang merged pull request #8900:
URL: https://github.com/apache/kafka/pull/8900
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
satishbellapu commented on a change in pull request #8921:
URL: https://github.com/apache/kafka/pull/8921#discussion_r444586705
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -123,6 +125,10 @@
private static
ryannedolan commented on a change in pull request #8921:
URL: https://github.com/apache/kafka/pull/8921#discussion_r444580176
##
File path:
connect/mirror/src/main/java/org/apache/kafka/connect/mirror/MirrorConnectorConfig.java
##
@@ -123,6 +125,10 @@
private static
[
https://issues.apache.org/jira/browse/KAFKA-9935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143428#comment-17143428
]
Steve Kecskes commented on KAFKA-9935:
--
Agreed, it does look similar to KAFKA-10105.
I see further
[
https://issues.apache.org/jira/browse/KAFKA-10160?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143427#comment-17143427
]
sats commented on KAFKA-10160:
--
Created a pull request [https://github.com/apache/kafka/pull/8921]
> Kafka
satishbellapu opened a new pull request #8921:
URL: https://github.com/apache/kafka/pull/8921
KAFKA-10160: Removed hardcoded auto.offset.reset in MM2 consumer
configuration, retained default as earliest unless specified.
### Committer Checklist (excluded from commit message)
-
mjsax commented on a change in pull request #8920:
URL: https://github.com/apache/kafka/pull/8920#discussion_r444554053
##
File path: docs/streams/developer-guide/processor-api.html
##
@@ -49,6 +49,7 @@
Defining and creating a
State Store
ableegoldman commented on a change in pull request #8712:
URL: https://github.com/apache/kafka/pull/8712#discussion_r444555724
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/InternalTopicManager.java
##
@@ -98,9 +98,10 @@ public
guozhangwang commented on pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#issuecomment-648472153
LGTM! I will merge after green jenkins.
This is an automated message from the Apache Git Service.
To respond
ableegoldman commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r444552897
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/AbstractProcessorStateManager.java
##
@@ -0,0 +1,33 @@
+/*
+ *
JimGalasyn opened a new pull request #8920:
URL: https://github.com/apache/kafka/pull/8920
Add a section on the timestamped state store interfaces, per
[KIP-258](https://cwiki.apache.org/confluence/display/KAFKA/KIP-258%3A+Allow+to+Store+Record+Timestamps+in+RocksDB).
mjsax commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r444541033
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/GlobalStateManagerImpl.java
##
@@ -402,4 +402,9 @@ public TaskType
mjsax commented on pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#issuecomment-648462369
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
abbccdda commented on pull request #8585:
URL: https://github.com/apache/kafka/pull/8585#issuecomment-648460501
Only known flaky test failures:
```
org.apache.kafka.connect.mirror.MirrorConnectorsIntegrationTest.testReplication
abbccdda commented on pull request #8107:
URL: https://github.com/apache/kafka/pull/8107#issuecomment-648459539
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please
abbccdda commented on pull request #6737:
URL: https://github.com/apache/kafka/pull/6737#issuecomment-648459250
Closed according to @dajac source.
This is an automated message from the Apache Git Service.
To respond to the
abbccdda closed pull request #6737:
URL: https://github.com/apache/kafka/pull/6737
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
mjsax commented on pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#issuecomment-648457282
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#issuecomment-648456919
Retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
mjsax commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r444538711
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java
##
@@ -474,6 +492,7 @@ public void
mjsax commented on pull request #8919:
URL: https://github.com/apache/kafka/pull/8919#issuecomment-648456709
Retest this please.
This is an automated message from the Apache Git Service.
To respond to the message, please log
ableegoldman commented on pull request #8919:
URL: https://github.com/apache/kafka/pull/8919#issuecomment-648455230
cc @mjsax
This is an automated message from the Apache Git Service.
To respond to the message, please log
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r444537297
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java
##
@@ -152,9 +152,9 @@ public
ableegoldman opened a new pull request #8919:
URL: https://github.com/apache/kafka/pull/8919
Hotfix for patching this in older branches
This is an automated message from the Apache Git Service.
To respond to the message,
abbccdda merged pull request #8845:
URL: https://github.com/apache/kafka/pull/8845
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
[
https://issues.apache.org/jira/browse/KAFKA-9509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143314#comment-17143314
]
Boyang Chen commented on KAFKA-9509:
Failed again:
h3. Stacktrace
java.lang.RuntimeException: Could
abbccdda commented on pull request #8845:
URL: https://github.com/apache/kafka/pull/8845#issuecomment-648449655
Having tested 3 * 3 times, and only flaky test failed such as this one:
https://issues.apache.org/jira/browse/KAFKA-9509
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r444530988
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java
##
@@ -474,6 +492,7 @@ public void
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r444528622
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java
##
@@ -474,6 +492,7 @@ public void
mjsax commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r444526844
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java
##
@@ -474,6 +492,7 @@ public void
mjsax commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r444526844
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/RecordCollectorTest.java
##
@@ -474,6 +492,7 @@ public void
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r444525997
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -679,92 +675,166 @@ private void
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r444522543
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java
##
@@ -152,9 +152,9 @@ public
mjsax commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r444518329
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -679,92 +675,166 @@ private void cleanupTask(final
mjsax commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r444517907
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -679,92 +675,166 @@ private void cleanupTask(final
mjsax commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r444517746
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -679,92 +675,166 @@ private void cleanupTask(final
mjsax commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r444516858
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsMetadataState.java
##
@@ -152,9 +152,9 @@ public StreamsMetadata
abbccdda merged pull request #8174:
URL: https://github.com/apache/kafka/pull/8174
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
mimaison commented on a change in pull request #8604:
URL: https://github.com/apache/kafka/pull/8604#discussion_r444504939
##
File path: core/src/main/scala/kafka/tools/ConsoleConsumer.scala
##
@@ -560,16 +561,15 @@ class LoggingMessageFormatter extends MessageFormatter
with
ableegoldman commented on pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#issuecomment-648404327
One unrelated failure: `PlaintextProducerSendTest.testNonBlockingProducer`
This is an automated message from
[
https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143275#comment-17143275
]
Vinoth Chandar commented on KAFKA-9846:
---
Sounds good. Close this as "Wont fix" then?
> Race
[
https://issues.apache.org/jira/browse/KAFKA-10179?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143238#comment-17143238
]
Sophie Blee-Goldman commented on KAFKA-10179:
-
[~desai.p.rohan] I'm not sure I understand
[
https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143228#comment-17143228
]
Sophie Blee-Goldman commented on KAFKA-9846:
Ok no worries. I don't think it's critical, just
cyrusv opened a new pull request #8918:
URL: https://github.com/apache/kafka/pull/8918
This very simply reduces the log level for these very frequently logged,
very infrequently useful log messages to debug level.
My experience operating these connectors is that these logs make reading
[
https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143168#comment-17143168
]
Gokul Ramanan Subramanian commented on KAFKA-10105:
---
[~ableegoldman], we are unable to
[
https://issues.apache.org/jira/browse/KAFKA-9846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143158#comment-17143158
]
Vinoth Chandar commented on KAFKA-9846:
---
Probably don't have time this week.. But if y'all can take
[
https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143153#comment-17143153
]
Ismael Juma commented on KAFKA-10140:
-
I understand now. Yeah, I ran into this issue before when
[
https://issues.apache.org/jira/browse/KAFKA-10192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143135#comment-17143135
]
Chris Egerton commented on KAFKA-10192:
---
I think what might be happening is that the worker is
ableegoldman commented on a change in pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#discussion_r444383211
##
File path:
streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java
##
@@ -130,6 +130,8 @@ public static void main(final
guozhangwang commented on pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#issuecomment-648298106
test this
This is an automated message from the Apache Git Service.
To respond to the message, please log on
chia7712 commented on a change in pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#discussion_r444374011
##
File path:
streams/src/test/java/org/apache/kafka/streams/tests/StreamsOptimizedTest.java
##
@@ -130,6 +130,8 @@ public static void main(final
chia7712 commented on a change in pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#discussion_r444373556
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##
@@ -303,7 +303,8 @@ public void
[
https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143112#comment-17143112
]
Chia-Ping Tsai commented on KAFKA-10140:
alterConfigs does not support APPEND and SUBTRACT so it
nizhikov opened a new pull request #8917:
URL: https://github.com/apache/kafka/pull/8917
After 8b22b8159673bfe22d8ac5dcd4e4312d4f2c863c `security_config` properties
are modified during `setup_node`: tls_version patched according to the node jdk
version. But python `@property` decorator
ableegoldman commented on a change in pull request #8913:
URL: https://github.com/apache/kafka/pull/8913#discussion_r444368127
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/ClientState.java
##
@@ -303,7 +303,8 @@ public void
d8tltanc commented on pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#issuecomment-648288498
@dajac @rajinisivaram Thanks for the second round of review. I've addressed
your comments and adopted your suggestions. Please let me know if you have more
thoughts on this PR.
[
https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143108#comment-17143108
]
Ismael Juma commented on KAFKA-10140:
-
We should check why alterConfigs handles this correctly and
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143105#comment-17143105
]
Sophie Blee-Goldman commented on KAFKA-10191:
-
Cool. Since this is failing pretty regularly,
[
https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143094#comment-17143094
]
Chia-Ping Tsai edited comment on KAFKA-10140 at 6/23/20, 4:49 PM:
--
The
[
https://issues.apache.org/jira/browse/KAFKA-10194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10194:
Labels: newbie (was: )
> run the reset tool between stopping
[
https://issues.apache.org/jira/browse/KAFKA-10194?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Sophie Blee-Goldman updated KAFKA-10194:
Component/s: system tests
streams
> run the reset tool between
skaundinya15 commented on pull request #8894:
URL: https://github.com/apache/kafka/pull/8894#issuecomment-648280522
@showuon no more comments
> Hi @ryannedolan @skaundinya15 , do you have any other comments? I think we
should merge this PR soon since the tests fails today's test
skaundinya15 edited a comment on pull request #8894:
URL: https://github.com/apache/kafka/pull/8894#issuecomment-648280522
> Hi @ryannedolan @skaundinya15 , do you have any other comments? I think we
should merge this PR soon since the tests fails today's test again. Thanks.
[
https://issues.apache.org/jira/browse/KAFKA-10140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143094#comment-17143094
]
Chia-Ping Tsai commented on KAFKA-10140:
The plugin component, like JmxReporter, does not offer
[
https://issues.apache.org/jira/browse/KAFKA-10192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143092#comment-17143092
]
Chris Egerton commented on KAFKA-10192:
---
[~bchen225242] I have a hypothesis for why these tests
[
https://issues.apache.org/jira/browse/KAFKA-10192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chris Egerton reassigned KAFKA-10192:
-
Assignee: Chris Egerton
> Flaky test BlockingConnectorTest#testBlockInConnectorStop
>
cadonna commented on pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#issuecomment-648271480
@ableegoldman could you also have a look at this PR since I think I changed
some code you are quite familiar with.
[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143075#comment-17143075
]
John Roesler commented on KAFKA-10173:
--
Hi [~karsten.schnitter] ,
Thanks for your efforts. I'm
junrao commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-648259565
Thanks. Triggering another round of system tests.
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143066#comment-17143066
]
Karsten Schnitter commented on KAFKA-10173:
---
Hi [~vvcephei],
the original message is lost due
cadonna commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r444334835
##
File path:
streams/src/test/java/org/apache/kafka/streams/kstream/internals/graph/TableSourceNodeTest.java
##
@@ -0,0 +1,58 @@
+/*
+ * Licensed to the
chia7712 commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-648254987
> Could you rebase your PR?
done
This is an automated message from the Apache Git Service.
To respond to
junrao commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-648254407
@chia7712 : I think the client compatibility test failures are probably
because you haven't rebased the PR. #8841 was fixed 6 days ago. Could you
rebase your PR?
junrao commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-648249808
There were still lots of client compatibility related failures
cadonna commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r444325329
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -120,7 +118,7 @@ public void
cadonna commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r444321667
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorContextImpl.java
##
@@ -103,7 +102,6 @@ public
cadonna commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r444321079
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java
##
@@ -103,8 +104,12 @@ public void init(final
cadonna commented on a change in pull request #8902:
URL: https://github.com/apache/kafka/pull/8902#discussion_r444319623
##
File path:
streams/src/main/java/org/apache/kafka/streams/state/internals/MeteredKeyValueStore.java
##
@@ -103,8 +104,12 @@ public void init(final
[
https://issues.apache.org/jira/browse/KAFKA-10192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17143052#comment-17143052
]
Boyang Chen commented on KAFKA-10192:
-
Failed again:
abbccdda commented on pull request #8845:
URL: https://github.com/apache/kafka/pull/8845#issuecomment-648242282
Also failed:
```
kafka.api.PlaintextAdminIntegrationTest.testAlterReplicaLogDirs
org.scalatest.exceptions.TestFailedException: only 0 messages are produced
within
1 - 100 of 132 matches
Mail list logo
