Невозможно запустить реестр Confluent Schema - PullRequest
Новая
       39

Невозможно запустить реестр Confluent Schema

0 голосов
/ 30 января 2019

Я установил confluent платформу на машине Ubuntu 16.04, и первоначально я настроил zookeeper, Kafka и ksql и запустил confluent платформу.Я могу видеть ниже сообщение.

 root@DESKTOP-DIB3097:/opt/kafkafull/confluent-5.1.0/bin# ./confluent start
 This CLI is intended for development only, not for production
 https://docs.confluent.io/current/cli/index.html
 Using CONFLUENT_CURRENT: /tmp/confluent.HUlCltYT
 Starting zookeeper
 zookeeper is [UP]
 Starting kafka
 kafka is [UP]
 Starting schema-registry
 schema-registry is [UP]
 Starting kafka-rest
 kafka-rest is [UP]
 Starting connect
 connect is [UP]
 Starting ksql-server
 ksql-server is [UP]
 Starting control-center
 control-center is [UP]

теперь все работает, когда я проверил состояние рабочей платформы, я заметил, что реестр Schema, connect & control-center недоступны.

Я проверил журналы реестра схемы и обнаружил следующий журнал. 


ERROR Error starting the schema registry (io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication)
io.confluent.kafka.schemaregistry.exceptions.SchemaRegistryInitializationException: Error initializing kafka store while initializing schema registry
        at io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.init(KafkaSchemaRegistry.java:210)
        at io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication.initSchemaRegistry(SchemaRegistryRestApplication.java:61)
        at io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication.setupResources(SchemaRegistryRestApplication.java:72)
        at io.confluent.kafka.schemaregistry.rest.SchemaRegistryRestApplication.setupResources(SchemaRegistryRestApplication.java:39)
        at io.confluent.rest.Application.createServer(Application.java:201)
        at io.confluent.kafka.schemaregistry.rest.SchemaRegistryMain.main(SchemaRegistryMain.java:41)
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:137)
        at io.confluent.kafka.schemaregistry.storage.KafkaSchemaRegistry.init(KafkaSchemaRegistry.java:208)
        ... 5 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:422)
        at io.confluent.kafka.schemaregistry.storage.KafkaStore.waitUntilKafkaReaderReachesLastOffset(KafkaStore.java:275)
        at io.confluent.kafka.schemaregistry.storage.KafkaStore.init(KafkaStore.java:135)
        ... 6 more
Caused by: java.util.concurrent.TimeoutException: Timeout after waiting for 60000 ms.
        at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:78)
        at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:30)
        at io.confluent.kafka.schemaregistry.storage.KafkaStore.getLatestOffset(KafkaStore.java:417)
        ... 8 more

1 Ответ

0 голосов
/ 31 января 2019

Я думаю, я нашел ответ,

В файлах конфигурации Kafka добавьте свойство host.name = host_ip_address , которое будет выступать в качестве хоста брокера kafka.поэтому во всех файлах конфигурации, где когда-либо присутствует свойство загрузчика kafka, измените его на соответствующее имя хоста или IP-адрес, как показано ниже.

bootstrap.servers = 192.168.0.193: 9092

Пример : В конфигурациях реестра схемы я изменил приведенное ниже свойство с локального хоста на соответствующий IP-адрес

kafkastore.bootstrap.servers = PLAINTEXT: //192.168.0.193: 9092

В других файлах проверьте свойство bootstrap.servers = 192.168.0.193: 9092 , ссылаясь правильно или нет.А также проверьте, правильно ли ссылается файл конфигурации реестра схемы.

(вы можете проверить и сравнить файлы конфигурации в журналах / tmp / confluent kafka)

Теперь после изменения всех файлов конфигурации, услуги запущены и работают.

...