向 KSQL 服务器发出 GET 时出错。连接到 ksql 服务器时的路径:/info

问题描述 投票:0回答:1

我尝试在本地使用ksql

这是我的 docker-compose 文件

kafka:
  image: confluentinc/cp-kafka:latest
  container_name: mvtds-transformer-kafka
  depends_on:
    - zookeeper
  ports:
    - "9092:9092"
  environment:
    KAFKA_BROKER_ID: 1
    KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092
    KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
    KAFKA_INTER_BROKER_LISTENER_NAME: PLAINTEXT
    KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
    KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
  volumes:
    - kafka-data:/var/run/docker.sock
ksqldb-server:
  image: confluentinc/ksqldb-server:0.28.2
  hostname: ksqldb-server
  container_name: ksqldb-server
  depends_on:
    - kafka
  ports:
    - "8088:8088"
  environment:
    KSQL_LISTENERS: http://0.0.0.0:8088
    KSQL_BOOTSTRAP_SERVERS: kafka:9092
    KSQL_KSQL_LOGGING_PROCESSING_STREAM_AUTO_CREATE: "true"
    KSQL_KSQL_LOGGING_PROCESSING_TOPIC_AUTO_CREATE: "true"
ksqldb-cli:
  image: confluentinc/ksqldb-cli:0.28.2
  container_name: ksqldb-cli
  depends_on:
    - kafka
    - ksqldb-server
  entrypoint: /bin/sh
  tty: true

我已检查 ksqldb 服务器和 ksqldb-cli pod 是否正在运行 然后我运行这个命令

docker exec -it ksqldb-cli ksql http://ksqldb-server:8088

我收到以下错误

Remote server at http://ksqldb-server:8088 does not appear to be a valid KSQL
server. Please ensure that the URL provided is for an active KSQL server.

The server responded with the following error: 
Error issuing GET to KSQL server. path:/info
Caused by: io.netty.channel.AbstractChannel$AnnotatedConnectException:
        Connection refused: ksqldb-server/192.168.16.9:8088
Caused by: Could not connect to the server. Please check the server details are
        correct and that the server is running.

我想知道我应该做什么来解决这个问题

apache-kafka docker-compose ksqldb
1个回答
0
投票

我遇到了同样的问题,但当我在 KRaft 而不是 Zookeeper 上运行代理时解决了它。

© www.soinside.com 2019 - 2024. All rights reserved.