Hi, I am running into a very strange issue that 'Could not find a "KafkaClient" entry in the JAAS configuration. System property "java.security.auth.login.config" is /etc/kafka/kafka_sink_jaas.conf' on a single node flink cluster when i consume record from kafka using beam KafkaIO.
The JAAS file contains 'KafkaClient', but the flink cluster cannot find the entry. Does anyone know the reason caused? Thanks! -- Fred
