From 7a3b669eec4d5b2da6b9a011027b8d72da149707 Mon Sep 17 00:00:00 2001 From: Skezzowski Date: Wed, 23 Nov 2022 08:26:20 +0100 Subject: [PATCH] DBZ-5772 Fix checkstyle Signed-off-by: Skezzowski --- .../server/nats/jetstream/NatsJetStreamChangeConsumer.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/debezium-server/debezium-server-nats-jetstream/src/main/java/io/debezium/server/nats/jetstream/NatsJetStreamChangeConsumer.java b/debezium-server/debezium-server-nats-jetstream/src/main/java/io/debezium/server/nats/jetstream/NatsJetStreamChangeConsumer.java index 51d5feb30..cba92f916 100644 --- a/debezium-server/debezium-server-nats-jetstream/src/main/java/io/debezium/server/nats/jetstream/NatsJetStreamChangeConsumer.java +++ b/debezium-server/debezium-server-nats-jetstream/src/main/java/io/debezium/server/nats/jetstream/NatsJetStreamChangeConsumer.java @@ -14,7 +14,6 @@ import javax.inject.Inject; import javax.inject.Named; -import io.debezium.server.CustomConsumerBuilder; import org.eclipse.microprofile.config.Config; import org.eclipse.microprofile.config.ConfigProvider; import org.eclipse.microprofile.config.inject.ConfigProperty; @@ -26,6 +25,7 @@ import io.debezium.engine.DebeziumEngine; import io.debezium.engine.DebeziumEngine.RecordCommitter; import io.debezium.server.BaseChangeConsumer; +import io.debezium.server.CustomConsumerBuilder; import io.nats.client.Connection; import io.nats.client.JetStream; import io.nats.client.JetStreamManagement; @@ -57,7 +57,6 @@ public class NatsJetStreamChangeConsumer extends BaseChangeConsumer @ConfigProperty(name = PROP_CREATE_STREAM, defaultValue = "false") boolean createStream; - @Inject @CustomConsumerBuilder Instance customStreamingConnection;