apache-kafka 配置格式的值io.confluent.connect.s3.format.protobuf.ProtobufFormat无效,类

z9gpfhce  于 2022-11-01  发布在  Apache
关注(0)|答案(1)|浏览(102)
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“}***处找到上面的错误列表

cetgtptt

cetgtptt1#

错误正确。没有config.format=ProtobufFormat配置
https://docs.confluent.io/kafka-connectors/s3-sink/current/configuration_options.html#connector
format.class设置为支持的值。

相关问题