Skip to content

Instantly share code, notes, and snippets.

@gaborgsomogyi
Last active April 4, 2019 15:22
Show Gist options
  • Save gaborgsomogyi/865674380af5b3dcf7b6719ab6b703f5 to your computer and use it in GitHub Desktop.
Save gaborgsomogyi/865674380af5b3dcf7b6719ab6b703f5 to your computer and use it in GitHub Desktop.
$ cat consumer.properties
security.protocol=SASL_SSL
sasl.kerberos.service.name=kafka
ssl.truststore.location=/etc/cdep-ssl-conf/CA_STANDARD/truststore.jks
ssl.truststore.password=cloudera
$ cat jaas.conf
KafkaClient {
com.sun.security.auth.module.Krb5LoginModule required
useKeyTab=true
storeKey=true
keyTab="/cdep/keytabs/systest.keytab"
useTicketCache=false
serviceName="kafka"
principal="systest@GCE.CLOUDERA.COM";
};
export KAFKA_OPTS="-Djava.security.auth.login.config=jaas.conf"
kafka-console-consumer --bootstrap-server $(hostname):9093 --consumer.config consumer.properties --topic topic2 --from-beginning
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment