Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
Currently, the KafkaSystemProducer's producer loop keeps retrying indefinitely when there is an exception in the retryBackOff loop. If there are repeated exceptions, then it makes sense to retry for awhile, and then fail the container.
Long term, we should focus on getting rid off the retryBackOff loop, and close the producer object in the callback during failure. This will guarantee in-order delivery.