错误500在向多个代理注册kafka连接PG连接器时无法创建PG连接

Question

当单一的分布式模式不能满足我时，我尝试使用多个经纪人kafka。但是我在注册kafka source Postgresql连接器时遇到了另一个问题。注册时，它总是给我发送错误500。这是我的kafka connect分布式配置:

bootstrap.servers=
group.id=connect-cluster
key.converter=org.apache.kafka.connect.json.JsonConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.converter.schemas.enable=true
value.converter.schemas.enable=true
offset.storage.topic=connect-offsets
offset.storage.replication.factor=3
#offset.storage.partitions=25
config.storage.topic=connect-configs
config.storage.replication.factor=3
status.storage.topic=connect-status
status.storage.replication.factor=3
#status.storage.partitions=5
offset.flush.interval.ms=10000
...
plugin.path=/home/admin/kafka/connectors

这就是我如何定义其中一个连接器：

    {
"name":"...",
    "config":{
        "connector.class":"io.debezium.connector.postgresql.PostgresConnector",
    "plugin.name":"wal2json",
...
        "database.history.kafka.bootstrap.servers":...
        "database.history.kafka.topic":"history_analytics_menu",
        "table.whitelist":"...",
        "transforms":"unwrap",
    "transforms.unwrap.type":"io.debezium.transforms.UnwrapFromEnvelope",
        "decimal.handling.mode":"double",
        "time.precision.mode":"connect",
    "transforms":"dropPrefix",
    "transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
    "transforms.dropPrefix.regex":"...",
    "transforms.dropPrefix.replacement":"..."
        }
    }

我错过了什么吗？

更新：

这是我从kafka-connect得到的：

[2020-03-21 12:25:29,390] ERROR Uncaught exception in REST call to /connectors (org.apache.kafka.connect.runtime.rest.errors.ConnectExceptionMapper:61)
org.apache.kafka.connect.errors.ConnectException: Could not create PG connection
Caused by: org.postgresql.util.PSQLException: Connection to XXX refused. Check that the hostname and port are correct and that the postmaster is accepting TCP/IP connections.
    ... 13 more
Caused by: java.net.ConnectException: Connection refused (Connection refused)
    ... 21 more

并从连接器卷曲：

{"error_code":500,"message":"Could not create PG connection"}

Answer 1

您为Postgres指定了一个无法从Kafka Connect运行的位置访问的主机/端口

org.postgresql.util.PSQLException: Connection to localhost:15432 refused. 
Check that the hostname and port are correct and that the postmaster is accepting TCP/IP connections.