3

我们正在为 Kafka 使用 Confluent 社区版设置，目前我们需要在集群周围配置 ACL，因此我们已经配置了 zk 和代理节点，因此客户端需要身份验证（用户名/密码） SASL_PLAINTEXT 令牌才能发布/订阅集群，它的在没有模式注册表的情况下完美工作，但是在配置模式注册表时，即使我们已将其配置为使用 SASL+PLAINTEXT 与 brokers/zk 节点的连接，它也无法初始化抛出异常。有什么我想念的请帮忙。

请注意，我们正在使用allow.everyone.if.no.acl.found=true标志，目前我们没有定义 ACL，所以我认为我们不需要为模式注册表用来初始化的 _schema 主题设置任何 ACL。

[2019-12-17 00:33:23,844] ERROR Error starting the schema registry (io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication:64)
io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException: Error initializing kafka store while initializing schema registry
        at io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.init(KafkaSchemaRegistry.java:212)
        at io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication.initSchemaRegistry(SchemaRegistryRestApplication.java:62)
        at io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication.setupResources(SchemaRegistryRestApplication.java:73)
        at io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication.setupResources(SchemaRegistryRestApplication.java:40)
        at io.confluent.rest.Application.createServer(Application.java:201)
        at io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain.main(SchemaRegistryMain.java:42)
Caused by: io.confluent.kafka.schemaregistry.storage.exceptions.StoreInitializationException: Timed out trying to create or validate schema topic configuration
        at io.confluent.kafka.schemaregistry.storage.KafkaStore.createOrVerifySchemaTopic(KafkaStore.java:172)
        at io.confluent.kafka.schemaregistry.storage.KafkaStore.init(KafkaStore.java:114)
        at io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.init(KafkaSchemaRegistry.java:210)
        ... 5 more
Caused by: java.util.concurrent.TimeoutException
        at org.apache.kafka.common.internals.KafkaFutureImpl$SingleWaiter.await(KafkaFutureImpl.java:108)
        at org.apache.kafka.common.internals.KafkaFutureImpl.get(KafkaFutureImpl.java:274)
        at io.confluent.kafka.schemaregistry.storage.KafkaStore.createOrVerifySchemaTopic(KafkaStore.java:165)
        ... 7 more
4

0 回答 0