问题启动模式注册表

tvmytwxo  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(481)

我正在尝试运行schema注册表,我看到下面的异常。

ERROR Server died unexpectedly: 
    (io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain:51)
    org.apache.kafka.common.config.ConfigException: Only plaintext and SSL Kafka endpoints are supported and none are configured.
    at io.confluent.kafka.schemaregistry.storage.KafkaStore.filterBrokerEndpoints(KafkaStore.java:271)
    at io.confluent.kafka.schemaregistry.storage.KafkaStore.<init>(KafkaStore.java:122)
    at io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.<init>(KafkaSchemaRegistry.java:141)
    at io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication.setupResources(SchemaRegistryRestApplication.java:53)
    at io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication.setupResources(SchemaRegistryRestApplication.java:37)
    at io.confluent.rest.Application.createServer(Application.java:118)
    at io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain.main(SchemaRegistryMain.java:43)

我使用的是Confluent3.0.1版本,我的kafka版本是0.10.0-2.11,下面是我的属性。

listeners=http://0.0.0.0:8081  
kafkastore.connection.url=sl73caehdp0131.visa.com:2181,sl73caehdp0125.visa.com:2181
kafkastore.topic=_schemas
debug=true
avro.compatibility.level=full
kafkastore.security.protocol=SASL_PLAINTEXT
sasl.kerberos.service.name=kafka

为了解决上述问题,我将以下属性添加到属性文件中。

kafkastore.bootstrap.servers=PLAINTEXT://sl73caehdp0135.visa.com:9092

添加这个属性之后,我得到了一个异常

ERROR Error starting the schema registry 

  (io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication:57) 

  io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException: Error initializing kafka store while initializing schema registry at io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.init(KafkaSchemaRegistry.java:189)
    at io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication.setupResources(SchemaRegistryRestApplication.java:55)
    at io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication.setupResources(SchemaRegistryRestApplication.java:37)
    at io.confluent.rest.Application.createServer(Application.java:118)
    at io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain.main(SchemaRegistryMain.java:43)
    Caused by: io.confluent.kafka.schemaregistry.storage.exceptions.StoreInitializationException: No live Kafka brokers
    at io.confluent.kafka.schemaregistry.storage.KafkaStore.createSchemaTopic(KafkaStore.java:225)
    at io.confluent.kafka.schemaregistry.storage.KafkaStore.init(KafkaStore.java:136)
    at io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.init(KafkaSchemaRegistry.java:187)
    ... 4 more

我可能犯了什么错误,请任何人帮忙。

6qqygrtg

6qqygrtg1#

请参阅3.0.1配置选项 kafkastore.security.protocol 与kafka(底层持久存储)连接时要使用的安全协议。值可以是纯文本或ssl。
另外,根据安全概述页面
目前,zookeeper安全和kafka sasl身份验证还不受支持。
直到升级到至少 0.10.2 Kafka,你将无法使用其他组件的更新版本。
理想情况下,它们都应该匹配,但是schema registry实际上只使用常规的使用者进程,因此对于那些较新的版本来说,拥有一个较新的客户机应该不是问题,假设服务器将支持它
confluent platform 3.2及更高版本中包含的架构注册表与confluent platform 3.0及更高版本中包含的任何apache kafka代理兼容

相关问题