[GitHub] [kafka] ableegoldman commented on a change in pull request #9863: MINOR: Restore interrupt status when closing

2021-01-25 Thread GitBox
ableegoldman commented on a change in pull request #9863: URL: https://github.com/apache/kafka/pull/9863#discussion_r563978428 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java ## @@ -612,11 +612,22 @@ public void

[GitHub] [kafka] ableegoldman commented on a change in pull request #9863: MINOR: Restore interrupt status when closing

2021-01-25 Thread GitBox
ableegoldman commented on a change in pull request #9863: URL: https://github.com/apache/kafka/pull/9863#discussion_r563978428 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java ## @@ -612,11 +612,22 @@ public void

[GitHub] [kafka] ableegoldman commented on a change in pull request #9863: MINOR: Restore interrupt status when closing

2021-01-22 Thread GitBox
ableegoldman commented on a change in pull request #9863: URL: https://github.com/apache/kafka/pull/9863#discussion_r562882284 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java ## @@ -612,11 +612,22 @@ public void

[GitHub] [kafka] ableegoldman commented on a change in pull request #9863: MINOR: Restore interrupt status when closing

2021-01-22 Thread GitBox
ableegoldman commented on a change in pull request #9863: URL: https://github.com/apache/kafka/pull/9863#discussion_r562815151 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamThread.java ## @@ -612,11 +612,22 @@ public void

[GitHub] [kafka] ableegoldman commented on a change in pull request #9863: MINOR: Restore interrupt status when closing

2021-01-22 Thread GitBox
ableegoldman commented on a change in pull request #9863: URL: https://github.com/apache/kafka/pull/9863#discussion_r562813288 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -249,20 +249,31 @@ public boolean isValidTransition(final State

[GitHub] [kafka] ableegoldman commented on a change in pull request #9863: MINOR: Restore interrupt status when closing

2021-01-12 Thread GitBox
ableegoldman commented on a change in pull request #9863: URL: https://github.com/apache/kafka/pull/9863#discussion_r556176651 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -249,20 +249,31 @@ public boolean isValidTransition(final State

[GitHub] [kafka] ableegoldman commented on a change in pull request #9863: MINOR: Restore interrupt status when closing

2021-01-12 Thread GitBox
ableegoldman commented on a change in pull request #9863: URL: https://github.com/apache/kafka/pull/9863#discussion_r556176651 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -249,20 +249,31 @@ public boolean isValidTransition(final State

[GitHub] [kafka] ableegoldman commented on a change in pull request #9863: MINOR: Restore interrupt status when closing

2021-01-12 Thread GitBox
ableegoldman commented on a change in pull request #9863: URL: https://github.com/apache/kafka/pull/9863#discussion_r556176651 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -249,20 +249,31 @@ public boolean isValidTransition(final State

[GitHub] [kafka] ableegoldman commented on a change in pull request #9863: MINOR: Restore interrupt status when closing

2021-01-12 Thread GitBox
ableegoldman commented on a change in pull request #9863: URL: https://github.com/apache/kafka/pull/9863#discussion_r556039219 ## File path: streams/src/main/java/org/apache/kafka/streams/KafkaStreams.java ## @@ -249,20 +249,31 @@ public boolean isValidTransition(final State