Added database to the url. Fixes #14. (#15)

jcustenborder · web-flow · commit f88ef7e5cf90 · 2019-09-11T16:44:34.000-05:00
diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/redis/RedisConnectorConfig.java b/src/main/java/com/github/jcustenborder/kafka/connect/redis/RedisConnectorConfig.java
@@ -218,6 +218,7 @@ public List<RedisURI> redisURIs() {
       RedisURI.Builder builder = RedisURI.builder();
       builder.withHost(host.getHost());
       builder.withPort(host.getPort());
+      builder.withDatabase(this.database);
       if (!Strings.isNullOrEmpty(this.password)) {
         builder.withPassword(this.password);
       }

Original file line number	Diff line number	Diff line change
`@@ -218,6 +218,7 @@ public List<RedisURI> redisURIs() {`
`218`	`218`	`RedisURI.Builder builder = RedisURI.builder();`
`219`	`219`	`builder.withHost(host.getHost());`
`220`	`220`	`builder.withPort(host.getPort());`
	`221`	`+ builder.withDatabase(this.database);`
`221`	`222`	`if (!Strings.isNullOrEmpty(this.password)) {`
`222`	`223`	`builder.withPassword(this.password);`
`223`	`224`	`}`