Hi Gwenhael, Sorry for the very long delayed response on this.
As you noticed, the “KafkaClient” entry name seems to be a hardcoded thing on the Kafka side, so currently I don’t think what you’re asking for is possible. It seems like this could be made possible with some of the new authentication features in Kafka 0.10 that seems related: [1] [2]. I’m not that deep into the authentication modules, but I’ll take a look and can keep you posted on this. Also looping in Eron (in CC) who could perhaps provide more insight on this at the same time. Cheers, Gordon [1] https://cwiki.apache.org/confluence/display/KAFKA/KIP-83+-+Allow+multiple+SASL+authenticated+Java+clients+in+a+single+JVM+process [2] https://cwiki.apache.org/confluence/display/KAFKA/KIP-85%3A+Dynamic+JAAS+configuration+for+Kafka+clients On 26 April 2017 at 8:48:20 PM, Gwenhael Pasquiers (gwenhael.pasqui...@ericsson.com) wrote: Hello, Up to now we’ve been using kafka with jaas (plain login/password) the following way: - yarnship the jaas file - add the jaas file name into “flink-conf.yaml” using property “env.java.opts” How to support multiple secured kafka 0.10 consumers and producers (with different logins and password of course) ? From what I saw in the kafka sources, the entry name “KafkaClient” is hardcoded… Best Regards, Gwenhaël PASQUIERS
