folks, how can I add option to a producer to make a retry?
Typically I’d say that type of testing is beyond the scope of what your application tests should worry about. At most I’d say you can maybe mock out the producer to ensure it’s getting the right config.
You just need to put a retries
key in your producer config https://kafka.apache.org/documentation/#retries