alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-5772 Fix checkstyle

Browse Source 
Signed-off-by: Skezzowski <sipblai@gmail.com>
This commit is contained in:
Skezzowski 2022-11-23 08:26:20 +01:00 committed by Jiri Pechanec
parent 1734b03b1c
commit 7a3b669eec
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
debezium-server/debezium-server-nats-jetstream/src/main/java/io/debezium/server/nats/jetstream/NatsJetStreamChangeConsumer.java
View File

@ -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<JetStream> customStreamingConnection;