kafka启动报错 DelegationToken not a valid resourceType name

FATAL [Kafka Server 0], Fatal error during KafkaServer startup. Prepare to shutdown (kafka.server.KafkaServer)

kafka.common.KafkaException: DelegationToken not a valid resourceType name. The valid names are Topic,Group,Cluster,TransactionalId
    at kafka.security.auth.ResourceType$$anonfun$fromString$1.apply(ResourceType.scala:56)
    at kafka.security.auth.ResourceType$$anonfun$fromString$1.apply(ResourceType.scala:56)
    at scala.Option.getOrElse(Option.scala:121)
    at kafka.security.auth.ResourceType$.fromString(ResourceType.scala:56)
    at kafka.security.auth.SimpleAclAuthorizer$$anonfun$loadCache$1$$anonfun$apply$mcV$sp$1.apply(SimpleAclAuthorizer.scala:234)
    at kafka.security.auth.SimpleAclAuthorizer$$anonfun$loadCache$1$$anonfun$apply$mcV$sp$1.apply(SimpleAclAuthorizer.scala:233)
    at scala.collection.Iterator$class.foreach(Iterator.scala:891)
    at scala.collection.AbstractIterator.foreach(Iterator.scala:1334)
    at scala.collection.IterableLike$class.foreach(IterableLike.scala:72)
    at scala.collection.AbstractIterable.foreach(Iterable.scala:54)
    at kafka.security.auth.SimpleAclAuthorizer$$anonfun$loadCache$1.apply$mcV$sp(SimpleAclAuthorizer.scala:233)
    at kafka.security.auth.SimpleAclAuthorizer$$anonfun$loadCache$1.apply(SimpleAclAuthorizer.scala:231)
    at kafka.security.auth.SimpleAclAuthorizer$$anonfun$loadCache$1.apply(SimpleAclAuthorizer.scala:231)
    at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:213)
    at kafka.utils.CoreUtils$.inWriteLock(CoreUtils.scala:221)
    at kafka.security.auth.SimpleAclAuthorizer.loadCache(SimpleAclAuthorizer.scala:231)
    at kafka.security.auth.SimpleAclAuthorizer.configure(SimpleAclAuthorizer.scala:115)
    at kafka.server.KafkaServer$$anonfun$startup$4.apply(KafkaServer.scala:247)
    at kafka.server.KafkaServer$$anonfun$startup$4.apply(KafkaServer.scala:245)
    at scala.Option.map(Option.scala:146)
    at kafka.server.KafkaServer.startup(KafkaServer.scala:245)
    at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:38)
    at kafka.Kafka$.main(Kafka.scala:65)
    at kafka.Kafka.main(Kafka.scala)





发表于: 2月前   最后更新时间: 2月前   游览量:942
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • 因为使用java客户端 spring-kafka是 2.12的版本,服务器broker是 2.11 的版本,进行操作broker时 , 在 zookeeper中创建 /kafka-acl/DelegationToken  节点,导致服务启不来,解决办法是 java客户制成与 broker版本一致 , 删除 zk 中的 /kafka-acl/DelegationToken , 就可以正常启动,谢谢各位关注!
  • 评论…
    • in this conversation