Kafka Connect, get Json Schema for JsonConverter Kafka Connect, get Json Schema for JsonConverter elasticsearch elasticsearch

Kafka Connect, get Json Schema for JsonConverter


The problem is that Elasticsearch Connector tries to infer mapping for elasticsearch based on message schema. Message schema is created by the Converter and modified by Transforms. If you set value.converter.schemas.enable on false your records schemas are nulls.

You have to set schema.ignore to true and Elasticsearch Connector won't infer schema.