dajac commented on code in PR #12035:
URL: https://github.com/apache/kafka/pull/12035#discussion_r858303688
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1498,6 +1516,37 @@ public synchronized boolean close(final Duration
timeout) throws
dajac commented on code in PR #12035:
URL: https://github.com/apache/kafka/pull/12035#discussion_r858024381
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1498,6 +1516,37 @@ public synchronized boolean close(final Duration
timeout) throws
dajac commented on code in PR #12035:
URL: https://github.com/apache/kafka/pull/12035#discussion_r858019261
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1498,6 +1516,37 @@ public synchronized boolean close(final Duration
timeout) throws
dajac commented on code in PR #12035:
URL: https://github.com/apache/kafka/pull/12035#discussion_r857116257
##
streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java:
##
@@ -1498,6 +1516,37 @@ public synchronized boolean close(final Duration
timeout) throws