gharris1727 commented on code in PR #13184:
URL: https://github.com/apache/kafka/pull/13184#discussion_r1119388653


##########
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java:
##########
@@ -531,8 +543,17 @@ private Converter badConverter() {
         return converter;
     }
 
+    private void mockSourceTransform() {
+        FaultyPassthrough<SourceRecord> faultyPassthrough = new 
FaultyPassthrough<>();
+        
doReturn(FaultyPassthrough.class).when(transformationStage).transformClass();
+        when(transformationStage.apply(any())).thenAnswer(invocation -> 
faultyPassthrough.apply(invocation.getArgument(0)));
+    }

Review Comment:
   I added this in preparation for a later commit, but I agree it doesn't make 
much sense in the context of this PR. I'll push this out to that other PR.



-- 
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 the specific comment.

To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to