org.apache.kafka.connect.errors.DataException when configuring Splunk Kafka Connector

Apache Kafka Connectors
1

Getting the error when configuring the Splunk Kafka Connect sink connector:

Caused by: org.apache.kafka.connect.errors.DataException: JsonConverter with schemas.enable requires "schema" and "payload" fields and may not contain additional fields. If you are trying to deserialize plain JSON data, set schemas.enable=false in your converter configuration.

1 Like
2

Ensure you have set:

key.converter.schemas.enable=false
value.converter.schemas.enable=false

…in your Kafka Connect configuration.

eg:

connector.class=com.splunk.kafka.connect.SplunkSinkConnector
splunk.hec.ssl.validate.certs=false
tasks.max=3
topics=auditd
splunk.sourcetypes=auditd
name=mysplunk
splunk.indexes=main
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter=org.apache.kafka.connect.storage.StringConverter
splunk.hec.token=xxxxxxxxxx
splunk.hec.uri=https://xxxxx:8088
key.converter.schemas.enable=false
value.converter.schemas.enable=false