Commit 8aca4458 authored by Stephen Nimmo's avatar Stephen Nimmo
Browse files

Switched source and sink alignment for the bindings vs the streamType

parent 97fa5938
Pipeline #77756 failed with stage
in 1 minute and 22 seconds
......@@ -53,9 +53,9 @@ public class TopicAdminServiceImpl implements TopicAdminService {
StreamDefinition streamDefinition = streamRecord.getData().getDatasetProperties().getStreamDefinition();
switch (streamType) {
case SOURCE:
return streamDefinition.getSourceBindings();
case SINK:
return streamDefinition.getSinkBindings();
case SINK:
return streamDefinition.getSourceBindings();
case PROCESSOR:
return Stream.concat(streamDefinition.getSourceBindings().stream(), streamDefinition.getSinkBindings().stream()).collect(Collectors.toList());
default:
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment