add tests for async producer w. leadership election, use log.exception