Kafka Schema註冊表錯誤：未能寫入Noop記錄到kafka商店

Question

我試圖啓動kafka模式註冊表，但出現以下錯誤：無法將noop記錄寫入kafka商店。堆棧跟蹤如下。我檢查了與動物園管理員，卡夫卡經紀人的聯繫 - 一切都很好。我可以發信息給卡夫卡。我試圖刪除_schema主題，甚至重新安裝kafka，但這個問題仍然存在。昨天一切正常，但今天，重新啓動我的流浪者箱後，這個問題出現了。有什麼我可以做的嗎？謝謝

[2015-11-19 19:12:25,904] INFO SchemaRegistryConfig values: 
master.eligibility = true 
port = 8081 
kafkastore.timeout.ms = 500 
kafkastore.init.timeout.ms = 60000 
debug = false 
kafkastore.zk.session.timeout.ms = 30000 
request.logger.name = io.confluent.rest-utils.requests 
metrics.sample.window.ms = 30000 
schema.registry.zk.namespace = schema_registry 
kafkastore.topic = _schemas 
avro.compatibility.level = none 
shutdown.graceful.ms = 1000 
response.mediatype.preferred = [application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json, application/json] 
metrics.jmx.prefix = kafka.schema.registry 
host.name = 12bac2a9529f 
metric.reporters = [] 
kafkastore.commit.interval.ms = -1 
kafkastore.connection.url = master.mesos:2181 
metrics.num.samples = 2 
response.mediatype.default = application/vnd.schemaregistry.v1+json 
kafkastore.topic.replication.factor = 3 
(io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig:135) 

[2015-11-19 19:12:25,904] INFO SchemaRegistryConfig values: 
master.eligibility = true 
port = 8081 
kafkastore.timeout.ms = 500 
kafkastore.init.timeout.ms = 60000 
debug = false 
kafkastore.zk.session.timeout.ms = 30000 
request.logger.name = io.confluent.rest-utils.requests 
metrics.sample.window.ms = 30000 
schema.registry.zk.namespace = schema_registry 
kafkastore.topic = _schemas 
avro.compatibility.level = none 
shutdown.graceful.ms = 1000 
response.mediatype.preferred = [application/vnd.schemaregistry.v1+json, application/vnd.schemaregistry+json, application/json] 
metrics.jmx.prefix = kafka.schema.registry 
host.name = 12bac2a9529f 
metric.reporters = [] 
kafkastore.commit.interval.ms = -1 
kafkastore.connection.url = master.mesos:2181 
metrics.num.samples = 2 
response.mediatype.default = application/vnd.schemaregistry.v1+json 
kafkastore.topic.replication.factor = 3 
(io.confluent.kafka.schemaregistry.rest.SchemaRegistryConfig:135) 
[2015-11-19 19:12:26,535] INFO Initialized the consumer offset to -1  (io.confluent.kafka.schemaregistry.storage.KafkaStoreReaderThread:87) 
[2015-11-19 19:12:27,167] WARN Creating the schema topic _schemas using a replication factor of 1, which is less than the desired one of 3. If this is a production environment, it's crucial to add more brokers and increase the replication factor of the topic. (io.confluent.kafka.schemaregistry.storage.KafkaStore:172) 
[2015-11-19 19:12:27,262] INFO [kafka-store-reader-thread-_schemas], Starting (io.confluent.kafka.schemaregistry.storage.KafkaStoreReaderThread:68) 
[2015-11-19 19:13:27,350] 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:164) 
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:104) 
at io.confluent.kafka.schemaregistry.rest.Main.main(Main.java:42) 
Caused by: io.confluent.kafka.schemaregistry.storage.exceptions.StoreInitializationException: io.confluent.kafka.schemaregistry.storage.exceptions.StoreException: Failed to write Noop record to kafka store. 
at io.confluent.kafka.schemaregistry.storage.KafkaStore.init(KafkaStore.java:151) 
at io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.init(KafkaSchemaRegistry.java:162) 
... 4 more 
Caused by: io.confluent.kafka.schemaregistry.storage.exceptions.StoreException: Failed to write Noop record to kafka store. 
at io.confluent.kafka.schemaregistry.storage.KafkaStore.getLatestOffset(KafkaStore.java:363) 
at io.confluent.kafka.schemaregistry.storage.KafkaStore.waitUntilKafkaReaderReachesLastOffset(KafkaStore.java:220) 
at io.confluent.kafka.schemaregistry.storage.KafkaStore.init(KafkaStore.java:149) 
... 5 more 

Answer 1

我得到了同樣的錯誤。問題是，我預計，卡夫卡使用kafka命名空間中的ZooKeeper，所以我將它設置在schema-registry.properties

kafkastore.connection.url=localhost:2181/kafka 

但卡夫卡server.properties我沒有設置它。配置包含

zookeeper.connect=localhost:2181 

，所以我只需要添加ZooKeeper的命名空間這個屬性，然後重新啓動卡夫卡

zookeeper.connect=localhost:2181/kafka 

也許你的問題是你定義您的模式，註冊表想到「/」命名空間，但在你的卡夫卡配置別的東西。你可以發佈卡夫卡配置嗎？

或者，您可以使用zkCli.sh找出ZooKeeper Kafka存儲主題信息的位置。

/bin/zkCli.sh localhost:2181 
Welcome to ZooKeeper! 
ls /kafka 
[cluster, controller, controller_epoch, brokers, admin, isr_change_notification, consumers, latest_producer_id_block, config]