CODEWITHSUNDEEP
apache-kafkaconfluent-platformconfluent-schema-registry
user3679686
user3679686

Reputation: 516

Issue Starting Schema Registry

I am trying to get the schema registry running and I am seeing the below exception.

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)

I am using Confluent 3.0.1 version and my kafka version is 0.10.0-2.11 Below are my properties.

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

To Resolve the above issue, i added the below property to the properties file. 

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

After adding this property, I get the exception

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

What could be the mistake i am making, can any one please help.

Upvotes: 1

Views: 2846

Answers (1)

OneCricketeer
OneCricketeer

Reputation: 191973

Refer to the 3.0.1 Configuration Options

kafkastore.security.protocol

The security protocol to use when connecting with Kafka, the underlying persistent storage. Values can be PLAINTEXT or SSL.

Plus, as per the Security Overview page

At this time, ZooKeeper security and Kafka SASL authentication are not yet supported.

Until you upgrade to a version of at least 0.10.2 Kafka, you won't be able to use a newer version of the other components.

Ideally, they should all match, but the Schema Registry really just uses a regular consumer process, so having a newer client shouldn't be a problem for those newer versions, assuming that the server will support it

Schema Registry that is included in Confluent Platform 3.2 and later is compatible with any Apache Kafka broker that is included in Confluent Platform 3.0 and later

Upvotes: 1

Related Questions