与Kafka的关系问题

pxy2qtax  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(321)

我对Kafka和 java 都是新手。我是第一次建立一个消费者应用程序。
我收到以下错误消息。
排除故障的方法有哪些?

  1. Exception in thread "main" org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
  2. at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:823)
  3. at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:667)
  4. at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:647)
  5. at com.abc.kafka.martechconsumer.ConsumerGroups.main(ConsumerGroups.java:76)
  6. Caused by: java.lang.IllegalArgumentException: Login module control flag not specified in JAAS config
  7. at org.apache.kafka.common.security.JaasConfig.parseAppConfigurationEntry(JaasConfig.java:110)
  8. at org.apache.kafka.common.security.JaasConfig.<init>(JaasConfig.java:63)
  9. at org.apache.kafka.common.security.JaasContext.load(JaasContext.java:90)
  10. at org.apache.kafka.common.security.JaasContext.loadClientContext(JaasContext.java:84)
  11. at org.apache.kafka.common.network.ChannelBuilders.create(ChannelBuilders.java:134)
  12. at org.apache.kafka.common.network.ChannelBuilders.clientChannelBuilder(ChannelBuilders.java:73)
  13. at org.apache.kafka.clients.ClientUtils.createChannelBuilder(ClientUtils.java:105)
  14. at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:740)

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题