Atmaram Hebbar
Atmaram Hebbar

Reputation: 1

kafka s3 sink connector keys and headers s3 storage write not working

I have enabled

"store.kafka.keys" : "true",
"store.kafka.headers" : "true",
"keys.format.class" : "io.confluent.connect.s3.format.json.JsonFormat",
"headers.format.class" : "io.confluent.connect.s3.format.json.JsonFormat"

But I don't see the headers, keys in the s3 storage. Only values part is stored.

Any input will greatly help.

Upvotes: 0

Views: 540

Answers (1)

OneCricketeer
OneCricketeer

Reputation: 191738

Make sure you've installed the latest version of the S3 sink connector.

It used to only write the values prior to (approximately) version 10.x

Upvotes: 0

Related Questions