Adds missing method to SslBundles impls
This commit is contained in:
@@ -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<String, SslBundle> registerHandler) {
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<String> getBundleNames() {
|
||||
return List.of();
|
||||
|
||||
@@ -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<String, SslBundle> registerHandler) {
|
||||
|
||||
}
|
||||
|
||||
@Override
|
||||
public List<String> getBundleNames() {
|
||||
return List.of();
|
||||
|
||||
Reference in New Issue
Block a user