KafkaConnectBigQuerySinkConnector请求SchemaRegistry时使用了错误的主题名称。

这个问题通常是由于Kafka Connect配置文件中的配置错误所致。具体地说，可能是value.subject.name.strategy参数被设置为了错误的值。解决此问题的方法是将value.subject.name.strategy设置为io.confluent.kafka.serializers.subject.TopicNameStrategy。以下是一个示例配置：

{
    "name": "bigquery-sink",
    "config": {
        "connector.class": "com.wepay.kafka.connect.bigquery.BigQuerySinkConnector",
        "tasks.max": 1,
        "topics": "example-topic",
        "auto.create.schemas.enable": false,
        "auto.update.schemas.enable": false,
        "schema.registry.url": "http://example.com:8081",
        "transforms": "addNamespace",
        "transforms.addNamespace.type": "org.apache.kafka.connect.transforms.RegexRouter",
        "transforms.addNamespace.regex": "(.*)",
        "transforms.addNamespace.replacement": "example-$1",
        "value.converter": "io.confluent.connect.avro.AvroConverter",
        "value.converter.schema.registry.url": "http://example.com:8081",
        "value.subject.name.strategy": "io.confluent.kafka.serializers.subject.TopicNameStrategy",
        "bigquery.project": "example-project",
        "bigquery.dataset": "example_dataset",
        "key.converter": "org.apache.kafka.connect.storage.StringConverter",
        "key.converter.schemas.enable": false,
        "schema.registry.basic.auth.user.info": "example-user:example-password"
    }
}