[INFO] fetching crate baichun-framework-rms 0.1.0... [INFO] testing baichun-framework-rms-0.1.0 against master#cdb45c87e2cd43495379f7e867e3cc15dcee9f93 for pr-145838-1 [INFO] extracting crate baichun-framework-rms 0.1.0 into /workspace/builds/worker-5-tc1/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-tc1/source/Cargo.toml [INFO] validating manifest of crates.io crate baichun-framework-rms 0.1.0 on toolchain cdb45c87e2cd43495379f7e867e3cc15dcee9f93 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "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" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded rdkafka v0.37.0 [INFO] [stderr] Downloaded cc v1.2.26 [INFO] [stderr] Downloaded rdkafka-sys v4.8.0+2.3.0 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/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" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 192d65478b3e927e2935e59b15ffeac006f20ed55c87b45378c369e0e8483435 [INFO] running `Command { std: "docker" "start" "-a" "192d65478b3e927e2935e59b15ffeac006f20ed55c87b45378c369e0e8483435", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "192d65478b3e927e2935e59b15ffeac006f20ed55c87b45378c369e0e8483435", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "192d65478b3e927e2935e59b15ffeac006f20ed55c87b45378c369e0e8483435", kill_on_drop: false }` [INFO] [stdout] 192d65478b3e927e2935e59b15ffeac006f20ed55c87b45378c369e0e8483435 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/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" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 0619a5979277fd47514df8831efc41a41dc4bf30351d278f8c86b8465d9a2b5e [INFO] running `Command { std: "docker" "start" "-a" "0619a5979277fd47514df8831efc41a41dc4bf30351d278f8c86b8465d9a2b5e", 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 parking_lot_core v0.9.11 [INFO] [stderr] Compiling signal-hook-registry v1.4.5 [INFO] [stderr] Compiling mio v1.0.4 [INFO] [stderr] Compiling parking_lot v0.12.4 [INFO] [stderr] Compiling socket2 v0.5.10 [INFO] [stderr] Compiling indexmap v2.9.0 [INFO] [stderr] Compiling either v1.15.0 [INFO] [stderr] Compiling rayon v1.10.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 libz-sys v1.1.22 [INFO] [stderr] Compiling chrono v0.4.41 [INFO] [stderr] Compiling toml_edit v0.22.27 [INFO] [stderr] Compiling sysinfo v0.30.13 [INFO] [stderr] Compiling proc-macro-crate v3.3.0 [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 async-trait v0.1.88 [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 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 17s [INFO] running `Command { std: "docker" "inspect" "0619a5979277fd47514df8831efc41a41dc4bf30351d278f8c86b8465d9a2b5e", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "0619a5979277fd47514df8831efc41a41dc4bf30351d278f8c86b8465d9a2b5e", kill_on_drop: false }` [INFO] [stdout] 0619a5979277fd47514df8831efc41a41dc4bf30351d278f8c86b8465d9a2b5e [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/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" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 68101026d95d44b23735d0b73447928b11fa66d036440378b3bb8e48e7d88aa6 [INFO] running `Command { std: "docker" "start" "-a" "68101026d95d44b23735d0b73447928b11fa66d036440378b3bb8e48e7d88aa6", kill_on_drop: false }` [INFO] [stderr] Compiling tokio v1.45.1 [INFO] [stderr] Compiling tracing v0.1.41 [INFO] [stderr] Compiling serial_test_derive v2.0.0 [INFO] [stderr] Compiling thread_local v1.1.8 [INFO] [stderr] Compiling diff v0.1.13 [INFO] [stderr] Compiling yansi v1.0.1 [INFO] [stderr] Compiling tracing-subscriber v0.3.19 [INFO] [stderr] Compiling serial_test v2.0.0 [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.51s [INFO] running `Command { std: "docker" "inspect" "68101026d95d44b23735d0b73447928b11fa66d036440378b3bb8e48e7d88aa6", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "68101026d95d44b23735d0b73447928b11fa66d036440378b3bb8e48e7d88aa6", kill_on_drop: false }` [INFO] [stdout] 68101026d95d44b23735d0b73447928b11fa66d036440378b3bb8e48e7d88aa6 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/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" "+cdb45c87e2cd43495379f7e867e3cc15dcee9f93" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] 83bb9fffa98c28d08fbdad1be7a7cebec612a46d35e1d619e1f2ff0252800274 [INFO] running `Command { std: "docker" "start" "-a" "83bb9fffa98c28d08fbdad1be7a7cebec612a46d35e1d619e1f2ff0252800274", 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.22s [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:21:27.245823Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 开始消息消费测试 [INFO] [stdout] 2025-09-01T07:21:27.249848Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 创建消费者实例 [INFO] [stdout] 2025-09-01T07:21:27.250436Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 消费者创建成功 [INFO] [stdout] 2025-09-01T07:21:27.250449Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 开始订阅主题: test-topic [INFO] [stdout] 2025-09-01T07:21:27.250457Z  INFO baichun_framework_rms::message::kafka::consumer: 开始订阅主题: test-topic [INFO] [stdout] 2025-09-01T07:21:27.250471Z ERROR baichun_framework_rms::message::kafka::consumer: 停止现有消费者失败: Channel error: channel closed [INFO] [stdout] 2025-09-01T07:21:32.254511Z  INFO baichun_framework_rms::message::kafka::consumer: 成功订阅主题: test-topic [INFO] [stdout] 2025-09-01T07:21:37.255080Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 成功订阅主题 [INFO] [stdout] 2025-09-01T07:21:37.255136Z  INFO baichun_framework_rms::message::kafka::consumer: 开始消费任务: test-topic [INFO] [stdout] 2025-09-01T07:21:37.255172Z  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:21:37.255200Z  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:21:37.255215Z  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:21:37.255229Z 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:21:37.255242Z 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:21:37.255255Z 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:21:37.255267Z 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:21:37.255281Z 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:21:37.255293Z 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:21:37.255305Z 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:21:37.255316Z 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:21:37.255338Z 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:21:37.255360Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:21:38.256992Z ERROR rdkafka::client: librdkafka: Global error: AllBrokersDown (Local: All broker connections are down): 1/1 brokers are down [INFO] [stdout] 2025-09-01T07:21:38.257033Z 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:21:39.260946Z 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:21:39.260990Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:21:39.261004Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-09-01T07:21:44.261802Z 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:21:44.261844Z 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:21:44.261860Z 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:21:44.261881Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:21:45.263032Z 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:21:45.263067Z 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, 1 identical error(s) suppressed) [INFO] [stdout] 2025-09-01T07:21:45.263088Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:21:46.265900Z 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:21:46.265931Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:21:46.265940Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-09-01T07:21:51.267054Z 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:21:51.267100Z 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:21:51.267112Z 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:21:51.267122Z 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:21:51.267133Z 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:21:51.267153Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:21:52.268519Z 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:21:52.268560Z 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:21:52.268582Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:21:53.271933Z 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:21:53.271984Z 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:21:53.272011Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:21:53.272020Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-09-01T07:21:58.273234Z 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:21:58.273282Z 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:21:58.273295Z 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:21:58.273306Z 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:21:58.273320Z 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:21:58.273340Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:21:59.274057Z 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:21:59.274100Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:22:00.275364Z 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:22:00.275411Z 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:22:00.275432Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:22:00.275439Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-09-01T07:22:05.276078Z 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:22:05.276126Z 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:22:05.276140Z 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:22:05.276152Z 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:22:05.276165Z 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:22:05.276187Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:22:06.277051Z 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:22:06.277092Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:22:07.278274Z 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:22:07.278332Z 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:22:07.278359Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-09-01T07:22:07.278367Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-09-01T07:22:07.305549Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 接收到的消息: [] [INFO] [stdout] [INFO] [stdout] thread 'message::kafka::consumer::tests::test_message_consumption' (16) panicked at src/message/kafka/consumer.rs:823:9: [INFO] [stdout] 没有接收到任何消息 [INFO] [stdout] stack backtrace: [INFO] [stdout] 0: 0x580f086d5a42 - std::backtrace_rs::backtrace::libunwind::trace::h7cddb8376417e7cc [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9 [INFO] [stdout] 1: 0x580f086d5a42 - std::backtrace_rs::backtrace::trace_unsynchronized::hb4e41acf4b349ff1 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14 [INFO] [stdout] 2: 0x580f086d5a42 - std::sys::backtrace::_print_fmt::h1222b80910ba6eb5 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/sys/backtrace.rs:66:9 [INFO] [stdout] 3: 0x580f086d5a42 - ::fmt::h5bb8a979ba5db788 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/sys/backtrace.rs:39:26 [INFO] [stdout] 4: 0x580f086e757f - core::fmt::rt::Argument::fmt::h2ee2c138a50a7796 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/fmt/rt.rs:173:76 [INFO] [stdout] 5: 0x580f086e757f - core::fmt::write::h1e0dbf07fe3990bd [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/fmt/mod.rs:1468:25 [INFO] [stdout] 6: 0x580f086a2bc3 - std::io::default_write_fmt::h7d7ad5ed6a883d81 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/io/mod.rs:639:11 [INFO] [stdout] 7: 0x580f086a2bc3 - std::io::Write::write_fmt::hc477d9325b345ece [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/io/mod.rs:1954:13 [INFO] [stdout] 8: 0x580f086aeb42 - std::sys::backtrace::BacktraceLock::print::h788d486777205086 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/sys/backtrace.rs:42:9 [INFO] [stdout] 9: 0x580f086b381f - std::panicking::default_hook::{{closure}}::ha7bdfeb5949fc0fa [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:301:27 [INFO] [stdout] 10: 0x580f086b36b1 - std::panicking::default_hook::h6dad75ec721846f4 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:325:9 [INFO] [stdout] 11: 0x580f083a202e - as core::ops::function::Fn>::call::h33799d04b0b96146 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/alloc/src/boxed.rs:1999:9 [INFO] [stdout] 12: 0x580f083a202e - test::test_main_with_exit_callback::{{closure}}::h880e31c829a2eb5d [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/test/src/lib.rs:145:21 [INFO] [stdout] 13: 0x580f086b3f6e - as core::ops::function::Fn>::call::h5e1b8c652ea49180 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/alloc/src/boxed.rs:1999:9 [INFO] [stdout] 14: 0x580f086b3f6e - std::panicking::panic_with_hook::hba00e869ada17676 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:842:13 [INFO] [stdout] 15: 0x580f086b3c56 - std::panicking::panic_handler::{{closure}}::h3d21149c258e5ceb [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:700:13 [INFO] [stdout] 16: 0x580f086aec79 - std::sys::backtrace::__rust_end_short_backtrace::h4f5d9b9dfb3e6ec1 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/sys/backtrace.rs:174:18 [INFO] [stdout] 17: 0x580f08696dcd - __rustc[9a7a9f9af7564de1]::rust_begin_unwind [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:698:5 [INFO] [stdout] 18: 0x580f086ef8e0 - core::panicking::panic_fmt::h78e817a90331d98b [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/panicking.rs:75:14 [INFO] [stdout] 19: 0x580f082f033d - baichun_framework_rms::message::kafka::consumer::tests::test_message_consumption::{{closure}}::ha92c01a7cb1655dc [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/consumer.rs:823:9 [INFO] [stdout] 20: 0x580f082d0fb2 - as core::future::future::Future>::poll::h979f9116a6067eb7 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/future/future.rs:133:9 [INFO] [stdout] 21: 0x580f082d106d - as core::future::future::Future>::poll::hc9317a16455cf4e5 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/future/future.rs:133:9 [INFO] [stdout] 22: 0x580f0830605d - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::{{closure}}::{{closure}}::hf63c7b4fcc0580ee [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: 0x580f08305dbb - tokio::task::coop::with_budget::hdee893dd7e7c2fb5 [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: 0x580f08305dbb - tokio::task::coop::budget::h027a474c9a789fa4 [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: 0x580f08305dbb - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::{{closure}}::h21ac3f9f61048bd6 [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: 0x580f083033d0 - tokio::runtime::scheduler::current_thread::Context::enter::hb5852f2ab618d3b0 [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: 0x580f0830548d - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::ha777e26cdb9f348d [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: 0x580f083046a4 - tokio::runtime::scheduler::current_thread::CoreGuard::enter::{{closure}}::h295ae9f8a8829cbc [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: 0x580f082fbcfb - tokio::runtime::context::scoped::Scoped::set::he783658a8f4f8b4f [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: 0x580f082fb869 - tokio::runtime::context::set_scheduler::{{closure}}::haa5ea6d450c1a4e9 [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: 0x580f083146d2 - std::thread::local::LocalKey::try_with::hc91d928a83dbc4f9 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/thread/local.rs:315:12 [INFO] [stdout] 32: 0x580f083133ce - std::thread::local::LocalKey::with::h123497341a9741e2 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/thread/local.rs:279:20 [INFO] [stdout] 33: 0x580f082fb81d - tokio::runtime::context::set_scheduler::hd5b1eb7ff6ef0b5e [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: 0x580f08304030 - tokio::runtime::scheduler::current_thread::CoreGuard::enter::h3cbc168c6276128e [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: 0x580f08304743 - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::h98898f5845783894 [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: 0x580f08301f70 - tokio::runtime::scheduler::current_thread::CurrentThread::block_on::{{closure}}::ha0c97e50649736cd [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: 0x580f082de5a0 - tokio::runtime::context::runtime::enter_runtime::h2acada5bb01a5779 [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: 0x580f08301931 - tokio::runtime::scheduler::current_thread::CurrentThread::block_on::h69ad7cd19b858e69 [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: 0x580f082df1c4 - tokio::runtime::runtime::Runtime::block_on_inner::h6df93998206a3bf0 [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: 0x580f082df387 - tokio::runtime::runtime::Runtime::block_on::h957ac6abb2132bf6 [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: 0x580f082eb0f3 - baichun_framework_rms::message::kafka::consumer::tests::test_message_consumption::h64910c9787275bd8 [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/consumer.rs:831:53 [INFO] [stdout] 42: 0x580f082eb187 - baichun_framework_rms::message::kafka::consumer::tests::test_message_consumption::{{closure}}::ha1312aedfac15009 [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/consumer.rs:741:40 [INFO] [stdout] 43: 0x580f082f4d86 - core::ops::function::FnOnce::call_once::h35a4b4e86443a4a4 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/ops/function.rs:253:5 [INFO] [stdout] 44: 0x580f083a1e2b - core::ops::function::FnOnce::call_once::h7f4b4fba903e39d5 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/ops/function.rs:253:5 [INFO] [stdout] 45: 0x580f083a1e2b - test::__rust_begin_short_backtrace::h9277cb6a2ccfc000 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/test/src/lib.rs:663:18 [INFO] [stdout] 46: 0x580f083b78d5 - test::run_test_in_process::{{closure}}::h9aea5ca90d1f4423 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/test/src/lib.rs:686:74 [INFO] [stdout] 47: 0x580f083b78d5 - as core::ops::function::FnOnce<()>>::call_once::h364f5fe6cc8afa85 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/panic/unwind_safe.rs:272:9 [INFO] [stdout] 48: 0x580f083b78d5 - std::panicking::catch_unwind::do_call::h2b2bec3317fe53ec [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:590:40 [INFO] [stdout] 49: 0x580f083b78d5 - std::panicking::catch_unwind::hc3763734156da4af [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:553:19 [INFO] [stdout] 50: 0x580f083b78d5 - std::panic::catch_unwind::h28038391e867eabc [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panic.rs:359:14 [INFO] [stdout] 51: 0x580f083b78d5 - test::run_test_in_process::had0273166695a036 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/test/src/lib.rs:686:27 [INFO] [stdout] 52: 0x580f083b78d5 - test::run_test::{{closure}}::h743d09d4bb476605 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/test/src/lib.rs:607:43 [INFO] [stdout] 53: 0x580f0838e2f4 - test::run_test::{{closure}}::he950b8f9118d37e2 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/test/src/lib.rs:637:41 [INFO] [stdout] 54: 0x580f0838e2f4 - std::sys::backtrace::__rust_begin_short_backtrace::hbfaffa6539f6abb7 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/sys/backtrace.rs:158:18 [INFO] [stdout] 55: 0x580f08391bda - std::thread::Builder::spawn_unchecked_::{{closure}}::{{closure}}::hcce3c2c65b9c3b20 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/thread/mod.rs:559:17 [INFO] [stdout] 56: 0x580f08391bda - as core::ops::function::FnOnce<()>>::call_once::hb66b30b6d37985a5 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/panic/unwind_safe.rs:272:9 [INFO] [stdout] 57: 0x580f08391bda - std::panicking::catch_unwind::do_call::h992bbe2c32dc1d79 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:590:40 [INFO] [stdout] 58: 0x580f08391bda - std::panicking::catch_unwind::h412991d5237de610 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:553:19 [INFO] [stdout] 59: 0x580f08391bda - std::panic::catch_unwind::ha82b139b3eb5840a [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panic.rs:359:14 [INFO] [stdout] 60: 0x580f08391bda - std::thread::Builder::spawn_unchecked_::{{closure}}::ha823b36f5114938e [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/thread/mod.rs:557:30 [INFO] [stdout] 61: 0x580f08391bda - core::ops::function::FnOnce::call_once{{vtable.shim}}::hf120e7b1db22ac07 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/ops/function.rs:253:5 [INFO] [stdout] 62: 0x580f086a8eff - as core::ops::function::FnOnce>::call_once::h3e049222c99298ac [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/alloc/src/boxed.rs:1985:9 [INFO] [stdout] 63: 0x580f086a8eff - std::sys::pal::unix::thread::Thread::new::thread_start::h942e336943ad5963 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/sys/pal/unix/thread.rs:118:17 [INFO] [stdout] 64: 0x7c3671a9faa4 - [INFO] [stdout] 65: 0x7c3671b2ca34 - clone [INFO] [stdout] 66: 0x0 - [INFO] [stdout] 2025-09-01T07:22:07.366185Z 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:22:07.366221Z 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:22:07.366234Z 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:22:07.366244Z 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:22:07.366253Z 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:22:07.366262Z 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:22:07.366271Z 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:22:07.366279Z 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:22:07.366288Z 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:22:07.366296Z 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:22:07.366304Z 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, 1 identical error(s) suppressed) [INFO] [stdout] 2025-09-01T07:22:07.366313Z 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:22:07.366321Z 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] [stderr] error: test failed, to rerun pass `--lib` [INFO] [stdout] [INFO] [stdout] ---- message::kafka::producer::tests::test_message_production stdout ---- [INFO] [stdout] 2025-09-01T07:21:27.246736Z  INFO baichun_framework_rms::message::kafka::producer::tests: 生产者创建成功 [INFO] [stdout] 2025-09-01T07:21:27.246757Z  INFO baichun_framework_rms::message::kafka::producer::tests: 开始发送消息到主题: test-topic [INFO] [stdout] 2025-09-01T07:21:27.246805Z  INFO baichun_framework_rms::message::kafka::producer::tests: 发送消息 1: 测试消息1 [INFO] [stdout] 2025-09-01T07:21:27.246826Z DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups [INFO] [stdout] 2025-09-01T07:21:27.246876Z DEBUG librdkafka: librdkafka: BROKER [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1 [INFO] [stdout] 2025-09-01T07:21:27.246885Z 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:21:27.246891Z DEBUG librdkafka: librdkafka: BRKMAIN [thrd::0/internal]: :0/internal: Enter main broker thread [INFO] [stdout] 2025-09-01T07:21:27.246898Z DEBUG librdkafka: librdkafka: INIT [thrd:app]: librdkafka v2.3.0 (0x20300ff) rdkafka#producer-1 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:21:27.246909Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: Client configuration: [INFO] [stdout] 2025-09-01T07:21:27.246916Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: client.software.version = 2.3.0 [INFO] [stdout] 2025-09-01T07:21:27.246924Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: metadata.broker.list = localhost:9092 [INFO] [stdout] 2025-09-01T07:21:27.246931Z 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:21:27.246939Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: enabled_events = 329 [INFO] [stdout] 2025-09-01T07:21:27.246946Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: log.queue = true [INFO] [stdout] 2025-09-01T07:21:27.246958Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: opaque = 0x7c366c00c9d0 [INFO] [stdout] 2025-09-01T07:21:27.246964Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: default_topic_conf = 0x7c366c00ca20 [INFO] [stdout] 2025-09-01T07:21:27.246971Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: Default topic configuration: [INFO] [stdout] 2025-09-01T07:21:27.246978Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: message.timeout.ms = 30000 [INFO] [stdout] 2025-09-01T07:21:27.246984Z DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread [INFO] [stdout] 2025-09-01T07:21:27.252815Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 6ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:21:27.252836Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 6ms in state CONNECT) [INFO] [stdout] 2025-09-01T07:21:27.252850Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:27.252858Z ERROR rdkafka::client: librdkafka: Global error: AllBrokersDown (Local: All broker connections are down): 1/1 brokers are down [INFO] [stdout] 2025-09-01T07:21:27.252866Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:28.248144Z 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:21:28.248182Z 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:21:28.248196Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:29.291856Z 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:21:29.291905Z 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:21:29.291921Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:30.249356Z 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:21:30.249395Z 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, 1 identical error(s) suppressed) [INFO] [stdout] 2025-09-01T07:21:30.249410Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:31.245724Z 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:21:31.245764Z 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:21:31.245780Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:33.245919Z 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:21:33.245953Z 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:21:33.245965Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:35.252338Z 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:21:35.252378Z 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:21:35.252392Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:37.252440Z 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:21:37.252478Z 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:21:37.252492Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:39.254240Z 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:21:39.254278Z 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:21:39.254293Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:40.254439Z 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:21:40.254482Z 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:21:40.254496Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:43.254784Z 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:21:43.254870Z 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:21:43.254884Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:44.255171Z 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:21:44.255206Z 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:21:44.255219Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:45.254977Z 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:21:45.255015Z 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:21:45.255028Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:46.262865Z 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:21:46.262901Z 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:21:46.262915Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:48.255402Z 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:21:48.255447Z 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:21:48.255463Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:49.280539Z 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:21:49.280573Z 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:21:49.280588Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:51.281508Z 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:21:51.281542Z 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:21:51.281556Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:52.281260Z 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:21:52.281280Z 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:21:52.281290Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:55.284908Z 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:21:55.284945Z 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:21:55.284960Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:57.285020Z 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:21:57.285057Z 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:21:57.285072Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:58.285194Z 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:21:58.285226Z 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:21:58.285240Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:21:59.285173Z 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:21:59.285206Z 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:21:59.285221Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:00.285426Z 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:22:00.285450Z 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:22:00.285462Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:01.285587Z 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:22:01.285622Z 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:22:01.285651Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:02.285278Z 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:22:02.285333Z 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:22:02.285350Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:03.285639Z 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:22:03.285690Z 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:22:03.285704Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:04.285421Z 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:22:04.285467Z 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:22:04.285483Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:06.285348Z 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:22:06.285381Z 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:22:06.285394Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:08.285830Z 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:22:08.285868Z 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:22:08.285882Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:11.286051Z 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:22:11.286089Z 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:22:11.286104Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:12.286551Z 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:22:12.286588Z 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:22:12.286612Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:13.286406Z 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:22:13.286444Z 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:22:13.286458Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:16.287345Z 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:22:16.287385Z 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:22:16.287407Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:19.287881Z 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:22:19.287924Z 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:22:19.287939Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:20.288034Z 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:22:20.288071Z 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:22:20.288085Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:22.287986Z 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:22:22.288026Z 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:22:22.288042Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:24.292309Z 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:22:24.292345Z 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:22:24.292358Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:25.292152Z 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:22:25.292187Z 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:22:25.292199Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:26.292449Z 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:22:26.292487Z 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:22:26.292508Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:27.292188Z 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:22:27.292224Z 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:22:27.292239Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-09-01T07:22:27.347663Z 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' (17) 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: 0x580f086d5a42 - std::backtrace_rs::backtrace::libunwind::trace::h7cddb8376417e7cc [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9 [INFO] [stdout] 1: 0x580f086d5a42 - std::backtrace_rs::backtrace::trace_unsynchronized::hb4e41acf4b349ff1 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14 [INFO] [stdout] 2: 0x580f086d5a42 - std::sys::backtrace::_print_fmt::h1222b80910ba6eb5 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/sys/backtrace.rs:66:9 [INFO] [stdout] 3: 0x580f086d5a42 - ::fmt::h5bb8a979ba5db788 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/sys/backtrace.rs:39:26 [INFO] [stdout] 4: 0x580f086e757f - core::fmt::rt::Argument::fmt::h2ee2c138a50a7796 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/fmt/rt.rs:173:76 [INFO] [stdout] 5: 0x580f086e757f - core::fmt::write::h1e0dbf07fe3990bd [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/fmt/mod.rs:1468:25 [INFO] [stdout] 6: 0x580f086a2bc3 - std::io::default_write_fmt::h7d7ad5ed6a883d81 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/io/mod.rs:639:11 [INFO] [stdout] 7: 0x580f086a2bc3 - std::io::Write::write_fmt::hc477d9325b345ece [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/io/mod.rs:1954:13 [INFO] [stdout] 8: 0x580f086aeb42 - std::sys::backtrace::BacktraceLock::print::h788d486777205086 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/sys/backtrace.rs:42:9 [INFO] [stdout] 9: 0x580f086b381f - std::panicking::default_hook::{{closure}}::ha7bdfeb5949fc0fa [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:301:27 [INFO] [stdout] 10: 0x580f086b36b1 - std::panicking::default_hook::h6dad75ec721846f4 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:325:9 [INFO] [stdout] 11: 0x580f083a202e - as core::ops::function::Fn>::call::h33799d04b0b96146 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/alloc/src/boxed.rs:1999:9 [INFO] [stdout] 12: 0x580f083a202e - test::test_main_with_exit_callback::{{closure}}::h880e31c829a2eb5d [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/test/src/lib.rs:145:21 [INFO] [stdout] 13: 0x580f086b3f6e - as core::ops::function::Fn>::call::h5e1b8c652ea49180 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/alloc/src/boxed.rs:1999:9 [INFO] [stdout] 14: 0x580f086b3f6e - std::panicking::panic_with_hook::hba00e869ada17676 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:842:13 [INFO] [stdout] 15: 0x580f086b3c8a - std::panicking::panic_handler::{{closure}}::h3d21149c258e5ceb [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:707:13 [INFO] [stdout] 16: 0x580f086aec79 - std::sys::backtrace::__rust_end_short_backtrace::h4f5d9b9dfb3e6ec1 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/sys/backtrace.rs:174:18 [INFO] [stdout] 17: 0x580f08696dcd - __rustc[9a7a9f9af7564de1]::rust_begin_unwind [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:698:5 [INFO] [stdout] 18: 0x580f086ef8e0 - core::panicking::panic_fmt::h78e817a90331d98b [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/panicking.rs:75:14 [INFO] [stdout] 19: 0x580f083377df - baichun_framework_rms::message::kafka::producer::tests::test_message_production::{{closure}}::h2db7e249afbae5d4 [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/producer.rs:193:21 [INFO] [stdout] 20: 0x580f082d0fb2 - as core::future::future::Future>::poll::h979f9116a6067eb7 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/future/future.rs:133:9 [INFO] [stdout] 21: 0x580f082d106d - as core::future::future::Future>::poll::hc9317a16455cf4e5 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/future/future.rs:133:9 [INFO] [stdout] 22: 0x580f0830605d - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::{{closure}}::{{closure}}::hf63c7b4fcc0580ee [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: 0x580f08305dbb - tokio::task::coop::with_budget::hdee893dd7e7c2fb5 [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: 0x580f08305dbb - tokio::task::coop::budget::h027a474c9a789fa4 [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: 0x580f08305dbb - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::{{closure}}::h21ac3f9f61048bd6 [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: 0x580f083033d0 - tokio::runtime::scheduler::current_thread::Context::enter::hb5852f2ab618d3b0 [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: 0x580f0830548d - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::ha777e26cdb9f348d [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: 0x580f083046a4 - tokio::runtime::scheduler::current_thread::CoreGuard::enter::{{closure}}::h295ae9f8a8829cbc [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: 0x580f082fbcfb - tokio::runtime::context::scoped::Scoped::set::he783658a8f4f8b4f [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: 0x580f082fb869 - tokio::runtime::context::set_scheduler::{{closure}}::haa5ea6d450c1a4e9 [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: 0x580f083146d2 - std::thread::local::LocalKey::try_with::hc91d928a83dbc4f9 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/thread/local.rs:315:12 [INFO] [stdout] 32: 0x580f083133ce - std::thread::local::LocalKey::with::h123497341a9741e2 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/thread/local.rs:279:20 [INFO] [stdout] 33: 0x580f082fb81d - tokio::runtime::context::set_scheduler::hd5b1eb7ff6ef0b5e [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: 0x580f08304030 - tokio::runtime::scheduler::current_thread::CoreGuard::enter::h3cbc168c6276128e [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: 0x580f08304743 - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::h98898f5845783894 [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: 0x580f08301f70 - tokio::runtime::scheduler::current_thread::CurrentThread::block_on::{{closure}}::ha0c97e50649736cd [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: 0x580f082de5a0 - tokio::runtime::context::runtime::enter_runtime::h2acada5bb01a5779 [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: 0x580f08301931 - tokio::runtime::scheduler::current_thread::CurrentThread::block_on::h69ad7cd19b858e69 [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: 0x580f082df1c4 - tokio::runtime::runtime::Runtime::block_on_inner::h6df93998206a3bf0 [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: 0x580f082df387 - tokio::runtime::runtime::Runtime::block_on::h957ac6abb2132bf6 [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: 0x580f08331553 - baichun_framework_rms::message::kafka::producer::tests::test_message_production::h98e70c41a6f0a275 [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/producer.rs:203:57 [INFO] [stdout] 42: 0x580f083315e7 - baichun_framework_rms::message::kafka::producer::tests::test_message_production::{{closure}}::h24b9ebf5411cb7ae [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/producer.rs:147:39 [INFO] [stdout] 43: 0x580f082f4f96 - core::ops::function::FnOnce::call_once::h5924d8fdb4a12dde [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/ops/function.rs:253:5 [INFO] [stdout] 44: 0x580f083a1e2b - core::ops::function::FnOnce::call_once::h7f4b4fba903e39d5 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/ops/function.rs:253:5 [INFO] [stdout] 45: 0x580f083a1e2b - test::__rust_begin_short_backtrace::h9277cb6a2ccfc000 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/test/src/lib.rs:663:18 [INFO] [stdout] 46: 0x580f083b78d5 - test::run_test_in_process::{{closure}}::h9aea5ca90d1f4423 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/test/src/lib.rs:686:74 [INFO] [stdout] 47: 0x580f083b78d5 - as core::ops::function::FnOnce<()>>::call_once::h364f5fe6cc8afa85 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/panic/unwind_safe.rs:272:9 [INFO] [stdout] 48: 0x580f083b78d5 - std::panicking::catch_unwind::do_call::h2b2bec3317fe53ec [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:590:40 [INFO] [stdout] 49: 0x580f083b78d5 - std::panicking::catch_unwind::hc3763734156da4af [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:553:19 [INFO] [stdout] 50: 0x580f083b78d5 - std::panic::catch_unwind::h28038391e867eabc [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panic.rs:359:14 [INFO] [stdout] 51: 0x580f083b78d5 - test::run_test_in_process::had0273166695a036 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/test/src/lib.rs:686:27 [INFO] [stdout] 52: 0x580f083b78d5 - test::run_test::{{closure}}::h743d09d4bb476605 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/test/src/lib.rs:607:43 [INFO] [stdout] 53: 0x580f0838e2f4 - test::run_test::{{closure}}::he950b8f9118d37e2 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/test/src/lib.rs:637:41 [INFO] [stdout] 54: 0x580f0838e2f4 - std::sys::backtrace::__rust_begin_short_backtrace::hbfaffa6539f6abb7 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/sys/backtrace.rs:158:18 [INFO] [stdout] 55: 0x580f08391bda - std::thread::Builder::spawn_unchecked_::{{closure}}::{{closure}}::hcce3c2c65b9c3b20 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/thread/mod.rs:559:17 [INFO] [stdout] 56: 0x580f08391bda - as core::ops::function::FnOnce<()>>::call_once::hb66b30b6d37985a5 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/panic/unwind_safe.rs:272:9 [INFO] [stdout] 57: 0x580f08391bda - std::panicking::catch_unwind::do_call::h992bbe2c32dc1d79 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:590:40 [INFO] [stdout] 58: 0x580f08391bda - std::panicking::catch_unwind::h412991d5237de610 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panicking.rs:553:19 [INFO] [stdout] 59: 0x580f08391bda - std::panic::catch_unwind::ha82b139b3eb5840a [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/panic.rs:359:14 [INFO] [stdout] 60: 0x580f08391bda - std::thread::Builder::spawn_unchecked_::{{closure}}::ha823b36f5114938e [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/thread/mod.rs:557:30 [INFO] [stdout] 61: 0x580f08391bda - core::ops::function::FnOnce::call_once{{vtable.shim}}::hf120e7b1db22ac07 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/core/src/ops/function.rs:253:5 [INFO] [stdout] 62: 0x580f086a8eff - as core::ops::function::FnOnce>::call_once::h3e049222c99298ac [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/alloc/src/boxed.rs:1985:9 [INFO] [stdout] 63: 0x580f086a8eff - std::sys::pal::unix::thread::Thread::new::thread_start::h942e336943ad5963 [INFO] [stdout] at /rustc/cdb45c87e2cd43495379f7e867e3cc15dcee9f93/library/std/src/sys/pal/unix/thread.rs:118:17 [INFO] [stdout] 64: 0x7c3671a9faa4 - [INFO] [stdout] 65: 0x7c3671b2ca34 - 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.15s [INFO] [stdout] [INFO] running `Command { std: "docker" "inspect" "83bb9fffa98c28d08fbdad1be7a7cebec612a46d35e1d619e1f2ff0252800274", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "83bb9fffa98c28d08fbdad1be7a7cebec612a46d35e1d619e1f2ff0252800274", kill_on_drop: false }` [INFO] [stdout] 83bb9fffa98c28d08fbdad1be7a7cebec612a46d35e1d619e1f2ff0252800274