[kafka] branch trunk updated: MINOR: Silence error logs for faulty plugins in integration tests (#13912)

[cegerton]

This is an automated email from the ASF dual-hosted git repository.

cegerton pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 39786841261 MINOR: Silence error logs for faulty plugins in 
integration tests (#13912)
39786841261 is described below

commit 397868412612bbb908e0d075b1d4cb5ede20d7ac
Author: Greg Harris <greg.har...@aiven.io>
AuthorDate: Fri Jun 23 14:10:18 2023 -0400

    MINOR: Silence error logs for faulty plugins in integration tests (#13912)
    
    Reviewers: Chris Egerton <chr...@aiven.io>
---
 .../org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java     | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git 
a/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java
 
b/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java
index 1946b01ee5d..239141ec20d 100644
--- 
a/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java
+++ 
b/connect/runtime/src/test/java/org/apache/kafka/connect/runtime/ErrorHandlingTaskTest.java
@@ -554,7 +554,8 @@ public class ErrorHandlingTaskTest {
     private abstract static class TestSinkTask extends SinkTask {
     }
 
-    static class FaultyConverter extends JsonConverter {
+    // Public to allow plugin discovery to complete without errors
+    public static class FaultyConverter extends JsonConverter {
         private static final Logger log = 
LoggerFactory.getLogger(FaultyConverter.class);
         private int invocations = 0;
 
@@ -573,7 +574,8 @@ public class ErrorHandlingTaskTest {
         }
     }
 
-    static class FaultyPassthrough<R extends ConnectRecord<R>> implements 
Transformation<R> {
+    // Public to allow plugin discovery to complete without errors
+    public static class FaultyPassthrough<R extends ConnectRecord<R>> 
implements Transformation<R> {
 
         private static final Logger log = 
LoggerFactory.getLogger(FaultyPassthrough.class);