0

环境操作系统：macOS

python库confluent_kafka==1.7.0

外部 kafka 代理版本 2.6.1

不指定任何安全协议，一切都是默认的 PLAINTEXT

运行这个

from confluent_kafka import Consumer
    c = Consumer(
    {
        'group.id': 'test',
        "bootstrap.servers": "my-external-host:9092",
    }
c.list_topics()
)

它不起作用，返回错误“请求 ApiVersion 时断开连接”

厌倦了使用单独的工具，如Kafka 工具和另一个 python 包，如kafka-python - 它正在工作，但 confluent_kafka 没有。

调试信息

%7|1637327168.507|经纪人|rdkafka#consumer-1| [thrd:app]：GroupCoordinator：添加了 NodeId -1 %7|1637327168.507|BROKER|rdkafka#consumer-1| 的新代理 [thrd:app]: my-external-host:9092/bootstrap: 添加了 NodeId -1 %7|1637327168.507|BRKMAIN|rdkafka#consumer-1| 的新代理 [thrd:GroupCoordinator]: GroupCoordinator: 进入主代理线程 %7|1637327168.507|BRKMAIN|rdkafka#consumer-1| [thrd::0/internal]: :0/internal: 进入主代理线程 %7|1637327168.507|INIT|rdkafka#consumer-1| [thrd:app]: librdkafka v1.7.0 (0x10700ff) rdkafka#consumer-1 已初始化 (builtin.features gzip,snappy,ssl,sasl,regex,lz4,sasl_gssapi,sasl_plain,sasl_scram,plugins,zstd,sasl_oauthbearer,STRIP STATIC_LINKING CC GXX PKGCONFIG OSXLD LIBDL 插件 ZLIB SSL SASL_CYRUS ZSTD HDRHISTOGRAM SNAPPY SOCKEM SASL_SCRAM SASL_OUTHBEARER CRC32C_HW，调试 0x2) %7|1637327168。507|连接|rdkafka#consumer-1| [thrd:main]: my-external-host:9092/bootstrap: 选择用于集群连接：协调器查询（代理有 0 次连接尝试）%7|1637327168.507|BRKMAIN|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: 进入主代理线程 %7|1637327168.507|CONNECT|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: 收到 CONNECT op %7|1637327168.507|STATE|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: 代理更改状态 INIT -> TRY_CONNECT %7|1637327168.507|CONNECT|rdkafka#consumer-1| [thrd:app]：没有为集群连接选择任何代理：仍然抑制 49 毫秒：应用程序元数据请求 %7|1637327168.507|CONNECT|rdkafka#consumer-1| [thrd：应用程序]：未为集群连接选择任何代理：仍被抑制 49 毫秒：应用程序元数据请求 %7|1637327168.507|CONNECT|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: 代理处于状态 TRY_CONNECT 连接 %7|1637327168.507|STATE|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: 代理更改状态 TRY_CONNECT -> CONNECT %7|1637327168.507|CONNECT|rdkafka#consumer-1| [thrd:app]：没有为集群连接选择任何代理：仍然抑制 49 毫秒：应用程序元数据请求 %7|1637327168.509|CONNECT|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: 使用套接字 11 %7|1637327168.578|CONNECT|rdkafka#consumer- 连接到 ipv4#10.103.68.24:9092（纯文本） 1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: 连接到 ipv4#10.103.68.24:9092 %7|1637327168.578|CONNECTED|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: 已连接 (#1) %7|1637327168.578|FEATURE|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]：my-external-host:9092/bootstrap：将启用的协议功能 +ApiVersion 更新为 ApiVersion %7|1637327168.578|STATE|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: 代理更改状态 CONNECT -> APIVERSION_QUERY %7|1637327168.578|CONNECT|rdkafka#consumer-1| [thrd:app]：集群连接已在进行中：应用程序元数据请求 %7|1637327168.580|FAIL|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]：my-external-host:9092/bootstrap：请求 ApiVersion 时断开连接：可能是由于错误的 security.protocol 配置（连接到 SSL 侦听器？）或代理版本 < 0.10（请参阅 api.version.request）（在状态 APIVERSION_QUERY 2 毫秒后）（_TRANSPORT）%6|1637327168.580|FAIL|rdkafka#消费者-1| [thrd:my-external-host:9092/bootstrap]: my-external-host:9092/bootstrap: Disconnected while requesting ApiVersion: 可能是由于不正确的 security.protocol 配置（连接到 SSL 侦听器？）或代理版本是< 0.10（参见 api.version.request）（在 APIVERSION_QUERY 状态 2 毫秒后）%7|1637327168.580|FEATURE|rdkafka#consumer-1| [thrd:my-external-host:9092/bootstrap]：my-external-host:9092/bootstrap：将启用的协议功能 -ApiVersion 更新为 %7|1637327168.580|STATE|rdkafka#consumer-1| [thrd：我的外部主机：9092/bootstrap]：我的外部主机：9092/bootstrap：

4

0 回答 0