合流模式注册表意外死亡

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

在我的汇合kafka(v3.3.0)群集重新启动(受控关闭)后,架构注册表没有立即启动,该群集正在启用vm-ssl的情况下运行。但如果我尝试在某个时间后重新启动(至少在kafka集群重新启动2小时后),schema registry就可以正常启动了。日志错误:无法订阅支持此数据存储的kafka主题\u架构。主题可能不存在。
我怀疑集群没有完全同步,但我描述了这个主题,它给了我预期的结果。请在下面找到 ./bin/kafka-topics --describe --zookeeper localhost:2181 --topic _schemas Topic:_schemas PartitionCount:1 ReplicationFactor:3 Configs:cleanup.policy=compact Topic: _schemas Partition: 0 Leader: 2 Replicas: 2,3,1 Isr: 3,2,1 此外,我还检查了集群状态—集群中的所有3个节点都是同步的。请在下面找到

./bin/zookeeper-shell localhost:2181 <<< "ls /brokers/ids"
Connecting to localhost:2181
Welcome to ZooKeeper!
JLine support is disabled

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
[1, 2, 3]

[2019-07-08 09:07:14132]/brokers/topics/\u架构的调试分区Map是Map(0->list(2,3,1))(kafka.utils.zkutils)[2019-07-08 09:07:25,292]错误服务器意外死亡:(io.confluent.kafka.schemaregistry.rest.schemaregistrymain)java.lang.illegalargumentexception:无法订阅支持此数据存储的kafka主题\u架构。主题可能不存在。在io.confluent.kafka.schemaregistry.storage.KafkastroreReaderThread.(KafkastroreReaderThread。java:130)at io.confluent.kafka.schemaregistry.storage.kafkastore.init(kafkastore。java:172)在io.confluent.kafka.schemaregistry.storage.kafkaschemaregistry.init(kafkaschemaregistry。java:212)在io.confluent.kafka.schemaregistry.rest.schemaregistryrestapplication.setupresources(schemaregistryrestapplication)。java:56)位于io.confluent.kafka.schemaregistry.rest.schemaregistryrestapplication.setupresources(schemaregistryrestapplication)。java:38)在io.confluent.rest.application.createserver(application。java:157)
我的schema-registry.properties:

listeners=https://XXXXXXXXXXXX:8081
kafkastore.connection.url=XXXX:2181,YYYY:2181,ZZZZ:2181
kafkastore.topic=_schemas
debug=true
kafkastore.timeout.ms=180000

kafkastore.ssl.key.password=changeit
kafkastore.ssl.keystore.location=/apps/KEYSTORE.jks
kafkastore.ssl.keystore.password=XXXX
kafkastore.ssl.truststore.location=/apps/TrustStore.jks
kafkastore.ssl.truststore.password=XXX
kafkastore.security.protocol=SSL
kafkastore.ssl.endpoint.identification.algorithm=HTTPS

ssl.keystore.location=/apps/KEYSTORE.jks
ssl.keystore.password=XXXXX
ssl.key.password=XXXXX
ssl.truststore.location=/apps/rustStore.jks
ssl.truststore.password=XXXXX
ssl.endpoint.identification.algorithm=HTTPS
zookeeper.set.acl=false

我的服务器.properties

ssl.client.auth=required
ssl.keystore.location=/apps/KEYSTORE.jks
ssl.keystore.password=XXXXX
ssl.key.password=XXXXX
ssl.truststore.location=/apps/TrustStore.jks
ssl.truststore.password=XXXXX
security.inter.broker.protocol=SSL
ssl.keystore.type=JKS
ssl.truststore.type=JKS
ssl.enabled.protocols=TLSv1.2,TLSv1.1,TLSv1
ssl.endpoint.identification.algorithm=HTTPS
zookeeper.set.acl=false

暂无答案!

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

相关问题