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