KafkaS3SinkConnector无法识别value.subject.name.strategy

这个问题通常是由于Kafka S3 Sink Connector配置文件中漏掉了“value.converter.”前缀而引起的。要解决这个问题，需要在配置文件中添加正确的前缀。以下是一个例子：

name=s3-sink
connector.class=io.confluent.connect.s3.S3SinkConnector
tasks.max=1

topics=my-topic
s3.bucket.name=my-bucket
s3.region=us-west-2
s3.part.size=5242880
flush.size=3

key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=io.confluent.connect.avro.AvroConverter
value.converter.schema.registry.url=http://localhost:8081
value.converter.schema.registry.topic.prefix=value.
value.converter.schema.registry.subject.strategy=io.confluent.kafka.serializers.subject.TopicNameStrategy

# 添加前缀- value.converter.
value.converter.value.subject.name.strategy=io.confluent.kafka.serializers.subject.TopicNameStrategy

在代码示例中，添加了前缀“value.converter.”来配置value.subject.name.strategy。这个前缀必须要添加，因为Kafka S3 Sink Connector需要知道该配置适用于哪个转换器。需要注意的是，前缀必须要和 key.converter 和 value.converter 的前缀一致。