I have implemented a workflow in Kestra which is polling for status of other workflows and writing the results into a Kafka topic for more detailed monitoring. I am having an issue once in a while ...