**Describe the feature** When we listen to messages from Kafka we will need to handle retries and failures