Uploaded image for project: 'Red Hat Fuse'
  1. Red Hat Fuse
  2. ENTESB-15812

Usage of ExtJsonConverter with JsonSchemaKafkaSerde

XMLWordPrintable

    • Icon: Clarification Clarification
    • Resolution: Won't Do
    • Icon: Major Major
    • None
    • None
    • None
    • False
    • False
    • % %
    • Undefined
    • Camel Kafka Connector

      When using ExtJsonConverter with Apicurio service I get NullPointerExceptions. There is probably a mistake in the configuration, but I can't figure out how to configure serializer and converter to cooperate. 

       

      I am using following properties for the connector: 
      connector.class=org.apache.camel.kafkaconnector.elasticsearchrest.CamelElasticsearchrestSinkConnector
      camel.sink.endpoint.operation=Index
      value.converter.apicurio.registry.url=localhost:49161/api
      value.converter.apicurio.registry.global-id=io.apicurio.registry.utils.serde.strategy.GetOrCreateIdStrategy
      tasks.max=1
      topics=JsonSchemaTestTopic
      value.converter.apicurio.registry.use.headers=true
      camel.sink.endpoint.hostAddresses=localhost:49155
      camel.sink.path.clusterName=docker-cluster
      camel.sink.endpoint.indexName=ckc-index
      name=CamelElasticSearchSinkConnector
      value.converter=io.apicurio.registry.utils.converter.ExtJsonConverter
      key.converter=org.apache.kafka.connect.storage.StringConverter
      And the producer producing messages is configured use the same apicurio registry and stores the artifact id in headers. 
      Is there any additional config needed to tell the converter to use headers for the artifact id? 
      In the opposite case if I want to have the schema in the message body what do I need to configure? 

            janstey@redhat.com Jonathan Anstey
            mmuzikar Martin Muzikar
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: