search

a0x8o / kafka

A high-throughput, distributed, publish-subscribe messaging system
Apache License 2.0
66 stars 172 forks source link

Exception while Upgrading three nodes kafka from version 0.10.1.1 to 2.1.0 #4

Open liqiang183 opened 5 years ago

liqiang183 commented 5 years ago

I want to Upgrade three nodes kafka from version 0.10.1.1 to 2.1.0 。 Firstly，I upgrade one node to 2.10 ,and it is success .The three kafka are all avaliable. Then,there two nodes are old version ,when i restart the old kafka ,an exception is merge. the server.log shows 2019-04-02 09:58:10.286 GMT+08:00 FATAL Fatal error during KafkaServerStartable startup. Prepare to shutdown (kafka.server.KafkaServerStartable) kafka.common.KafkaException: TransactionalId not a valid resourceType name. The valid names are Cluster,Topic,Group at kafka.security.auth.ResourceType$$anonfun$fromString$1.apply(ResourceType.scala:49) at kafka.security.auth.ResourceType$$anonfun$fromString$1.apply(ResourceType.scala:49) at scala.Option.getOrElse(Option.scala:121) at kafka.security.auth.ResourceType$.fromString(ResourceType.scala:49) at kafka.security.auth.SimpleAclAuthorizer$$anonfun$loadCache$1$$anonfun$apply$mcV$sp$1.apply(SimpleAclAuthorizer.scala:233) at kafka.security.auth.SimpleAclAuthorizer$$anonfun$loadCache$1$$anonfun$apply$mcV$sp$1.apply(SimpleAclAuthorizer.scala:232) at scala.collection.Iterator$class.foreach(Iterator.scala:893) at scala.collection.AbstractIterator.foreach(Iterator.scala:1336) 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:232) at kafka.security.auth.SimpleAclAuthorizer$$anonfun$loadCache$1.apply(SimpleAclAuthorizer.scala:230) at kafka.security.auth.SimpleAclAuthorizer$$anonfun$loadCache$1.apply(SimpleAclAuthorizer.scala:230) at kafka.utils.CoreUtils$.inLock(CoreUtils.scala:234) at kafka.utils.CoreUtils$.inWriteLock(CoreUtils.scala:242) at kafka.security.auth.SimpleAclAuthorizer.loadCache(SimpleAclAuthorizer.scala:230) at kafka.security.auth.SimpleAclAuthorizer.configure(SimpleAclAuthorizer.scala:115) at kafka.server.KafkaServer$$anonfun$startup$4.apply(KafkaServer.scala:239) at kafka.server.KafkaServer$$anonfun$startup$4.apply(KafkaServer.scala:237) at scala.Option.map(Option.scala:146) at kafka.server.KafkaServer.startup(KafkaServer.scala:237) at kafka.server.KafkaServerStartable.startup(KafkaServerStartable.scala:39) at kafka.Kafka$.main(Kafka.scala:67) at kafka.Kafka.main(Kafka.scala)

when i upgrade the libs in old kafka ,and the it start succcessfuly,And no error. But,when upgrading is failed ,i want to rollback .With this exception ,i can not rollback .because old kafka can not starts,if there is new kafka in colony。

so i ask you for help . Thanks

xutingz commented 4 years ago

not sure if this problem got resolved. But for us, the workaround is to manually clean up zk and remove the "TransactionalId" and 'DelegationToken' for the old broker restart to work.