Flink CDC 里flink是docker部署的，目前想把postgre同步到es，报错咋办？

Flink CDC 里我的flink是docker部署的，我目前想把postgre同步到es，但是报kafka的异常？用的是默认的配置，没有单独指定配置。jobmanager:
restart: always
image: flink:1.16.0-scala_2.12-java11
container_name: jobmanager
ports:

  - "8087:8081"
command: jobmanager
environment:
  - |
    FLINK_PROPERTIES=
    jobmanager.rpc.address: jobmanager
    jobmanager.memory.process.size: 1024m
volumes:
  - ./build/settings/:/settings
  - ./build/data/:/data
networks:
  - smart-net

taskmanager:
restart: always
image: flink:1.16.0-scala_2.12-java11
container_name: taskmanager
depends_on:

  - jobmanager
command: taskmanager
scale: 1
environment:
  - |
    FLINK_PROPERTIES=
    jobmanager.rpc.address: jobmanager
    taskmanager.numberOfTaskSlots: 6
    taskmanager.memory.process.size: 1024m
    taskmanager.memory.jvm-overhead.min: 200m

volumes:
  - ./build/settings/:/settings
  - ./build/data/:/data
networks:
  - smart-net这是flink docker compose 的相关配置![ee31bda69971be29e6d4699c49470695.png](https://ucc.alicdn.com/pic/developer-ecology/cckkirpdqa7sk_84a0708a3a9447b384e2c13b7d263cf1.png)sql client。