Выводить вывод на консоль при использовании API процессора KafkaStream - PullRequest
0 голосов
/ 10 мая 2019

При использовании StreamDSL я могу вызвать .print(Printed.toConsole()), чтобы увидеть вывод в консоли.

Есть ли что-то подобное при использовании Processor API?Я ожидаю PrintToConsoleProcessor или?

Конечно, я могу создать фиктивный процессор, но PrintToConsoleProcessor было бы очень полезно.

1 Ответ

1 голос
/ 10 мая 2019

Ок, может быть довольно просто

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