使用Kafkastream处理器API时，将输出打印到控制台

Question

当使用StreamDSL时，我可以调用.print(Printed.toConsole())查看控制台中的输出。

使用处理器API时，STH是否相似？我期望PrintToConsoleProcessor或？

肯定可以创建一个虚拟处理器，但是PrintToConsoleProcessor非常有用。

Answer 1

确定可能很容易

topology.addProcessor("console", () -> new Processor() {
            @Override
            public void init(ProcessorContext context) {
            }
            @Override
            public void process(Object key, Object value) {
                System.out.println(value.toString());
            }
            @Override
            public void punctuate(long timestamp) {
            }
            @Override
            public void close() {
            }
        }, "PARENT")