Scala module with reusable Kafka functionality (including some Java friendliness).
Along with a lot of reusable Kafka code, more can be found (with improvements) in Kafka Demo.
Example usage included while covering "beginner" to "advanced" Kafka courses including: