用于发布/订阅到 Apache Kafka 连接器的 GCP 凭证

Question

我想使用此连接器将消息从 AWS MSK 传输到 GCP Pub/Sub。

已上传 connector(pubsub-group-kafka-connector-1.2.0.jar ) 到 s3 存储桶，创建 custum 插件，并希望使用此配置创建 MKS 连接器。

connector.class=com.google.pubsublite.kafka.sink.PubSubLiteSinkConnector 
gcp.credentials.json="service account json converted to string" 
pubsublite.project=*********
tasks.max=10
topics=my-kafka-topic 
value.converter=org.apache.kafka.connect.converters.ByteArrayConverter 
pubsublite.topic=moove-test 
key.converter=org.apache.kafka.connect.converters.ByteArrayConverter 
pubsublite.location=us-west1

我收到此错误

我认为gcp.credentials.json参数有问题，但将值转换为json时成功。有什么建议吗？

Answer 1

该错误表示无法解析

gcp.credentials.json

。只需删除引号

"

。

总结该方法：如果您已格式化 JSON 文件，请将值展平为一行并按原样发布。这是一些例子：

gcp.credentials.json={"type":"service_account","project_id":"","private_key_id":"","private_key":"-----BEGIN PRIVATE KEY----------END PRIVATE KEY-----\n","client_email":"","client_id":"","auth_uri":"https://accounts.google.com/o/oauth2/auth","token_uri":"https://oauth2.googleapis.com/token","auth_provider_x509_cert_url":"https://www.googleapis.com/oauth2/v1/certs","client_x509_cert_url":""}

我认为您不需要转义 JSON 值内的任何引号，除非您的属性文件也是 JSON。