Обратный вызов Кафки Streams streams.to ()? - PullRequest
0 голосов
/ 12 марта 2019

Я хотел бы знать, сколько времени занимает каждая запись в обработке потоков?Поэтому, когда я потребляю запись, я обернул свой объект полем, скажем, поле StopWatch.start (), и я хотел остановить его, когда я помещаю запись в раздел «Мойка».С простым производителем Kafka я могу сделать это, насколько мне известно.Есть ли способ получить обратный вызов после получения подтверждения от брокера с использованием API Kafka Streams?

...