debezium无法使用带有默认插件pgoutput的postgres 11访问文件“decoderbufs”

Question

我是Kafka的新手，我正在尝试使用debezium postgres连接器。但是，即使使用带有标准插件的postgres版本11，我也会得到这样的错误：org.apache.kafka.connect.errors.connectException：org.PostgreSQL.util.psqlException：error：could not access file“decoderbufs”：没有这样的文件或目录

为了运行kafka/debezium，我使用了fast-data-dev docker的图像，如下所示

  # this is our kafka cluster.
  kafka-cluster:
    image: landoop/fast-data-dev:latest
    environment:
      ADV_HOST: 127.0.0.1         # Change to 192.168.99.100 if using Docker Toolbox
      RUNTESTS: 0                 # Disable Running tests so the cluster starts faster
    ports:
      - 2181:2181                 # Zookeeper
      - 3030:3030                 # Landoop UI
      - 8081-8083:8081-8083       # REST Proxy, Schema Registry, Kafka Connect ports
      - 9581-9585:9581-9585       # JMX Ports
      - 9092:9092                 # Kafka Broker

运行后，我可以打开我的localhost:3030来选择debezium连接器，我这样配置它：

Answer 1

您还没有将Debezium连接器属性中的“plugin.name”属性设置为“pgoutput”，您已经知道了这一点。但是这个答案是给那些不知道在哪里设置这个选项的人的，也是为了更清楚。

在下列连接器属性中：

由于您没有设置plugin.name选项，它采用了默认值，即decoderbufs，这就是您得到以下错误的原因：

{ 
  "connector.class": "io.debezium.connector.postgresql.PostgresConnector", 
  "database.user": "postgres",
  "database.dbname": "xxxxx",
  "tasks.max": "1", 
  "database.hostname": "xxxx.rds.amazonaws.com", 
  "database.password": "xxxx", 
  "database.server.name": "database-1",
  "database.port": "5432",
  "plugin.name": "pgoutput" --> this property
}