我正在尝试运行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
我可能犯了什么错误,请任何人帮忙。
1条答案
按热度按时间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代理兼容