added connector tests

Author: jruaux

src/main/java/com/redislabs/kafkaconnect/RedisEnterpriseSinkConnector.java

@@ -26,7 +26,7 @@
 import java.util.List;
 import java.util.Map;
 
-public class  RedisEnterpriseSinkConnector extends SinkConnector {
+public class RedisEnterpriseSinkConnector extends SinkConnector {
 
     private Map<String, String> props;
 

src/main/java/com/redislabs/kafkaconnect/common/RedisEnterpriseConfigException.java

@@ -1,12 +1,12 @@
 /**
  * Copyright © 2021 Redis Labs
- *
+ * <p>
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
  * You may obtain a copy of the License at
- *
+ * <p>
  * http://www.apache.org/licenses/LICENSE-2.0
- *
+ * <p>
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
@@ -20,19 +20,19 @@
 
 public class RedisEnterpriseConfigException extends ConfigException {
 
-  @Getter
-  private final String name;
-  @Getter
-  private final Object value;
-  @Getter
-  private final String originalMessage;
+    @Getter
+    private final String name;
+    @Getter
+    private final Object value;
+    @Getter
+    private final String originalMessage;
 
-  public RedisEnterpriseConfigException(String name, Object value, String message) {
-    super(name, value, message);
-    this.name = name;
-    this.value = value;
-    this.originalMessage = message;
-  }
+    public RedisEnterpriseConfigException(String name, Object value, String message) {
+        super(name, value, message);
+        this.name = name;
+        this.value = value;
+        this.originalMessage = message;
+    }
 
 
 }

src/test/java/com/redislabs/kafkaconnect/AbstractRedisEnterpriseTest.java

@@ -1,13 +1,10 @@
 package com.redislabs.kafkaconnect;
 
-import com.redislabs.testcontainers.RedisContainer;
 import com.redislabs.testcontainers.RedisStandaloneContainer;
 import io.lettuce.core.RedisClient;
 import io.lettuce.core.api.StatefulRedisConnection;
 import io.lettuce.core.api.sync.RedisCommands;
-import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.AfterEach;
-import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
 import org.springframework.util.Assert;
 import org.testcontainers.junit.jupiter.Container;

src/test/java/com/redislabs/kafkaconnect/RedisEnterpriseSinkConnectorTest.java

@@ -0,0 +1,37 @@
+package com.redislabs.kafkaconnect;
+
+import com.redislabs.kafkaconnect.sink.RedisEnterpriseSinkConfig;
+import com.redislabs.kafkaconnect.sink.RedisEnterpriseSinkTask;
+import io.lettuce.core.StreamMessage;
+import io.lettuce.core.XReadArgs;
+import org.apache.kafka.common.config.ConfigDef;
+import org.apache.kafka.connect.data.Schema;
+import org.apache.kafka.connect.data.SchemaBuilder;
+import org.apache.kafka.connect.data.Struct;
+import org.apache.kafka.connect.sink.SinkRecord;
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import java.util.Arrays;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class RedisEnterpriseSinkConnectorTest {
+
+    @Test
+    public void testConfig() {
+        ConfigDef config = new RedisEnterpriseSinkConnector().config();
+        Assertions.assertNotNull(config);
+        Assertions.assertTrue(config instanceof RedisEnterpriseSinkConfig.RedisEnterpriseSinkConfigDef);
+    }
+
+    @Test
+    public void testTask() {
+        Assertions.assertEquals(RedisEnterpriseSinkTask.class, new RedisEnterpriseSinkConnector().taskClass());
+    }
+
+
+}

src/test/java/com/redislabs/kafkaconnect/RedisEnterpriseSourceConnectorTest.java

@@ -0,0 +1,24 @@
+package com.redislabs.kafkaconnect;
+
+import com.redislabs.kafkaconnect.source.RedisEnterpriseSourceConfig;
+import com.redislabs.kafkaconnect.source.RedisEnterpriseSourceTask;
+import org.apache.kafka.common.config.ConfigDef;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.Test;
+
+public class RedisEnterpriseSourceConnectorTest {
+
+    @Test
+    public void testConfig() {
+        ConfigDef config = new RedisEnterpriseSourceConnector().config();
+        Assertions.assertNotNull(config);
+        Assertions.assertTrue(config instanceof RedisEnterpriseSourceConfig.RedisEnterpriseSourceConfigDef);
+    }
+
+    @Test
+    public void testTask() {
+        Assertions.assertEquals(RedisEnterpriseSourceTask.class, new RedisEnterpriseSourceConnector().taskClass());
+    }
+
+
+}