Skip to content

Commit 54998d8

Browse files
committed
fixed config in unit test
1 parent 877d14b commit 54998d8

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@ public void createTask() {
2929
private void startTask(RedisServer redis) {
3030
final Map<String, String> config = new HashMap<>();
3131
config.put("redis.uri", redis.getRedisURI());
32-
config.put("redis.key", STREAM);
32+
config.put("redis.stream.name", STREAM);
3333
task.start(config);
3434
}
3535

0 commit comments

Comments
 (0)