Hello, I was wondering if anyone is aware of an implementation of the KafkaBolt that uses the new Java Kafka Producer instead of the legacy Scala one. I have a topology with a high volume of tuples that need to be written to Kafka, so I would like to take advantage of the batching that the asynchronous mode provides. However, I also want to only ack tuples after I have confirmation that they have been successfully written to at least one Kafka broker. Since the Scala producer does not support callbacks, I think I would need to use the new Java producer to realize the desired functionality.
Thoughts? Thanks, -Ryan
