Java Code to publish messages to a kafka broker.

If using Intellij import the JAR files add the below additional VM options.

-Djava.security.auth.login.config=/tmp/kafka_client_jaas.conf -Djava.security.krb5.conf=/tmp/krb5.conf -Djavax.security.auth.useSubjectCredsOnly=false

Modify the kafka_client_jaas.conf kerberos keytabs as per your environment.