Github user cestella commented on the issue:
https://github.com/apache/metron/pull/958
Moving this conversation to the top. I believe I have refactored the
KafkaProducers appropriately. Let me know if I missed something, @justinleet ---
