[INFO] fetching crate baichun-framework-rms 0.1.0... [INFO] testing baichun-framework-rms-0.1.0 against try#b83b707f97d809763b7861afa7638871f3339a33 for pr-145838-1 [INFO] extracting crate baichun-framework-rms 0.1.0 into /workspace/builds/worker-5-tc2/source [INFO] started tweaking crates.io crate baichun-framework-rms 0.1.0 [INFO] removed 0 missing tests [INFO] finished tweaking crates.io crate baichun-framework-rms 0.1.0 [INFO] tweaked toml for crates.io crate baichun-framework-rms 0.1.0 written to /workspace/builds/worker-5-tc2/source/Cargo.toml [INFO] validating manifest of crates.io crate baichun-framework-rms 0.1.0 on toolchain b83b707f97d809763b7861afa7638871f3339a33 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+b83b707f97d809763b7861afa7638871f3339a33" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate crates.io crate baichun-framework-rms 0.1.0 already has a lockfile, it will not be regenerated [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+b83b707f97d809763b7861afa7638871f3339a33" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+b83b707f97d809763b7861afa7638871f3339a33" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 94e39b4e58a68edd060249cfdae997d44bdaa2d5861ad4b11aed4b60c29f2d76 [INFO] running `Command { std: "docker" "start" "-a" "94e39b4e58a68edd060249cfdae997d44bdaa2d5861ad4b11aed4b60c29f2d76", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "94e39b4e58a68edd060249cfdae997d44bdaa2d5861ad4b11aed4b60c29f2d76", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "94e39b4e58a68edd060249cfdae997d44bdaa2d5861ad4b11aed4b60c29f2d76", kill_on_drop: false }` [INFO] [stdout] 94e39b4e58a68edd060249cfdae997d44bdaa2d5861ad4b11aed4b60c29f2d76 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+b83b707f97d809763b7861afa7638871f3339a33" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 34cd789b494c7f0a4a709c447ce9dc0461c752a3e7d5aeffb0de0877014a8622 [INFO] running `Command { std: "docker" "start" "-a" "34cd789b494c7f0a4a709c447ce9dc0461c752a3e7d5aeffb0de0877014a8622", kill_on_drop: false }` [INFO] [stderr] Compiling syn v2.0.102 [INFO] [stderr] Compiling hashbrown v0.15.4 [INFO] [stderr] Compiling cc v1.2.26 [INFO] [stderr] Compiling lock_api v0.4.13 [INFO] [stderr] Compiling winnow v0.7.11 [INFO] [stderr] Compiling smallvec v1.15.1 [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling rdkafka-sys v4.8.0+2.3.0 [INFO] [stderr] Compiling num-traits v0.2.19 [INFO] [stderr] Compiling mio v1.0.4 [INFO] [stderr] Compiling parking_lot_core v0.9.11 [INFO] [stderr] Compiling signal-hook-registry v1.4.5 [INFO] [stderr] Compiling indexmap v2.9.0 [INFO] [stderr] Compiling socket2 v0.5.10 [INFO] [stderr] Compiling parking_lot v0.12.4 [INFO] [stderr] Compiling either v1.15.0 [INFO] [stderr] Compiling getrandom v0.3.3 [INFO] [stderr] Compiling time v0.3.41 [INFO] [stderr] Compiling dashmap v5.5.3 [INFO] [stderr] Compiling rayon v1.10.0 [INFO] [stderr] Compiling toml_edit v0.22.27 [INFO] [stderr] Compiling chrono v0.4.41 [INFO] [stderr] Compiling libz-sys v1.1.22 [INFO] [stderr] Compiling proc-macro-crate v3.3.0 [INFO] [stderr] Compiling sysinfo v0.30.13 [INFO] [stderr] Compiling serde_derive v1.0.219 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling num_enum_derive v0.7.3 [INFO] [stderr] Compiling tokio-macros v2.5.0 [INFO] [stderr] Compiling tracing-attributes v0.1.29 [INFO] [stderr] Compiling thiserror-impl v1.0.69 [INFO] [stderr] Compiling tokio v1.45.1 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling num_enum v0.7.3 [INFO] [stderr] Compiling async-trait v0.1.88 [INFO] [stderr] Compiling thiserror v1.0.69 [INFO] [stderr] Compiling tracing v0.1.41 [INFO] [stderr] Compiling serde v1.0.219 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling serde_json v1.0.140 [INFO] [stderr] Compiling uuid v1.17.0 [INFO] [stderr] Compiling rdkafka v0.37.0 [INFO] [stderr] Compiling baichun-framework-rms v0.1.0 (/opt/rustwide/workdir) [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 2m 24s [INFO] running `Command { std: "docker" "inspect" "34cd789b494c7f0a4a709c447ce9dc0461c752a3e7d5aeffb0de0877014a8622", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "34cd789b494c7f0a4a709c447ce9dc0461c752a3e7d5aeffb0de0877014a8622", kill_on_drop: false }` [INFO] [stdout] 34cd789b494c7f0a4a709c447ce9dc0461c752a3e7d5aeffb0de0877014a8622 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+b83b707f97d809763b7861afa7638871f3339a33" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 080633bf5a89a6ab0e3a3b93796aa9483666e580c6c70555ed88a7558763a059 [INFO] running `Command { std: "docker" "start" "-a" "080633bf5a89a6ab0e3a3b93796aa9483666e580c6c70555ed88a7558763a059", kill_on_drop: false }` [INFO] [stderr] Compiling tokio v1.45.1 [INFO] [stderr] Compiling tracing v0.1.41 [INFO] [stderr] Compiling thread_local v1.1.8 [INFO] [stderr] Compiling serial_test_derive v2.0.0 [INFO] [stderr] Compiling yansi v1.0.1 [INFO] [stderr] Compiling diff v0.1.13 [INFO] [stderr] Compiling serial_test v2.0.0 [INFO] [stderr] Compiling tracing-subscriber v0.3.19 [INFO] [stderr] Compiling pretty_assertions v1.4.1 [INFO] [stderr] Compiling rdkafka v0.37.0 [INFO] [stderr] Compiling baichun-framework-rms v0.1.0 (/opt/rustwide/workdir) [INFO] [stdout] warning: unused import: `lazy_static::lazy_static` [INFO] [stdout] --> tests/common/mod.rs:1:5 [INFO] [stdout] | [INFO] [stdout] 1 | use lazy_static::lazy_static; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: unused import: `warn` [INFO] [stdout] --> tests/kafka/basic_test.rs:20:21 [INFO] [stdout] | [INFO] [stdout] 20 | use tracing::{info, warn}; [INFO] [stdout] | ^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 24.58s [INFO] running `Command { std: "docker" "inspect" "080633bf5a89a6ab0e3a3b93796aa9483666e580c6c70555ed88a7558763a059", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "080633bf5a89a6ab0e3a3b93796aa9483666e580c6c70555ed88a7558763a059", kill_on_drop: false }` [INFO] [stdout] 080633bf5a89a6ab0e3a3b93796aa9483666e580c6c70555ed88a7558763a059 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:7ad1b28ee6f5f7f699f6cf7015098d6ccdd96d6f2d78dd06228f5b4c9faf309c" "/opt/rustwide/cargo-home/bin/cargo" "+b83b707f97d809763b7861afa7638871f3339a33" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] 2ecf425cf3bb45b36decb2a3b1a5690b063ff7e381e77ed5b9147d81e52d3bf3 [INFO] running `Command { std: "docker" "start" "-a" "2ecf425cf3bb45b36decb2a3b1a5690b063ff7e381e77ed5b9147d81e52d3bf3", kill_on_drop: false }` [INFO] [stderr] warning: unused import: `lazy_static::lazy_static` [INFO] [stderr] --> tests/common/mod.rs:1:5 [INFO] [stderr] | [INFO] [stderr] 1 | use lazy_static::lazy_static; [INFO] [stderr] | ^^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stderr] | [INFO] [stderr] = note: `#[warn(unused_imports)]` (part of `#[warn(unused)]`) on by default [INFO] [stderr] [INFO] [stderr] warning: unused import: `warn` [INFO] [stderr] --> tests/kafka/basic_test.rs:20:21 [INFO] [stderr] | [INFO] [stderr] 20 | use tracing::{info, warn}; [INFO] [stderr] | ^^^^ [INFO] [stderr] [INFO] [stderr] warning: `baichun-framework-rms` (test "lib") generated 2 warnings (run `cargo fix --test "lib"` to apply 2 suggestions) [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 0.18s [INFO] [stderr] Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/baichun_framework_rms-91dcbb49993ba479) [INFO] [stdout] [INFO] [stdout] running 3 tests [INFO] [stdout] test message::kafka::producer::tests::test_producer_creation ... ok [INFO] [stdout] test message::kafka::consumer::tests::test_message_consumption ... FAILED [INFO] [stdout] test message::kafka::producer::tests::test_message_production has been running for over 60 seconds [INFO] [stdout] test message::kafka::producer::tests::test_message_production ... FAILED [INFO] [stdout] [INFO] [stdout] failures: [INFO] [stdout] [INFO] [stdout] ---- message::kafka::consumer::tests::test_message_consumption stdout ---- [INFO] [stdout] 2025-09-01T07:25:19.936219Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 开始消息消费测试 [INFO] [stdout] 2025-09-01T07:25:19.936297Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 创建消费者实例 [INFO] [stdout] 2025-09-01T07:25:19.937361Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 消费者创建成功 [INFO] [stdout] 2025-09-01T07:25:19.937375Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 开始订阅主题: test-topic [INFO] [stdout] 2025-09-01T07:25:19.937383Z  INFO baichun_framework_rms::message::kafka::consumer: 开始订阅主题: test-topic [INFO] [stdout] 2025-09-01T07:25:19.937396Z ERROR baichun_framework_rms::message::kafka::consumer: 停止现有消费者失败: Channel error: channel closed [INFO] [stdout] 2025-09-01T07:25:24.939336Z  INFO baichun_framework_rms::message::kafka::consumer: 成功订阅主题: test-topic [INFO] [stdout] 2025-09-01T07:25:29.941058Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 成功订阅主题 [INFO] [stdout] 2025-09-01T07:25:29.941105Z  INFO baichun_framework_rms::message::kafka::consumer: 开始消费任务: test-topic [INFO] [stdout] 2025-09-01T07:25:29.941141Z  WARN librdkafka: librdkafka: CONFWARN [thrd:app]: Configuration property enable.idempotence is a producer property and will be ignored by this consumer instance [INFO] [stdout] 2025-09-01T07:25:29.941165Z  WARN librdkafka: librdkafka: CONFWARN [thrd:app]: Configuration property retry.backoff.ms is a producer property and will be ignored by this consumer instance [INFO] [stdout] 2025-09-01T07:25:29.941177Z  WARN librdkafka: librdkafka: CONFWARN [thrd:app]: Configuration property request.timeout.ms is a producer property and will be ignored by this consumer instance [INFO] [stdout] 2025-09-01T07:25:29.941187Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:29.941198Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:29.941209Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT, 1 identical error(s) suppressed) [INFO] [stdout] 2025-09-01T07:25:29.941220Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:29.941231Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:29.941242Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:29.941253Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:29.941265Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:29.941276Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 1ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:29.941296Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:30.943181Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:30.943234Z ERROR rdkafka::client: librdkafka: Global error: AllBrokersDown (Local: All broker connections are down): 1/1 brokers are down [INFO] [stdout] 2025-09-01T07:25:30.943256Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: AllBrokersDown (Local: All broker connections are down) [INFO] [stdout] 2025-09-01T07:25:31.945068Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:31.945116Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:31.945139Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:31.945151Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-09-01T07:25:36.947051Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:36.947099Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:36.947111Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:36.947124Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT, 1 identical error(s) suppressed) [INFO] [stdout] 2025-09-01T07:25:36.947145Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:37.948251Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:37.948310Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:38.949951Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:38.949992Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:38.950001Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-09-01T07:25:43.952034Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:43.952084Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:43.952101Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:43.952113Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:43.952173Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:43.952196Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:44.953518Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:44.953568Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:44.953598Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:45.963929Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:45.963970Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:45.963979Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-09-01T07:25:50.972929Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:50.972965Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:50.972977Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:50.972986Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:50.972996Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:50.973007Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:50.973026Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:51.980928Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:51.980979Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:51.981001Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:52.983065Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:52.983110Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:52.983142Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:52.983152Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-09-01T07:25:57.985056Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:57.985099Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:57.985114Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:57.985127Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:57.985138Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:57.985150Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:57.985173Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:58.988922Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT, 1 identical error(s) suppressed) [INFO] [stdout] 2025-09-01T07:25:58.988986Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:58.989010Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:59.991055Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:59.991104Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:59.991127Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:25:59.991135Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-09-01T07:26:00.063904Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 接收到的消息: [] [INFO] [stdout] [INFO] [stdout] thread 'message::kafka::consumer::tests::test_message_consumption' (17) panicked at src/message/kafka/consumer.rs:823:9: [INFO] [stdout] 没有接收到任何消息 [INFO] [stdout] stack backtrace: [INFO] [stdout] 0: 0x5ba4b9c19aa2 - std::backtrace_rs::backtrace::libunwind::trace::h589a96ef7638b383 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9 [INFO] [stdout] 1: 0x5ba4b9c19aa2 - std::backtrace_rs::backtrace::trace_unsynchronized::h23a30a7548c40de4 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14 [INFO] [stdout] 2: 0x5ba4b9c19aa2 - std::sys::backtrace::_print_fmt::h87dabd6535c8c07a [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/sys/backtrace.rs:66:9 [INFO] [stdout] 3: 0x5ba4b9c19aa2 - ::fmt::hffd20ad4e5eca8ab [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/sys/backtrace.rs:39:26 [INFO] [stdout] 4: 0x5ba4b9c2b5df - core::fmt::rt::Argument::fmt::h75c83e3fd5ce2419 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/fmt/rt.rs:173:76 [INFO] [stdout] 5: 0x5ba4b9c2b5df - core::fmt::write::h6d9d3a7cfd7b84f5 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/fmt/mod.rs:1468:25 [INFO] [stdout] 6: 0x5ba4b9be6c23 - std::io::default_write_fmt::he11a713685e2464d [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/io/mod.rs:639:11 [INFO] [stdout] 7: 0x5ba4b9be6c23 - std::io::Write::write_fmt::h9d08f7e050bd2612 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/io/mod.rs:1954:13 [INFO] [stdout] 8: 0x5ba4b9bf2ba2 - std::sys::backtrace::BacktraceLock::print::hb28797143397220e [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/sys/backtrace.rs:42:9 [INFO] [stdout] 9: 0x5ba4b9bf787f - std::panicking::default_hook::{{closure}}::h7555113b62983743 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:301:27 [INFO] [stdout] 10: 0x5ba4b9bf7711 - std::panicking::default_hook::h2714b564abe8d914 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:325:9 [INFO] [stdout] 11: 0x5ba4b98e921e - as core::ops::function::Fn>::call::h0e9de8cceb22406e [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/alloc/src/boxed.rs:1999:9 [INFO] [stdout] 12: 0x5ba4b98e921e - test::test_main_with_exit_callback::{{closure}}::h8125bd66cf4739d0 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/test/src/lib.rs:145:21 [INFO] [stdout] 13: 0x5ba4b9bf7fce - as core::ops::function::Fn>::call::h1fd0a0802eaec16b [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/alloc/src/boxed.rs:1999:9 [INFO] [stdout] 14: 0x5ba4b9bf7fce - std::panicking::panic_with_hook::h190dc82263685ec5 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:842:13 [INFO] [stdout] 15: 0x5ba4b9bf7cb6 - std::panicking::panic_handler::{{closure}}::h8b036a1b366643ac [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:700:13 [INFO] [stdout] 16: 0x5ba4b9bf2cd9 - std::sys::backtrace::__rust_end_short_backtrace::h45affcfc0c830da8 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/sys/backtrace.rs:174:18 [INFO] [stdout] 17: 0x5ba4b9bdae2d - __rustc[9b67c8562bba447b]::rust_begin_unwind [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:698:5 [INFO] [stdout] 18: 0x5ba4b9c33940 - core::panicking::panic_fmt::hc084f85b1e76c16d [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/panicking.rs:75:14 [INFO] [stdout] 19: 0x5ba4b98392ad - baichun_framework_rms::message::kafka::consumer::tests::test_message_consumption::{{closure}}::h9ba7d368be83e43b [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/consumer.rs:823:9 [INFO] [stdout] 20: 0x5ba4b981a112 - as core::future::future::Future>::poll::hd0ae5cf4e05e4b71 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/future/future.rs:133:9 [INFO] [stdout] 21: 0x5ba4b9819fcd - as core::future::future::Future>::poll::h4b83a81f88dd6b33 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/future/future.rs:133:9 [INFO] [stdout] 22: 0x5ba4b984f5bd - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::{{closure}}::{{closure}}::h7d1bdd5d06eedc1e [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:733:70 [INFO] [stdout] 23: 0x5ba4b984f4eb - tokio::task::coop::with_budget::h067ac16d06330264 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/task/coop/mod.rs:167:5 [INFO] [stdout] 24: 0x5ba4b984f4eb - tokio::task::coop::budget::h1b53b0795c63ea82 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/task/coop/mod.rs:133:5 [INFO] [stdout] 25: 0x5ba4b984f4eb - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::{{closure}}::h661e94029dd741c7 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:733:25 [INFO] [stdout] 26: 0x5ba4b984cc90 - tokio::runtime::scheduler::current_thread::Context::enter::hf7ae8dabc22c234a [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:432:19 [INFO] [stdout] 27: 0x5ba4b984ea2d - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::hc0ad4ab0f67d5800 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:732:44 [INFO] [stdout] 28: 0x5ba4b984dc44 - tokio::runtime::scheduler::current_thread::CoreGuard::enter::{{closure}}::h40f72dac5fd0df02 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:820:68 [INFO] [stdout] 29: 0x5ba4b983cfcb - tokio::runtime::context::scoped::Scoped::set::h3be4d65ea7341406 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/context/scoped.rs:40:9 [INFO] [stdout] 30: 0x5ba4b98448b9 - tokio::runtime::context::set_scheduler::{{closure}}::h53aef2b0f00cc627 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/context.rs:176:38 [INFO] [stdout] 31: 0x5ba4b985d7e2 - std::thread::local::LocalKey::try_with::h9bcb96f321f51797 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/thread/local.rs:315:12 [INFO] [stdout] 32: 0x5ba4b985ca6e - std::thread::local::LocalKey::with::hfd07cf4142335385 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/thread/local.rs:279:20 [INFO] [stdout] 33: 0x5ba4b984486d - tokio::runtime::context::set_scheduler::haf7dc789d742b5c5 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/context.rs:176:17 [INFO] [stdout] 34: 0x5ba4b984d5d0 - tokio::runtime::scheduler::current_thread::CoreGuard::enter::h1f56dd7168db1f5a [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:820:27 [INFO] [stdout] 35: 0x5ba4b984dce3 - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::he2d12fc5f75c69f9 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:720:24 [INFO] [stdout] 36: 0x5ba4b984b1c0 - tokio::runtime::scheduler::current_thread::CurrentThread::block_on::{{closure}}::ha81c094c0e70a82d [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:200:33 [INFO] [stdout] 37: 0x5ba4b9827580 - tokio::runtime::context::runtime::enter_runtime::h6a2d5b553614e998 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/context/runtime.rs:65:16 [INFO] [stdout] 38: 0x5ba4b984af81 - tokio::runtime::scheduler::current_thread::CurrentThread::block_on::hf9056f5fd1198bec [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:188:9 [INFO] [stdout] 39: 0x5ba4b9828304 - tokio::runtime::runtime::Runtime::block_on_inner::he9ef53fba5873ec9 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/runtime.rs:356:52 [INFO] [stdout] 40: 0x5ba4b98284c7 - tokio::runtime::runtime::Runtime::block_on::h2783748cdd243b2c [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/runtime.rs:330:18 [INFO] [stdout] 41: 0x5ba4b9834063 - baichun_framework_rms::message::kafka::consumer::tests::test_message_consumption::h7d2ff39b7318b2cc [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/consumer.rs:831:53 [INFO] [stdout] 42: 0x5ba4b98340f7 - baichun_framework_rms::message::kafka::consumer::tests::test_message_consumption::{{closure}}::h78ad7bd0571f86a5 [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/consumer.rs:741:40 [INFO] [stdout] 43: 0x5ba4b983df86 - core::ops::function::FnOnce::call_once::h4d3ff77c010fc94b [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/ops/function.rs:253:5 [INFO] [stdout] 44: 0x5ba4b98e8fdb - core::ops::function::FnOnce::call_once::hdbf42be2a49fb464 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/ops/function.rs:253:5 [INFO] [stdout] 45: 0x5ba4b98e8fdb - test::__rust_begin_short_backtrace::h8ae08814d38cb356 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/test/src/lib.rs:663:18 [INFO] [stdout] 46: 0x5ba4b98feac5 - test::run_test_in_process::{{closure}}::h54574ee4f414d690 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/test/src/lib.rs:686:74 [INFO] [stdout] 47: 0x5ba4b98feac5 - as core::ops::function::FnOnce<()>>::call_once::h01a0b7e7aad1a501 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/panic/unwind_safe.rs:272:9 [INFO] [stdout] 48: 0x5ba4b98feac5 - std::panicking::catch_unwind::do_call::h23820e817c5612cd [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:590:40 [INFO] [stdout] 49: 0x5ba4b98feac5 - std::panicking::catch_unwind::h89c73a1febce5587 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:553:19 [INFO] [stdout] 50: 0x5ba4b98feac5 - std::panic::catch_unwind::h6f55caf410861914 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panic.rs:359:14 [INFO] [stdout] 51: 0x5ba4b98feac5 - test::run_test_in_process::h4db851878e5d3983 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/test/src/lib.rs:686:27 [INFO] [stdout] 52: 0x5ba4b98feac5 - test::run_test::{{closure}}::h57e8c5acaceacd24 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/test/src/lib.rs:607:43 [INFO] [stdout] 53: 0x5ba4b98d54b4 - test::run_test::{{closure}}::he775ccc3a9d3b97e [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/test/src/lib.rs:637:41 [INFO] [stdout] 54: 0x5ba4b98d54b4 - std::sys::backtrace::__rust_begin_short_backtrace::hcd94d85d7765225a [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/sys/backtrace.rs:158:18 [INFO] [stdout] 55: 0x5ba4b98d8cfa - std::thread::Builder::spawn_unchecked_::{{closure}}::{{closure}}::ha814de8393f07830 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/thread/mod.rs:559:17 [INFO] [stdout] 56: 0x5ba4b98d8cfa - as core::ops::function::FnOnce<()>>::call_once::h8deb00af0abdeaf1 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/panic/unwind_safe.rs:272:9 [INFO] [stdout] 57: 0x5ba4b98d8cfa - std::panicking::catch_unwind::do_call::h1917979b0c279ea2 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:590:40 [INFO] [stdout] 58: 0x5ba4b98d8cfa - std::panicking::catch_unwind::h791ad91fee6ce34e [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:553:19 [INFO] [stdout] 59: 0x5ba4b98d8cfa - std::panic::catch_unwind::h982b8f40ed9c3cce [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panic.rs:359:14 [INFO] [stdout] 60: 0x5ba4b98d8cfa - std::thread::Builder::spawn_unchecked_::{{closure}}::h545e54700c945db4 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/thread/mod.rs:557:30 [INFO] [stdout] 61: 0x5ba4b98d8cfa - core::ops::function::FnOnce::call_once{{vtable.shim}}::hb427481a5227d78a [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/ops/function.rs:253:5 [INFO] [stdout] 62: 0x5ba4b9becf5f - as core::ops::function::FnOnce>::call_once::h1d452951a81e9d0a [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/alloc/src/boxed.rs:1985:9 [INFO] [stdout] 63: 0x5ba4b9becf5f - std::sys::pal::unix::thread::Thread::new::thread_start::h29c84e109630689a [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/sys/pal/unix/thread.rs:118:17 [INFO] [stdout] 64: 0x7ce588de4aa4 - [INFO] [stdout] 65: 0x7ce588e71a34 - clone [INFO] [stdout] 66: 0x0 - [INFO] [stdout] 2025-09-01T07:26:00.147287Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] [INFO] [stdout] ---- message::kafka::producer::tests::test_message_production stdout ---- [INFO] [stdout] 2025-09-01T07:25:19.968001Z  INFO baichun_framework_rms::message::kafka::producer::tests: 生产者创建成功 [INFO] [stdout] 2025-09-01T07:25:19.968034Z  INFO baichun_framework_rms::message::kafka::producer::tests: 开始发送消息到主题: test-topic [INFO] [stdout] 2025-09-01T07:25:19.968058Z  INFO baichun_framework_rms::message::kafka::producer::tests: 发送消息 1: 测试消息1 [INFO] [stdout] 2025-09-01T07:25:19.968058Z DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups [INFO] [stdout] 2025-09-01T07:25:19.968078Z DEBUG librdkafka: librdkafka: BROKER [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1 [INFO] [stdout] 2025-09-01T07:25:19.968086Z DEBUG librdkafka: librdkafka: CONNECT [thrd:app]: localhost:9092/bootstrap: Selected for cluster connection: bootstrap servers added (broker has 0 connection attempt(s)) [INFO] [stdout] 2025-09-01T07:25:19.968094Z DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread [INFO] [stdout] 2025-09-01T07:25:19.970195Z DEBUG librdkafka: librdkafka: CONNECT [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Received CONNECT op [INFO] [stdout] 2025-09-01T07:25:19.970208Z DEBUG librdkafka: librdkafka: STATE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state INIT -> TRY_CONNECT [INFO] [stdout] 2025-09-01T07:25:19.970216Z DEBUG librdkafka: librdkafka: BROADCAST [thrd:localhost:9092/bootstrap]: Broadcasting state change [INFO] [stdout] 2025-09-01T07:25:19.970224Z DEBUG librdkafka: librdkafka: CONNECT [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: broker in state TRY_CONNECT connecting [INFO] [stdout] 2025-09-01T07:25:19.970231Z DEBUG librdkafka: librdkafka: STATE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state TRY_CONNECT -> CONNECT [INFO] [stdout] 2025-09-01T07:25:19.970239Z DEBUG librdkafka: librdkafka: BROADCAST [thrd:localhost:9092/bootstrap]: Broadcasting state change [INFO] [stdout] 2025-09-01T07:25:19.970247Z DEBUG librdkafka: librdkafka: CONNECT [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connecting to ipv4#127.0.0.1:9092 (plaintext) with socket 31 [INFO] [stdout] 2025-09-01T07:25:19.970262Z DEBUG librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 1ms in state CONNECT) (_TRANSPORT) [INFO] [stdout] 2025-09-01T07:25:19.970272Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 1ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:19.970280Z DEBUG librdkafka: librdkafka: STATE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state CONNECT -> DOWN [INFO] [stdout] 2025-09-01T07:25:19.970288Z DEBUG librdkafka: librdkafka: BROADCAST [thrd:localhost:9092/bootstrap]: Broadcasting state change [INFO] [stdout] 2025-09-01T07:25:19.970296Z DEBUG librdkafka: librdkafka: BUFQ [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers [INFO] [stdout] 2025-09-01T07:25:19.970303Z DEBUG librdkafka: librdkafka: BUFQ [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Purging bufq with 0 buffers [INFO] [stdout] 2025-09-01T07:25:19.970312Z DEBUG librdkafka: librdkafka: BUFQ [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Updating 0 buffers on connection reset [INFO] [stdout] 2025-09-01T07:25:19.970321Z DEBUG librdkafka: librdkafka: STATE [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Broker changed state DOWN -> INIT [INFO] [stdout] 2025-09-01T07:25:19.970328Z DEBUG librdkafka: librdkafka: BROADCAST [thrd:localhost:9092/bootstrap]: Broadcasting state change [INFO] [stdout] 2025-09-01T07:25:19.970337Z DEBUG librdkafka: librdkafka: BRKMAIN [thrd::0/internal]: :0/internal: Enter main broker thread [INFO] [stdout] 2025-09-01T07:25:19.970345Z DEBUG librdkafka: librdkafka: INIT [thrd:app]: librdkafka v2.3.0 (0x20300ff) rdkafka#producer-2 initialized (builtin.features gzip,snappy,sasl,regex,lz4,sasl_plain,plugins, GCC GXX PKGCONFIG INSTALL GNULD LDS C11THREADS LIBDL PLUGINS ZLIB HDRHISTOGRAM SYSLOG SNAPPY SOCKEM CRC32C_HW, debug 0xfffff) [INFO] [stdout] 2025-09-01T07:25:19.970354Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: Client configuration: [INFO] [stdout] 2025-09-01T07:25:19.970368Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: client.software.version = 2.3.0 [INFO] [stdout] 2025-09-01T07:25:19.970376Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: metadata.broker.list = localhost:9092 [INFO] [stdout] 2025-09-01T07:25:19.970384Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: debug = generic,broker,topic,metadata,feature,queue,msg,protocol,cgrp,security,fetch,interceptor,plugin,consumer,admin,eos,mock,assignor,conf,all [INFO] [stdout] 2025-09-01T07:25:19.970392Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: enabled_events = 329 [INFO] [stdout] 2025-09-01T07:25:19.970401Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: log.queue = true [INFO] [stdout] 2025-09-01T07:25:19.970409Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: opaque = 0x7ce570006a50 [INFO] [stdout] 2025-09-01T07:25:19.970418Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: default_topic_conf = 0x7ce570006a80 [INFO] [stdout] 2025-09-01T07:25:19.970426Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: Default topic configuration: [INFO] [stdout] 2025-09-01T07:25:19.970435Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: message.timeout.ms = 30000 [INFO] [stdout] 2025-09-01T07:25:19.970444Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 1ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:19.970459Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:19.970468Z ERROR rdkafka::client: librdkafka: Global error: AllBrokersDown (Local: All broker connections are down): 1/1 brokers are down [INFO] [stdout] 2025-09-01T07:25:19.970475Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:20.966173Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT, 1 identical error(s) suppressed) [INFO] [stdout] 2025-09-01T07:25:20.966211Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT, 1 identical error(s) suppressed) [INFO] [stdout] 2025-09-01T07:25:20.966225Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:21.961573Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:21.961619Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:21.961634Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:23.962180Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:23.962213Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:23.962226Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:24.962066Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:24.962103Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:24.962117Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:25.962231Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:25.962269Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:25.962283Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:26.962098Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:26.962135Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:26.962150Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:28.962146Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:28.962190Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:28.962204Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:30.962144Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:30.962181Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:30.962196Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:32.963003Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:32.963043Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:32.963059Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:33.963131Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:33.963165Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:33.963179Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:34.963022Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:34.963057Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:34.963079Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:37.005029Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:37.005068Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:37.005083Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:38.005258Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:38.005301Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:38.005316Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:39.005128Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:39.005164Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:39.005177Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:41.056856Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:41.056895Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:41.056911Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:42.021052Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:42.021086Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:42.021099Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:44.022210Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:44.022247Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:44.022262Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:46.022370Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:46.022406Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:46.022419Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:47.022538Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:47.022574Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:47.022597Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:48.023021Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:48.023057Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:48.023070Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:50.023259Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:50.023296Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:50.023311Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:51.023438Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT, 1 identical error(s) suppressed) [INFO] [stdout] 2025-09-01T07:25:51.023474Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT, 1 identical error(s) suppressed) [INFO] [stdout] 2025-09-01T07:25:51.023487Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:52.030158Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:52.030195Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:52.030210Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:53.030026Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:53.030060Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:53.030073Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:55.030089Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:55.030133Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:55.030146Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:56.078206Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:56.078245Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:56.078259Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:57.078111Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:57.078148Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:57.078163Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:58.085394Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:58.085432Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:58.085447Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:25:59.078167Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:59.078204Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:25:59.078218Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:00.078281Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:00.078314Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:00.078329Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:01.084895Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:01.084955Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:01.084971Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:03.078188Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:03.078223Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:03.078236Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:04.078337Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:04.078374Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:04.078388Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:05.082850Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:05.082890Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:05.082906Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:06.082056Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:06.082097Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:06.082113Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:08.082056Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:08.082092Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:08.082106Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:10.082114Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:10.082157Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:10.082172Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:11.082259Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:11.082294Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:11.082309Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:12.082158Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:12.082193Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:12.082207Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:13.082286Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:13.082323Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:13.082337Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:14.082167Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:14.082204Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:14.082218Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:15.082337Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:15.082376Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:15.082391Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:16.082212Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:16.082254Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:16.082272Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:17.082350Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:17.082388Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv4#127.0.0.1:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:17.082402Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:18.082241Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:18.082279Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 0ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:26:18.082294Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:26:20.071146Z ERROR baichun_framework_rms::message::kafka::producer::tests: 消息 1 发送失败: Config("Failed to create topic: Admin operation error: OperationTimedOut (Local: Timed out)") [INFO] [stdout] [INFO] [stdout] thread 'message::kafka::producer::tests::test_message_production' (18) panicked at src/message/kafka/producer.rs:193:21: [INFO] [stdout] 消息发送失败: Config("Failed to create topic: Admin operation error: OperationTimedOut (Local: Timed out)") [INFO] [stdout] stack backtrace: [INFO] [stdout] 0: 0x5ba4b9c19aa2 - std::backtrace_rs::backtrace::libunwind::trace::h589a96ef7638b383 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9 [INFO] [stdout] 1: 0x5ba4b9c19aa2 - std::backtrace_rs::backtrace::trace_unsynchronized::h23a30a7548c40de4 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14 [INFO] [stdout] 2: 0x5ba4b9c19aa2 - std::sys::backtrace::_print_fmt::h87dabd6535c8c07a [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/sys/backtrace.rs:66:9 [INFO] [stdout] 3: 0x5ba4b9c19aa2 - ::fmt::hffd20ad4e5eca8ab [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/sys/backtrace.rs:39:26 [INFO] [stdout] 4: 0x5ba4b9c2b5df - core::fmt::rt::Argument::fmt::h75c83e3fd5ce2419 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/fmt/rt.rs:173:76 [INFO] [stdout] 5: 0x5ba4b9c2b5df - core::fmt::write::h6d9d3a7cfd7b84f5 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/fmt/mod.rs:1468:25 [INFO] [stdout] 6: 0x5ba4b9be6c23 - std::io::default_write_fmt::he11a713685e2464d [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/io/mod.rs:639:11 [INFO] [stdout] 7: 0x5ba4b9be6c23 - std::io::Write::write_fmt::h9d08f7e050bd2612 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/io/mod.rs:1954:13 [INFO] [stdout] 8: 0x5ba4b9bf2ba2 - std::sys::backtrace::BacktraceLock::print::hb28797143397220e [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/sys/backtrace.rs:42:9 [INFO] [stdout] 9: 0x5ba4b9bf787f - std::panicking::default_hook::{{closure}}::h7555113b62983743 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:301:27 [INFO] [stdout] 10: 0x5ba4b9bf7711 - std::panicking::default_hook::h2714b564abe8d914 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:325:9 [INFO] [stdout] 11: 0x5ba4b98e921e - as core::ops::function::Fn>::call::h0e9de8cceb22406e [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/alloc/src/boxed.rs:1999:9 [INFO] [stdout] 12: 0x5ba4b98e921e - test::test_main_with_exit_callback::{{closure}}::h8125bd66cf4739d0 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/test/src/lib.rs:145:21 [INFO] [stdout] 13: 0x5ba4b9bf7fce - as core::ops::function::Fn>::call::h1fd0a0802eaec16b [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/alloc/src/boxed.rs:1999:9 [INFO] [stdout] 14: 0x5ba4b9bf7fce - std::panicking::panic_with_hook::h190dc82263685ec5 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:842:13 [INFO] [stdout] 15: 0x5ba4b9bf7cea - std::panicking::panic_handler::{{closure}}::h8b036a1b366643ac [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:707:13 [INFO] [stdout] 16: 0x5ba4b9bf2cd9 - std::sys::backtrace::__rust_end_short_backtrace::h45affcfc0c830da8 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/sys/backtrace.rs:174:18 [INFO] [stdout] 17: 0x5ba4b9bdae2d - __rustc[9b67c8562bba447b]::rust_begin_unwind [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:698:5 [INFO] [stdout] 18: 0x5ba4b9c33940 - core::panicking::panic_fmt::hc084f85b1e76c16d [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/panicking.rs:75:14 [INFO] [stdout] 19: 0x5ba4b988077f - baichun_framework_rms::message::kafka::producer::tests::test_message_production::{{closure}}::h86b3603d608b5b16 [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/producer.rs:193:21 [INFO] [stdout] 20: 0x5ba4b981a112 - as core::future::future::Future>::poll::hd0ae5cf4e05e4b71 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/future/future.rs:133:9 [INFO] [stdout] 21: 0x5ba4b9819fcd - as core::future::future::Future>::poll::h4b83a81f88dd6b33 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/future/future.rs:133:9 [INFO] [stdout] 22: 0x5ba4b984f5bd - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::{{closure}}::{{closure}}::h7d1bdd5d06eedc1e [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:733:70 [INFO] [stdout] 23: 0x5ba4b984f4eb - tokio::task::coop::with_budget::h067ac16d06330264 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/task/coop/mod.rs:167:5 [INFO] [stdout] 24: 0x5ba4b984f4eb - tokio::task::coop::budget::h1b53b0795c63ea82 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/task/coop/mod.rs:133:5 [INFO] [stdout] 25: 0x5ba4b984f4eb - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::{{closure}}::h661e94029dd741c7 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:733:25 [INFO] [stdout] 26: 0x5ba4b984cc90 - tokio::runtime::scheduler::current_thread::Context::enter::hf7ae8dabc22c234a [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:432:19 [INFO] [stdout] 27: 0x5ba4b984ea2d - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::hc0ad4ab0f67d5800 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:732:44 [INFO] [stdout] 28: 0x5ba4b984dc44 - tokio::runtime::scheduler::current_thread::CoreGuard::enter::{{closure}}::h40f72dac5fd0df02 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:820:68 [INFO] [stdout] 29: 0x5ba4b983cfcb - tokio::runtime::context::scoped::Scoped::set::h3be4d65ea7341406 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/context/scoped.rs:40:9 [INFO] [stdout] 30: 0x5ba4b98448b9 - tokio::runtime::context::set_scheduler::{{closure}}::h53aef2b0f00cc627 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/context.rs:176:38 [INFO] [stdout] 31: 0x5ba4b985d7e2 - std::thread::local::LocalKey::try_with::h9bcb96f321f51797 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/thread/local.rs:315:12 [INFO] [stdout] 32: 0x5ba4b985ca6e - std::thread::local::LocalKey::with::hfd07cf4142335385 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/thread/local.rs:279:20 [INFO] [stdout] 33: 0x5ba4b984486d - tokio::runtime::context::set_scheduler::haf7dc789d742b5c5 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/context.rs:176:17 [INFO] [stdout] 34: 0x5ba4b984d5d0 - tokio::runtime::scheduler::current_thread::CoreGuard::enter::h1f56dd7168db1f5a [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:820:27 [INFO] [stdout] 35: 0x5ba4b984dce3 - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::he2d12fc5f75c69f9 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:720:24 [INFO] [stdout] 36: 0x5ba4b984b1c0 - tokio::runtime::scheduler::current_thread::CurrentThread::block_on::{{closure}}::ha81c094c0e70a82d [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:200:33 [INFO] [stdout] 37: 0x5ba4b9827580 - tokio::runtime::context::runtime::enter_runtime::h6a2d5b553614e998 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/context/runtime.rs:65:16 [INFO] [stdout] 38: 0x5ba4b984af81 - tokio::runtime::scheduler::current_thread::CurrentThread::block_on::hf9056f5fd1198bec [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/scheduler/current_thread/mod.rs:188:9 [INFO] [stdout] 39: 0x5ba4b9828304 - tokio::runtime::runtime::Runtime::block_on_inner::he9ef53fba5873ec9 [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/runtime.rs:356:52 [INFO] [stdout] 40: 0x5ba4b98284c7 - tokio::runtime::runtime::Runtime::block_on::h2783748cdd243b2c [INFO] [stdout] at /opt/rustwide/cargo-home/registry/src/index.crates.io-1949cf8c6b5b557f/tokio-1.45.1/src/runtime/runtime.rs:330:18 [INFO] [stdout] 41: 0x5ba4b987a523 - baichun_framework_rms::message::kafka::producer::tests::test_message_production::h45498a26dd15ad98 [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/producer.rs:203:57 [INFO] [stdout] 42: 0x5ba4b9880937 - baichun_framework_rms::message::kafka::producer::tests::test_message_production::{{closure}}::hd1ea22f0b632683e [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/producer.rs:147:39 [INFO] [stdout] 43: 0x5ba4b983ddb6 - core::ops::function::FnOnce::call_once::h3288b0da12c775d3 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/ops/function.rs:253:5 [INFO] [stdout] 44: 0x5ba4b98e8fdb - core::ops::function::FnOnce::call_once::hdbf42be2a49fb464 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/ops/function.rs:253:5 [INFO] [stdout] 45: 0x5ba4b98e8fdb - test::__rust_begin_short_backtrace::h8ae08814d38cb356 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/test/src/lib.rs:663:18 [INFO] [stdout] 46: 0x5ba4b98feac5 - test::run_test_in_process::{{closure}}::h54574ee4f414d690 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/test/src/lib.rs:686:74 [INFO] [stdout] 47: 0x5ba4b98feac5 - as core::ops::function::FnOnce<()>>::call_once::h01a0b7e7aad1a501 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/panic/unwind_safe.rs:272:9 [INFO] [stdout] 48: 0x5ba4b98feac5 - std::panicking::catch_unwind::do_call::h23820e817c5612cd [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:590:40 [INFO] [stdout] 49: 0x5ba4b98feac5 - std::panicking::catch_unwind::h89c73a1febce5587 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:553:19 [INFO] [stdout] 50: 0x5ba4b98feac5 - std::panic::catch_unwind::h6f55caf410861914 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panic.rs:359:14 [INFO] [stdout] 51: 0x5ba4b98feac5 - test::run_test_in_process::h4db851878e5d3983 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/test/src/lib.rs:686:27 [INFO] [stdout] 52: 0x5ba4b98feac5 - test::run_test::{{closure}}::h57e8c5acaceacd24 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/test/src/lib.rs:607:43 [INFO] [stdout] 53: 0x5ba4b98d54b4 - test::run_test::{{closure}}::he775ccc3a9d3b97e [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/test/src/lib.rs:637:41 [INFO] [stdout] 54: 0x5ba4b98d54b4 - std::sys::backtrace::__rust_begin_short_backtrace::hcd94d85d7765225a [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/sys/backtrace.rs:158:18 [INFO] [stdout] 55: 0x5ba4b98d8cfa - std::thread::Builder::spawn_unchecked_::{{closure}}::{{closure}}::ha814de8393f07830 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/thread/mod.rs:559:17 [INFO] [stdout] 56: 0x5ba4b98d8cfa - as core::ops::function::FnOnce<()>>::call_once::h8deb00af0abdeaf1 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/panic/unwind_safe.rs:272:9 [INFO] [stdout] 57: 0x5ba4b98d8cfa - std::panicking::catch_unwind::do_call::h1917979b0c279ea2 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:590:40 [INFO] [stdout] 58: 0x5ba4b98d8cfa - std::panicking::catch_unwind::h791ad91fee6ce34e [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panicking.rs:553:19 [INFO] [stdout] 59: 0x5ba4b98d8cfa - std::panic::catch_unwind::h982b8f40ed9c3cce [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/panic.rs:359:14 [INFO] [stdout] 60: 0x5ba4b98d8cfa - std::thread::Builder::spawn_unchecked_::{{closure}}::h545e54700c945db4 [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/thread/mod.rs:557:30 [INFO] [stdout] 61: 0x5ba4b98d8cfa - core::ops::function::FnOnce::call_once{{vtable.shim}}::hb427481a5227d78a [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/core/src/ops/function.rs:253:5 [INFO] [stdout] 62: 0x5ba4b9becf5f - as core::ops::function::FnOnce>::call_once::h1d452951a81e9d0a [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/alloc/src/boxed.rs:1985:9 [INFO] [stdout] 63: 0x5ba4b9becf5f - std::sys::pal::unix::thread::Thread::new::thread_start::h29c84e109630689a [INFO] [stdout] at /rustc/b83b707f97d809763b7861afa7638871f3339a33/library/std/src/sys/pal/unix/thread.rs:118:17 [INFO] [stdout] 64: 0x7ce588de4aa4 - [INFO] [stdout] 65: 0x7ce588e71a34 - clone [INFO] [stdout] 66: 0x0 - [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] failures: [INFO] [stdout] message::kafka::consumer::tests::test_message_consumption [INFO] [stdout] message::kafka::producer::tests::test_message_production [INFO] [stdout] [INFO] [stdout] test result: FAILED. 1 passed; 2 failed; 0 ignored; 0 measured; 0 filtered out; finished in 60.23s [INFO] [stdout] [INFO] [stderr] error: test failed, to rerun pass `--lib` [INFO] running `Command { std: "docker" "inspect" "2ecf425cf3bb45b36decb2a3b1a5690b063ff7e381e77ed5b9147d81e52d3bf3", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "2ecf425cf3bb45b36decb2a3b1a5690b063ff7e381e77ed5b9147d81e52d3bf3", kill_on_drop: false }` [INFO] [stdout] 2ecf425cf3bb45b36decb2a3b1a5690b063ff7e381e77ed5b9147d81e52d3bf3