'Sending message to Kafka topic and registering callback
I am sending message to Kafka topic using streamBridge. As a side-effect of successful sending I need to perform database update. StreamBridge doesn't have any callbacks that I can attach, and it's being called in asynchronous way that I want to keep. I tried creating ChannelInterceptor thinking that it will be called once message is sent, but it didn't catch any evnts.
I also tried setting my own Channel, but I need to setup subscriber in this case, and I am not sure who is the subscriber should be.
May be there is simpler way to attach listener to streamBridge that I am not aware of?
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
| Solution | Source |
|---|