Arjan van Wieringen
11/07/2025, 6:56 AMfun Application.module(myService: MyService) {
subscribe(topic = "my-topic", autoOffsetReset = Latest) {
on<UserRegistered> { event ->
myService.userHasRegistered(event.user)
}
}
}
No need for HTTP (although I use it for liveness and readyness probe) but I use al the Ktor app featuresBruce Hamilton
11/07/2025, 8:05 AMArjan van Wieringen
11/07/2025, 8:28 AMrnett
11/07/2025, 6:19 PMAaron Freeman
11/09/2025, 3:03 AMBruce Hamilton
11/09/2025, 7:57 AMArjan van Wieringen
11/09/2025, 8:40 AM