You just need to put a retries key in your producer config https://kafka.apache.org/documentation/#retries

thanks!

there's a recommended way to test the retries on kafka from clojure?

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.