kafka icon indicating copy to clipboard operation
kafka copied to clipboard

Externally renewed ticket is not getting reloaded and renewTgt not working as expected

Open javatype opened this issue 4 years ago • 0 comments

Hi,

I am using kafka appender library to push logs to logstash. I am using kerberos authentication method to connect to kafka broker. At the start of my app, everything works fine and I am able to connect to kafka brokers. Below are few producer configs I am providing.

 <producerConfig>sasl.jaas.config=com.sun.security.auth.module.krb5LoginModule
required
ticketCache="path-to-my-ticket-cache"
useTicketCache="true"
refreshKrb5Config="true"
doNotPrompt="true"
principal="myprincipal@realm";
</producerConfig>

When I hit this command - klist -c path-to-my-ticket-cache , I see ticket is getting renewed after every 2 hours but the same renewed time is not reflecting in my java app. The app still shows the initial expiry time loaded at startup and it destroys the ticket after expiry and authentication starts failing.

Few Things I tried,

Added renewTgt=true and sasl.kerberos.kinit.cmd=/usr/bin/kinit -c path-to-my-ticket-cache -R property to producer config, it tried to renew but failed with error-IOException: error=2, No such file or directory. When i hit same command from shell, it works fine and renew ticket. how I can pass cache location parameter in this command? How we can force the app to read the ticket from the main cache which is getting renewed but kafka client seems not aware of it?

javatype avatar Jan 20 '21 10:01 javatype