строки из реляционной таблицы в топик с тремя партициями, работает ок. В коннекторе указан mode:bulk и sql запрос. Я выполняю PUT на порт 8083, коннектор начинает работать. Как понять, что все строки из запроса добавлены в топик, то есть коннектор закончил работу и ждет?
Думаю, что можно по статистике топика посмотреть поступают ли новые сообщения. Либо смотреть логи/JMX статистику самого коннектора.
Обсуждают сегодня