[GitHub] [kafka] mjsax commented on a change in pull request #10300: KAFKA-12452: Remove deprecated overloads of ProcessorContext#forward

2021-03-12 Thread GitBox
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 {

[GitHub] [kafka] mjsax commented on a change in pull request #10300: KAFKA-12452: Remove deprecated overloads of ProcessorContext#forward

2021-03-12 Thread GitBox
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

[GitHub] [kafka] mjsax commented on a change in pull request #10300: KAFKA-12452: Remove deprecated overloads of ProcessorContext#forward

2021-03-12 Thread GitBox
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

[GitHub] [kafka] mjsax commented on a change in pull request #10300: KAFKA-12452: Remove deprecated overloads of ProcessorContext#forward

2021-03-11 Thread GitBox
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

[GitHub] [kafka] mjsax commented on a change in pull request #10300: KAFKA-12452: Remove deprecated overloads of ProcessorContext#forward

2021-03-11 Thread GitBox
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

[GitHub] [kafka] mjsax commented on a change in pull request #10300: KAFKA-12452: Remove deprecated overloads of ProcessorContext#forward

2021-03-10 Thread GitBox
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 {

[GitHub] [kafka] mjsax commented on a change in pull request #10300: KAFKA-12452: Remove deprecated overloads of ProcessorContext#forward

2021-03-10 Thread GitBox
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