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

DBZ-6773 Cleaning unused fields and variables in tests

Browse Source
This commit is contained in:
Jakub Cechacek 2023-09-06 09:11:31 +02:00 committed by Jiri Pechanec
parent c748fc494b
commit 842e92bc52
1 changed files with 0 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/transforms/ExtractNewDocumentStateTest.java
View File

@ -10,10 +10,8 @@
import static io.debezium.junit.SkipWhenKafkaVersion.KafkaVersion.KAFKA_241;
import static org.assertj.core.api.Assertions.assertThat;
import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import org.apache.kafka.connect.data.Schema;
import org.apache.kafka.connect.data.SchemaBuilder;
@ -26,18 +24,10 @@
import org.junit.rules.ExpectedException;
import org.junit.rules.TestRule;
import io.debezium.config.CommonConnectorConfig;
import io.debezium.config.Configuration;
import io.debezium.connector.AbstractSourceInfo;
import io.debezium.connector.mongodb.Configurator;
import io.debezium.connector.mongodb.Filters;
import io.debezium.connector.mongodb.MongoDbConnectorConfig;
import io.debezium.connector.mongodb.SourceInfo;
import io.debezium.doc.FixFor;
import io.debezium.junit.SkipTestRule;
import io.debezium.junit.SkipWhenKafkaVersion;
import io.debezium.schema.DefaultTopicNamingStrategy;
import io.debezium.spi.topic.TopicNamingStrategy;
/**
* Unit test for {@link ExtractNewDocumentState}.
@ -48,11 +38,6 @@ public class ExtractNewDocumentStateTest {
private static final String SERVER_NAME = "serverX";
private Filters filters;
private SourceInfo source;
private TopicNamingStrategy topicNamingStrategy;
private List<SourceRecord> produced;
private ExtractNewDocumentState<SourceRecord> transformation;
@Rule
@ -63,15 +48,6 @@ public class ExtractNewDocumentStateTest {
@Before
public void setup() {
filters = new Configurator().createFilters();
MongoDbConnectorConfig connectorConfig = new MongoDbConnectorConfig(
Configuration.create()
.with(CommonConnectorConfig.TOPIC_PREFIX, SERVER_NAME)
.build());
source = new SourceInfo(connectorConfig);
topicNamingStrategy = DefaultTopicNamingStrategy.create(connectorConfig);
produced = new ArrayList<>();
transformation = new ExtractNewDocumentState<>();
transformation.configure(Collections.singletonMap("array.encoding", "array"));
}