diff --git a/instrumentation/spring/spring-kafka-2.7/testing/src/main/java/io/opentelemetry/testing/DoNothingBatchErrorHandler.java b/instrumentation/spring/spring-kafka-2.7/testing/src/main/java/io/opentelemetry/testing/DoNothingBatchErrorHandler.java deleted file mode 100644 index 507d84a32807..000000000000 --- a/instrumentation/spring/spring-kafka-2.7/testing/src/main/java/io/opentelemetry/testing/DoNothingBatchErrorHandler.java +++ /dev/null @@ -1,15 +0,0 @@ -/* - * Copyright The OpenTelemetry Authors - * SPDX-License-Identifier: Apache-2.0 - */ - -package io.opentelemetry.testing; - -import org.apache.kafka.clients.consumer.ConsumerRecords; -import org.springframework.kafka.listener.BatchErrorHandler; - -public class DoNothingBatchErrorHandler implements BatchErrorHandler { - - @Override - public void handle(Exception thrownException, ConsumerRecords data) {} -} diff --git a/instrumentation/spring/spring-kafka-2.7/testing/src/main/java/io/opentelemetry/testing/DoNothingErrorHandler.java b/instrumentation/spring/spring-kafka-2.7/testing/src/main/java/io/opentelemetry/testing/DoNothingErrorHandler.java deleted file mode 100644 index 131cba6d7963..000000000000 --- a/instrumentation/spring/spring-kafka-2.7/testing/src/main/java/io/opentelemetry/testing/DoNothingErrorHandler.java +++ /dev/null @@ -1,15 +0,0 @@ -/* - * Copyright The OpenTelemetry Authors - * SPDX-License-Identifier: Apache-2.0 - */ - -package io.opentelemetry.testing; - -import org.apache.kafka.clients.consumer.ConsumerRecord; -import org.springframework.kafka.listener.ErrorHandler; - -public class DoNothingErrorHandler implements ErrorHandler { - - @Override - public void handle(Exception thrownException, ConsumerRecord data) {} -} diff --git a/instrumentation/spring/spring-kafka-2.7/testing/src/main/java/io/opentelemetry/testing/ErrorHandlerSetter.java b/instrumentation/spring/spring-kafka-2.7/testing/src/main/java/io/opentelemetry/testing/ErrorHandlerSetter.java deleted file mode 100644 index 4d2c97c42a36..000000000000 --- a/instrumentation/spring/spring-kafka-2.7/testing/src/main/java/io/opentelemetry/testing/ErrorHandlerSetter.java +++ /dev/null @@ -1,24 +0,0 @@ -/* - * Copyright The OpenTelemetry Authors - * SPDX-License-Identifier: Apache-2.0 - */ - -package io.opentelemetry.testing; - -import org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory; - -// Base classes for error handlers are missing in the latest version. Setter methods were extracted -// in ConsumerConfig to avoid verifier attempting to load these classes. -class ErrorHandlerSetter { - - private ErrorHandlerSetter() {} - - static void setBatchErrorHandler( - ConcurrentKafkaListenerContainerFactory factory) { - factory.setBatchErrorHandler(new DoNothingBatchErrorHandler()); - } - - static void setErrorHandler(ConcurrentKafkaListenerContainerFactory factory) { - factory.setErrorHandler(new DoNothingErrorHandler()); - } -}