Kafka broker TSV source

Kafka Connect
1

I have kafka connect reading from kafka cluster but data in TSV format.

what are the variables I should set to consume TSV msgs?

Like we use below for json format.

CONNECT_KEY_CONVERTER=org.apache.kafka.connect.json.JsonConverter
CONNECT_VALUE_CONVERTER=org.apache.kafka.connect.json.JsonConverter
CONNECT_INTERNAL_KEY_CONVERTER="org.apache.kafka.connect.json.JsonConverter"
CONNECT_INTERNAL_VALUE_CONVERTER="org.apache.kafka.connect.json.JsonConverter"

but what values to be set for TSV kafka msgs?

2

You can simply use StringConverter.

You’d need a message-transform in order to apply any schema for the data.

3

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.