0

我已启用

"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"

但我没有看到 s3 存储中的标题和键。仅存储值部分。

任何输入都会有很大帮助。

4

0 回答 0