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.
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.