curl -i -X PUT -H "Accept:application/json" \
-H "Content-Type:application/json" http://localhost:8083/connectors/sink-s3-voluble/config \
-d '
{
"connector.class": "io.confluent.connect.s3.S3SinkConnector",
"key.converter":"io.confluent.connect.protobuf.ProtobufConverter",
"tasks.max": "1",
"topics": "cats",
"s3.region": "ap-south-1",
"s3.bucket.name": "testbucketkafka",
"flush.size": "65536",
"storage.class": "io.confluent.connect.s3.storage.S3Storage",
"schema.generator.class": "io.confluent.connect.storage.hive.schema.DefaultSchemaGenerator",
"schema.compatibility": "NONE",
"partitioner.class": "io.confluent.connect.storage.partitioner.DefaultPartitioner",
"transforms": "AddMetadata",
"transforms.AddMetadata.type": "org.apache.kafka.connect.transforms.InsertField$Value",
"transforms.AddMetadata.offset.field": "_offset",
"transforms.AddMetadata.partition.field": "_partition"
}
***给定的错误是连接器配置无效,并包含以下1个错误:\n配置格式的值io.confluent.connect.s3.format.protobuf.ProtobufFormat无效。类:找不到类io.confluent.connect.s3.format.protobuf.ProtobufFormat。\n您还可以在终结点/connector-plugins/{connectorType}/config/validate
“}***处找到上面的错误列表
1条答案
按热度按时间cetgtptt1#
错误正确。没有
config.format=ProtobufFormat
配置https://docs.confluent.io/kafka-connectors/s3-sink/current/configuration_options.html#connector
将
format.class
设置为支持的值。