Matthias Wessendorf
I suppose for now you meant just start a consumer, read the last message(or unread messages) and update the metrics and finally stop the consumer. Or you want to start a consumer only the first time the endpoint is invoked and has it running afterwards?