Reputation: 1
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
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