Skip to content

Commit 0d0d44b

Browse files
committed
Create test to prove config check is broken
1 parent 6e37e51 commit 0d0d44b

File tree

1 file changed

+16
-1
lines changed

1 file changed

+16
-1
lines changed

src/test/java/com/splunk/kafka/connect/SplunkSinkConnecterTest.java

+16-1
Original file line numberDiff line numberDiff line change
@@ -207,6 +207,21 @@ public void testInvalidIndex() {
207207
Assertions.assertThrows(ConfigException.class, ()->connector.validate(configs));
208208
}
209209

210+
@Test
211+
public void testValidMultipleURIs() {
212+
final Map<String, String> configs = new HashMap<>();
213+
addNecessaryConfigs(configs);
214+
SplunkSinkConnector connector = new SplunkSinkConnector();
215+
configs.put("topics", "b");
216+
configs.put("splunk.indexes", "b");
217+
configs.put("splunk.hec.uri", "https://localhost:8088,https://localhost:8089");
218+
configs.put("splunk.hec.ssl.validate.certs", "false");
219+
MockHecClientWrapper clientInstance = new MockHecClientWrapper();
220+
clientInstance.client.setResponse(CloseableHttpClientMock.success);
221+
((SplunkSinkConnector) connector).setHecInstance(clientInstance);
222+
Assertions.assertDoesNotThrow(()->connector.validate(configs));
223+
}
224+
210225
@Test
211226
public void testValidSplunkConfigurations() {
212227
final Map<String, String> configs = new HashMap<>();
@@ -237,4 +252,4 @@ private void assertHasErrorMessage(Config config, String property, String msg) {
237252
private void assertNoErrors(Config config) {
238253
config.configValues().forEach(c -> assertTrue(c.errorMessages().isEmpty()));
239254
}
240-
}
255+
}

0 commit comments

Comments
 (0)