-
Notifications
You must be signed in to change notification settings - Fork 81
Open
Description
StreamBuilder builder = new StreamBuilder("wordCount");
RStream<JSONObject> source = builder.source("stream-topic-1", total -> {
String value = new String(total, StandardCharsets.UTF_8);
JSONObject jsonObject = JSON.parseObject(value);
return new Pair<>(null, jsonObject);
});
source.print();
source.sink("stream-topic-sink",new KVJsonSerializer<>());
TopologyBuilder topologyBuilder = builder.build();
In TopologyBuilder, public Processor build(String topicName) is executed in node order and cannot implement multiple sinks. The above code can only execute the first sink.
Reactions are currently unavailable
Metadata
Metadata
Assignees
Labels
No labels