Current transactional implementation of the Kafka Emitter is creating/closing the Producer each time, which consumes a lot of resources (MBean is registered each time, etc). It should be better to reuse the same producer (at the end, it's the same client for the broker).