mjsax commented on a change in pull request #10300:
URL: https://github.com/apache/kafka/pull/10300#discussion_r593539158
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java
##
@@ -37,7 +37,6 @@
public class ProcessorNode {
mjsax commented on a change in pull request #10300:
URL: https://github.com/apache/kafka/pull/10300#discussion_r593538979
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/ProcessorTopologyTest.java
##
@@ -280,61 +280,6 @@ public void
mjsax commented on a change in pull request #10300:
URL: https://github.com/apache/kafka/pull/10300#discussion_r593538020
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContextTest.java
##
@@ -155,29 +155,20 @@ public void
mjsax commented on a change in pull request #10300:
URL: https://github.com/apache/kafka/pull/10300#discussion_r592837536
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContextTest.java
##
@@ -155,29 +155,20 @@ public void
mjsax commented on a change in pull request #10300:
URL: https://github.com/apache/kafka/pull/10300#discussion_r592837536
##
File path:
streams/src/test/java/org/apache/kafka/streams/processor/internals/AbstractProcessorContextTest.java
##
@@ -155,29 +155,20 @@ public void
mjsax commented on a change in pull request #10300:
URL: https://github.com/apache/kafka/pull/10300#discussion_r592036244
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/internals/ProcessorNode.java
##
@@ -37,7 +37,6 @@
public class ProcessorNode {
mjsax commented on a change in pull request #10300:
URL: https://github.com/apache/kafka/pull/10300#discussion_r592035201
##
File path:
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java
##
@@ -189,29 +189,6 @@ Cancellable schedule(final Duration