In CLI, in my krb-client.properties files I can do security.protocol=SASL_SSL sasl.mechanism=GSSAPI
And I invoke echo "bar" | kafka-console-producer.sh --producer.config krb-client.properties it works great. I have a custom Java client but I am not sure how I can incorporate these settings. How can I specify security protocol in Java code?
