You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
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.
The text was updated successfully, but these errors were encountered:
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.
The text was updated successfully, but these errors were encountered: