From fca2ffab61ead76ccce33dde037902565599ecec Mon Sep 17 00:00:00 2001 From: spencergibb Date: Wed, 29 Jan 2025 15:56:42 -0500 Subject: [PATCH] Adds missing method to SslBundles impls --- .../kafka/KafkaItemReaderAutoConfigurationTests.java | 6 ++++++ .../batch/autoconfigure/kafka/KafkaItemWriterTests.java | 6 ++++++ 2 files changed, 12 insertions(+) diff --git a/spring-cloud-starter-single-step-batch-job/src/test/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemReaderAutoConfigurationTests.java b/spring-cloud-starter-single-step-batch-job/src/test/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemReaderAutoConfigurationTests.java index 996d8cae..7f41f5de 100644 --- a/spring-cloud-starter-single-step-batch-job/src/test/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemReaderAutoConfigurationTests.java +++ b/spring-cloud-starter-single-step-batch-job/src/test/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemReaderAutoConfigurationTests.java @@ -21,6 +21,7 @@ import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.function.BiConsumer; import java.util.function.Consumer; import org.apache.kafka.clients.admin.NewTopic; @@ -245,6 +246,11 @@ public class KafkaItemReaderAutoConfigurationTests { } + @Override + public void addBundleRegisterHandler(BiConsumer registerHandler) { + + } + @Override public List getBundleNames() { return List.of(); diff --git a/spring-cloud-starter-single-step-batch-job/src/test/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemWriterTests.java b/spring-cloud-starter-single-step-batch-job/src/test/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemWriterTests.java index b837dd33..b6cd51e8 100644 --- a/spring-cloud-starter-single-step-batch-job/src/test/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemWriterTests.java +++ b/spring-cloud-starter-single-step-batch-job/src/test/java/org/springframework/cloud/task/batch/autoconfigure/kafka/KafkaItemWriterTests.java @@ -20,6 +20,7 @@ import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; +import java.util.function.BiConsumer; import org.apache.kafka.clients.consumer.Consumer; import org.apache.kafka.clients.consumer.ConsumerRecords; @@ -160,6 +161,11 @@ public class KafkaItemWriterTests { } + @Override + public void addBundleRegisterHandler(BiConsumer registerHandler) { + + } + @Override public List getBundleNames() { return List.of();