GitHub user doveq edited a discussion: 请教使用 rust client 连接失败的问题
同一个机器上安装的 RocketMQ Dashboard 可正常连接管理。但使用的是官方 https://github.com/apache/rocketmq-clients/blob/master/rust/examples/producer.rs 的例子一直提示如下错误： ``` Compiling testmq v0.1.0 (/root/testmq) Finished dev [unoptimized + debuginfo] target(s) in 5.50s Running `target/debug/testmq` Sep 07 03:06:15.214 INFO[/root/.cargo/registry/src/index.crates.io-6f17d22bba15001f/rocketmq-5.0.0/src/session.rs:175:9] create session success, peer: 172.16.0.182:9876, component: session producer start failed: Client internal error at client.start => send rpc telemetry failed Context: called: session.start Source: status: Unknown, message: "transport error", details: [], metadata: MetadataMap { headers: {} } Caused by: 0: transport error 1: connection error: stream closed because of a broken pipe 2: stream closed because of a broken pipe ``` 2个服务的启动方式： ``` sh mqnamesrv sh mqbroker -n mqnamesrv:9876 -c /home/rocketmq/conf/broker.conf --enable-proxy ``` broker.conf 配置如下 ``` # 集群名称 brokerClusterName = DefaultCluster # 节点名称 brokerName = broker-a # broker id节点ID， 0 表示 master, 其他的正整数表示 slave，不能小于0 brokerId = 0 # Broker服务地址 String 内部使用填内网ip，如果是需要给外部使用填公网ip brokerIP1 = 172.16.0.182 # Broker角色 brokerRole = ASYNC_MASTER # 刷盘方式 flushDiskType = ASYNC_FLUSH # 在每天的什么时间删除已经超过文件保留时间的 commit log，默认值04 deleteWhen = 04 # 以小时计算的文件保留时间 默认值72小时 fileReservedTime = 72 # 是否允许Broker 自动创建Topic，建议线下开启，线上关闭 autoCreateTopicEnable=true # 是否允许Broker自动创建订阅组，建议线下开启，线上关闭 autoCreateSubscriptionGroup=true ``` 请问可能是什么问题？谢谢 GitHub link: https://github.com/apache/rocketmq-clients/discussions/597 ---- This is an automatically sent email for dev@rocketmq.apache.org. To unsubscribe, please send an email to: dev-unsubscr...@rocketmq.apache.org
