Отправка сообщения в тему Kafka и регистрация обратного вызова
Я отправляю сообщение в тему Kafka, используя streamBridge. В качестве побочного эффекта успешной отправки мне необходимо выполнить обновление базы данных. У StreamBridge нет никаких обратных вызовов, которые я могу присоединить, и он вызывается асинхронным способом, который я хочу сохранить. Я попытался создать ChannelInterceptor, думая, что он будет вызываться после отправки сообщения, но он не перехватил никаких событий.
Я также пытался настроить свой собственный канал, но в этом случае мне нужно настроить подписчика, и я не уверен, кто должен быть подписчиком.
Может быть, есть более простой способ подключить слушателя к streamBridge, о котором я не знаю?