sample code to test kafka producer/consumer on secure/un-secure cluster
Primary LanguageJava
mvn clean package