Skip to content

Commit 5ad285b

Browse files
committed
added config test
1 parent 8b16482 commit 5ad285b

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

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

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,16 +3,25 @@
33
import com.redislabs.kafkaconnect.source.RedisEnterpriseSourceConfig;
44
import com.redislabs.kafkaconnect.source.RedisEnterpriseSourceTask;
55
import org.apache.kafka.common.config.ConfigDef;
6+
import org.apache.kafka.common.config.ConfigValue;
67
import org.junit.jupiter.api.Assertions;
78
import org.junit.jupiter.api.Test;
89

10+
import java.util.HashMap;
11+
import java.util.Map;
12+
913
public class RedisEnterpriseSourceConnectorTest {
1014

1115
@Test
1216
public void testConfig() {
1317
ConfigDef config = new RedisEnterpriseSourceConnector().config();
1418
Assertions.assertNotNull(config);
1519
Assertions.assertTrue(config instanceof RedisEnterpriseSourceConfig.RedisEnterpriseSourceConfigDef);
20+
Map<String, ConfigValue> results = config.validateAll(new HashMap<>());
21+
ConfigValue value = results.get(RedisEnterpriseSourceConfig.STREAM_NAME);
22+
Assertions.assertEquals(RedisEnterpriseSourceConfig.STREAM_NAME, value.name());
23+
Assertions.assertNull(value.value());
24+
Assertions.assertEquals("Invalid value null for configuration redis.stream.name: Missing stream configuration: '" + RedisEnterpriseSourceConfig.STREAM_NAME + "'", value.errorMessages().get(0));
1625
}
1726

1827
@Test

0 commit comments

Comments
 (0)