[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17141736#comment-17141736
]
Karsten Schnitter commented on KAFKA-10173:
---
Hi [~vvcephei],
The application
chia7712 edited a comment on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-647233460
> This is a second run of the system tests.
http://testing.confluent.io/confluent-kafka-branch-builder-system-test-results/?prefix=2020-06-19--001.1592614513--chia7712--fix
Chia-Ping Tsai created KAFKA-10191:
--
Summary: fix flaky StreamsOptimizedTest
Key: KAFKA-10191
URL: https://issues.apache.org/jira/browse/KAFKA-10191
Project: Kafka
Issue Type: Test
chia7712 commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-647352301
I have filed https://issues.apache.org/jira/browse/KAFKA-10191 to trace
```StreamsOptimizedTest```
This is an au
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chia-Ping Tsai updated KAFKA-10191:
---
Description:
{quote}Exception in thread
"StreamsOptimizedTest-53c7d3b1-12b2-4d02-90b1-15757
michael-carter-instaclustr commented on pull request #8844:
URL: https://github.com/apache/kafka/pull/8844#issuecomment-647356784
Thanks for reviewing this @C0urante.
"if the framework successfully instantiates a connector and is able to call
start on it, should that alone qualify as
michael-carter-instaclustr commented on a change in pull request #8844:
URL: https://github.com/apache/kafka/pull/8844#discussion_r443385491
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java
##
@@ -289,7 +285,6 @@ public void startConnect
michael-carter-instaclustr commented on a change in pull request #8844:
URL: https://github.com/apache/kafka/pull/8844#discussion_r443385639
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java
##
@@ -562,7 +556,6 @@ public boolean startTask
michael-carter-instaclustr commented on a change in pull request #8844:
URL: https://github.com/apache/kafka/pull/8844#discussion_r443385901
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerMetricsGroup.java
##
@@ -0,0 +1,204 @@
+/*
+ * Licens
michael-carter-instaclustr commented on a change in pull request #8844:
URL: https://github.com/apache/kafka/pull/8844#discussion_r443386418
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerMetricsGroup.java
##
@@ -0,0 +1,204 @@
+/*
+ * Licens
michael-carter-instaclustr commented on a change in pull request #8844:
URL: https://github.com/apache/kafka/pull/8844#discussion_r443386551
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerMetricsGroup.java
##
@@ -0,0 +1,204 @@
+/*
+ * Licens
itantiger commented on pull request #8753:
URL: https://github.com/apache/kafka/pull/8753#issuecomment-647359639
@ijuma Can you take a look at this (since you requested it in #8390 )?
This is an automated message from the Ap
michael-carter-instaclustr commented on a change in pull request #8844:
URL: https://github.com/apache/kafka/pull/8844#discussion_r443387368
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java
##
@@ -56,7 +56,7 @@
private static fi
[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17141983#comment-17141983
]
Karsten Schnitter commented on KAFKA-10173:
---
Hi [~vvcephei],
after trying for
[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17141983#comment-17141983
]
Karsten Schnitter edited comment on KAFKA-10173 at 6/22/20, 12:21 PM:
mimaison commented on pull request #8604:
URL: https://github.com/apache/kafka/pull/8604#issuecomment-647618474
@kkonstantine @omkreddy Can you take a look? Thanks
This is an automated message from the Apache Git Service.
To
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142237#comment-17142237
]
Sophie Blee-Goldman commented on KAFKA-10191:
-
This looks like it could be a
[
https://issues.apache.org/jira/browse/KAFKA-10138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vinoth Chandar resolved KAFKA-10138.
Resolution: Fixed
> Prefer --bootstrap-server for reassign_partitions command in ducktape
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-10191:
Component/s: unit tests
streams
> fix flaky StreamsOptimizedTest
> --
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142285#comment-17142285
]
Sophie Blee-Goldman commented on KAFKA-10191:
-
Hey [~chia7712], you don't ha
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142285#comment-17142285
]
Sophie Blee-Goldman edited comment on KAFKA-10191 at 6/22/20, 5:29 PM:
---
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142291#comment-17142291
]
Sophie Blee-Goldman commented on KAFKA-10191:
-
I think this could be caused
[
https://issues.apache.org/jira/browse/KAFKA-9974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-9974:
---
Assignee: Guozhang Wang
> Flaky Test OptimizedKTableIntegrationTest#shouldApplyUpdatesToStan
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142301#comment-17142301
]
Jun Rao commented on KAFKA-10191:
-
This test failure occurred
[http://testing.confluent
[
https://issues.apache.org/jira/browse/KAFKA-10184?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler reassigned KAFKA-10184:
Assignee: John Roesler
> Flaky
> HighAvailabilityTaskAssignorIntegrationTest.shouldScale
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10191:
-
Priority: Blocker (was: Major)
> fix flaky StreamsOptimizedTest
> -
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
John Roesler updated KAFKA-10191:
-
Fix Version/s: 2.6.0
> fix flaky StreamsOptimizedTest
> --
>
>
junrao commented on pull request #8657:
URL: https://github.com/apache/kafka/pull/8657#issuecomment-647688705
It seems we just fixed a bunch of client compatibility related failures in
https://github.com/apache/kafka/pull/8841. Another 18 test failures were due to
TLSv1.3 and are tracked i
C0urante commented on a change in pull request #8844:
URL: https://github.com/apache/kafka/pull/8844#discussion_r443742947
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/Worker.java
##
@@ -289,7 +285,6 @@ public void startConnector(
C0urante commented on a change in pull request #8844:
URL: https://github.com/apache/kafka/pull/8844#discussion_r443756424
##
File path:
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/WorkerTask.java
##
@@ -56,7 +56,7 @@
private static final String THREAD_
C0urante commented on pull request #8844:
URL: https://github.com/apache/kafka/pull/8844#issuecomment-647707645
Thanks for the insight @michael-carter-instaclustr. This type of direct user
feedback and perspective is invaluable! I'm convinced that your interpretation
is likely the more use
mjsax commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443759806
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -679,58 +675,75 @@ private void cleanupTask(final Tas
mjsax commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443760619
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -679,58 +675,75 @@ private void cleanupTask(final Tas
mjsax commented on pull request #8022:
URL: https://github.com/apache/kafka/pull/8022#issuecomment-647711505
I am not aware of any particular use-case that needs this feature atm. If
you really want to work on it, feel free to do and we will try to review the
PR. But it would be low priori
mjsax commented on pull request #8029:
URL: https://github.com/apache/kafka/pull/8029#issuecomment-647713849
There is a directory `docs` -- with sub-directory `streams` (cf
https://github.com/apache/kafka/tree/trunk/docs).
As this PR implements a KIP, you should update
`docs/streams
mjsax commented on pull request #8887:
URL: https://github.com/apache/kafka/pull/8887#issuecomment-647718486
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 #8887:
URL: https://github.com/apache/kafka/pull/8887#discussion_r443768571
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -1048,4 +1042,28 @@ public String toString(final Stri
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443769782
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -158,9 +175,15 @@ public InetAddress currentAddress(String
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443770204
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -300,30 +325,47 @@ public AuthenticationException
authent
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443769844
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -158,9 +175,15 @@ public InetAddress currentAddress(String
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443774588
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -357,6 +399,38 @@ private NodeConnectionState nodeState(St
[
https://issues.apache.org/jira/browse/KAFKA-10191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142361#comment-17142361
]
Sophie Blee-Goldman commented on KAFKA-10191:
-
Awesome, thanks Jun.
I think
abbccdda commented on pull request #8725:
URL: https://github.com/apache/kafka/pull/8725#issuecomment-647731489
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
abbccdda opened a new pull request #8725:
URL: https://github.com/apache/kafka/pull/8725
Start the basic template for transaction event simulation.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI bu
abbccdda closed pull request #8725:
URL: https://github.com/apache/kafka/pull/8725
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to t
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443785134
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -357,6 +398,36 @@ private NodeConnectionState nodeState(St
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443785134
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -357,6 +398,36 @@ private NodeConnectionState nodeState(St
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443785134
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -357,6 +398,36 @@ private NodeConnectionState nodeState(St
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443785134
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -357,6 +398,36 @@ private NodeConnectionState nodeState(St
abbccdda commented on pull request #8845:
URL: https://github.com/apache/kafka/pull/8845#issuecomment-647739314
test this please
This is an automated message from the Apache Git Service.
To respond to the message, please log
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443793290
##
File path:
clients/src/main/java/org/apache/kafka/clients/ClusterConnectionStates.java
##
@@ -357,6 +345,37 @@ private NodeConnectionState nodeState(St
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443794598
##
File path:
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
##
@@ -103,6 +103,12 @@
Utils.join(SecurityProtocol.names()
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443806341
##
File path:
clients/src/main/java/org/apache/kafka/clients/CommonClientConfigs.java
##
@@ -185,4 +191,9 @@ public static void
warnIfDeprecatedDnsLookup
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443807553
##
File path: clients/src/main/java/org/apache/kafka/clients/NetworkClient.java
##
@@ -771,7 +794,7 @@ private void processDisconnection(List
responses,
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443808226
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -522,7 +522,7 @@ private void close(final boole
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443809040
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -69,7 +68,6 @@
private final ChangelogRea
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443809040
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -69,7 +68,6 @@
private final ChangelogRea
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443828344
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
##
@@ -267,7 +283,17 @@ public void close()
[
https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142419#comment-17142419
]
Gokul Ramanan Subramanian commented on KAFKA-10105:
---
[~william_reynold
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10189:
-
Description:
The metric
[EventQueueTimeMs|[https://github.com/apache/kafka/blob/trunk/core/src/main/sca
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10189:
-
Description:
The metric
[EventQueueTimeMs|[http://github.com/apache/kafka/blob/trunk/core/src/main/scal
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10189:
-
Description:
The metric
[EventQueueTimeMs|[http://github.com/apache/kafka/blob/trunk/core/src/main/scal
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10189:
-
Description:
The metric
[EventQueueTimeMs|[http://github.com/apache/kafka/blob/trunk/core/src/main/scal
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10189:
-
Description:
The metric
[EventQueueTimeMs|https://github.com/apache/kafka/blob/trunk/core/src/main/scal
[
https://issues.apache.org/jira/browse/KAFKA-10189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10189:
-
Description:
The metric
[EventQueueTimeMs|https://github.com/apache/kafka/blob/trunk/core/src/main/scal
abbccdda commented on pull request #8887:
URL: https://github.com/apache/kafka/pull/8887#issuecomment-647778576
Only one flaky test failed:
```
org.apache.kafka.connect.integration.BlockingConnectorTest.testBlockInConnectorStop
```
Boyang Chen created KAFKA-10192:
---
Summary: Flaky test BlockingConnectorTest#testBlockInConnectorStop
Key: KAFKA-10192
URL: https://issues.apache.org/jira/browse/KAFKA-10192
Project: Kafka
Issue
abbccdda commented on a change in pull request #8887:
URL: https://github.com/apache/kafka/pull/8887#discussion_r443837837
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -1048,4 +1042,28 @@ public String toString(final S
[
https://issues.apache.org/jira/browse/KAFKA-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142429#comment-17142429
]
Boyang Chen commented on KAFKA-10055:
-
Need to move to the shared utility class as w
[
https://issues.apache.org/jira/browse/KAFKA-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142429#comment-17142429
]
Boyang Chen edited comment on KAFKA-10055 at 6/22/20, 9:32 PM:
---
abbccdda commented on pull request #8174:
URL: https://github.com/apache/kafka/pull/8174#issuecomment-647782852
retest this please
This is an automated message from the Apache Git Service.
To respond to the message, please lo
guozhangwang commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443847867
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -69,7 +68,6 @@
private final ChangelogRea
guozhangwang commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443849945
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
##
@@ -267,7 +283,17 @@ public void close()
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443850536
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -679,58 +675,75 @@ private void cleanupTask(fi
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443851041
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -542,7 +542,12 @@ private void close(final bool
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443852154
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -679,58 +675,75 @@ private void cleanupTask(fi
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443852676
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
##
@@ -679,58 +675,75 @@ private void cleanupTask(fi
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443854106
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
##
@@ -203,6 +208,34 @@ public void
shouldBeAbleToRu
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443854750
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
##
@@ -203,6 +208,34 @@ public void
shouldBeAbleToRu
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443855976
##
File path:
streams/src/test/java/org/apache/kafka/streams/integration/EosIntegrationTest.java
##
@@ -203,6 +208,34 @@ public void
shouldBeAbleToRu
abbccdda commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443855731
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
##
@@ -250,10 +250,26 @@ public void flush() {
Jeff Kim created KAFKA-10193:
Summary: Add preemption for ControllerEvent that have callbacks
Key: KAFKA-10193
URL: https://issues.apache.org/jira/browse/KAFKA-10193
Project: Kafka
Issue Type: Bu
[
https://issues.apache.org/jira/browse/KAFKA-10193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jeff Kim updated KAFKA-10193:
-
Summary: Add preemption for controller events that have callbacks (was:
Add preemption for ControllerEv
[
https://issues.apache.org/jira/browse/KAFKA-10055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142451#comment-17142451
]
Vito Jeng commented on KAFKA-10055:
---
[~bchen225242] Got it.
> Add shared internal uti
[
https://issues.apache.org/jira/browse/KAFKA-10173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142460#comment-17142460
]
John Roesler commented on KAFKA-10173:
--
Wow, thanks for that great information, [~k
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443864310
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
##
@@ -267,7 +283,17 @@ public void close()
[
https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142467#comment-17142467
]
Gokul Ramanan Subramanian commented on KAFKA-10105:
---
[~ableegoldman] c
abbccdda merged pull request #8887:
URL: https://github.com/apache/kafka/pull/8887
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to t
abbccdda commented on pull request #8832:
URL: https://github.com/apache/kafka/pull/8832#issuecomment-647809159
test 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_r443871712
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
##
@@ -267,7 +283,17 @@ public void close() {
mjsax commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443871959
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java
##
@@ -542,7 +542,12 @@ private void close(final boolean cle
[
https://issues.apache.org/jira/browse/KAFKA-10105?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17142478#comment-17142478
]
Sophie Blee-Goldman commented on KAFKA-10105:
-
It's possible. If you're able
guozhangwang commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443873843
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
##
@@ -267,7 +283,17 @@ public void close()
mjsax commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443875108
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
##
@@ -267,7 +283,17 @@ public void close() {
mjsax commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443875108
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
##
@@ -267,7 +283,17 @@ public void close() {
ableegoldman commented on a change in pull request #8900:
URL: https://github.com/apache/kafka/pull/8900#discussion_r443877830
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/RecordCollectorImpl.java
##
@@ -267,7 +283,17 @@ public void close()
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443888648
##
File path:
clients/src/main/java/org/apache/kafka/common/utils/ExponentialBackoff.java
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foun
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443890115
##
File path:
clients/src/main/java/org/apache/kafka/common/utils/ExponentialBackoff.java
##
@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foun
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443891445
##
File path:
clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java
##
@@ -321,4 +325,37 @@ public void testIsPreparingConnectio
d8tltanc commented on a change in pull request #8683:
URL: https://github.com/apache/kafka/pull/8683#discussion_r443903133
##
File path:
clients/src/test/java/org/apache/kafka/clients/ClusterConnectionStatesTest.java
##
@@ -321,4 +325,37 @@ public void testIsPreparingConnectio
1 - 100 of 149 matches
Mail list logo
