KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is not set

dkJava11 发布于 2020/02/24 10:46

阅读 5K+

Apache

Scala

Java

Apache Kafka LAIN Entry

ssl.key.password = null
   ssl.keymanager.algorithm = SunX509
   ssl.keystore.location = null
   ssl.keystore.password = null
   ssl.keystore.type = JKS
   ssl.protocol = TLS
   ssl.provider = null
   ssl.secure.random.implementation = null
   ssl.trustmanager.algorithm = PKIX
   ssl.truststore.location = null
   ssl.truststore.password = null
   ssl.truststore.type = JKS
   value.deserializer = class org.apache.kafka.common.serialization.ByteArrayDeserializer

20/02/24 10:52:16 ERROR tools.ConsoleConsumer$: Unknown error when running consumer:
org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
   at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:811)
   at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:659)
   at kafka.tools.ConsoleConsumer$.run(ConsoleConsumer.scala:67)
   at kafka.tools.ConsoleConsumer$.main(ConsoleConsumer.scala:54)
   at kafka.tools.ConsoleConsumer.main(ConsoleConsumer.scala)
Caused by: java.lang.IllegalArgumentException: Could not find a 'KafkaClient' entry in the JAAS configuration. System property 'java.security.auth.login.config' is not set
   at org.apache.kafka.common.security.JaasContext.defaultContext(JaasContext.java:133)
   at org.apache.kafka.common.security.JaasContext.load(JaasContext.java:98)
   at org.apache.kafka.common.security.JaasContext.loadClientContext(JaasContext.java:84)
   at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:124)
   at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:67)
   at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:99)
   at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:726)