[INFO] fetching crate baichun-framework-rms 0.1.0... [INFO] testing baichun-framework-rms-0.1.0 against master#c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38 for pr-146098-7 [INFO] extracting crate baichun-framework-rms 0.1.0 into /workspace/builds/worker-2-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-2-tc1/source/Cargo.toml [INFO] validating manifest of crates.io crate baichun-framework-rms 0.1.0 on toolchain c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "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" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded rustversion v1.0.21 [INFO] [stderr] Downloaded bumpalo v3.18.1 [INFO] [stderr] Downloaded serial_test_derive v2.0.0 [INFO] [stderr] Downloaded num_enum v0.7.3 [INFO] [stderr] Downloaded num_enum_derive v0.7.3 [INFO] [stderr] Downloaded diff v0.1.13 [INFO] [stderr] Downloaded uuid v1.17.0 [INFO] [stderr] Downloaded yansi v1.0.1 [INFO] [stderr] Downloaded pretty_assertions v1.4.1 [INFO] [stderr] Downloaded cc v1.2.26 [INFO] [stderr] Downloaded time v0.3.41 [INFO] [stderr] Downloaded winnow v0.7.11 [INFO] [stderr] Downloaded sysinfo v0.30.13 [INFO] [stderr] Downloaded tracing-subscriber v0.3.19 [INFO] [stderr] Downloaded tracing-attributes v0.1.29 [INFO] [stderr] Downloaded rustc-demangle v0.1.25 [INFO] [stderr] Downloaded serial_test v2.0.0 [INFO] [stderr] Downloaded regex-syntax v0.6.29 [INFO] [stderr] Downloaded syn v2.0.102 [INFO] [stderr] Downloaded libz-sys v1.1.22 [INFO] [stderr] Downloaded tokio v1.45.1 [INFO] [stderr] Downloaded rdkafka-sys v4.8.0+2.3.0 [INFO] [stderr] Downloaded windows v0.52.0 [INFO] [stderr] Downloaded rdkafka v0.37.0 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-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:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] d2f62d3f04fb4c1bfcd48e72233fe9c1100f54140cdc701e402760859717e007 [INFO] running `Command { std: "docker" "start" "-a" "d2f62d3f04fb4c1bfcd48e72233fe9c1100f54140cdc701e402760859717e007", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "d2f62d3f04fb4c1bfcd48e72233fe9c1100f54140cdc701e402760859717e007", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "d2f62d3f04fb4c1bfcd48e72233fe9c1100f54140cdc701e402760859717e007", kill_on_drop: false }` [INFO] [stdout] d2f62d3f04fb4c1bfcd48e72233fe9c1100f54140cdc701e402760859717e007 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-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:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 0ef394fae1a1822309c848358271c72f36a9c5935af754a2f8210a0bf3a6335f [INFO] running `Command { std: "docker" "start" "-a" "0ef394fae1a1822309c848358271c72f36a9c5935af754a2f8210a0bf3a6335f", kill_on_drop: false }` [INFO] [stderr] Compiling cfg-if v1.0.1 [INFO] [stderr] Compiling equivalent v1.0.2 [INFO] [stderr] Compiling hashbrown v0.15.4 [INFO] [stderr] Compiling crossbeam-utils v0.8.21 [INFO] [stderr] Compiling parking_lot_core v0.9.11 [INFO] [stderr] Compiling winnow v0.7.11 [INFO] [stderr] Compiling toml_datetime v0.6.11 [INFO] [stderr] Compiling futures-core v0.3.31 [INFO] [stderr] Compiling lock_api v0.4.13 [INFO] [stderr] Compiling cc v1.2.26 [INFO] [stderr] Compiling futures-sink v0.3.31 [INFO] [stderr] Compiling smallvec v1.15.1 [INFO] [stderr] Compiling scopeguard v1.2.0 [INFO] [stderr] Compiling syn v2.0.102 [INFO] [stderr] Compiling futures-io v0.3.31 [INFO] [stderr] Compiling rayon-core v1.12.1 [INFO] [stderr] Compiling rdkafka-sys v4.8.0+2.3.0 [INFO] [stderr] Compiling num-traits v0.2.19 [INFO] [stderr] Compiling getrandom v0.3.3 [INFO] [stderr] Compiling serde_json v1.0.140 [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling signal-hook-registry v1.4.5 [INFO] [stderr] Compiling mio v1.0.4 [INFO] [stderr] Compiling socket2 v0.5.10 [INFO] [stderr] Compiling anyhow v1.0.98 [INFO] [stderr] Compiling either v1.15.0 [INFO] [stderr] Compiling deranged v0.4.0 [INFO] [stderr] Compiling iana-time-zone v0.1.63 [INFO] [stderr] Compiling time-core v0.1.4 [INFO] [stderr] Compiling parking_lot v0.12.4 [INFO] [stderr] Compiling dashmap v5.5.3 [INFO] [stderr] Compiling crossbeam-epoch v0.9.18 [INFO] [stderr] Compiling crossbeam-deque v0.8.6 [INFO] [stderr] Compiling indexmap v2.9.0 [INFO] [stderr] Compiling chrono v0.4.41 [INFO] [stderr] Compiling time v0.3.41 [INFO] [stderr] Compiling libz-sys v1.1.22 [INFO] [stderr] Compiling rayon v1.10.0 [INFO] [stderr] Compiling toml_edit v0.22.27 [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 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 num_enum_derive v0.7.3 [INFO] [stderr] Compiling tokio v1.45.1 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling thiserror v1.0.69 [INFO] [stderr] Compiling num_enum v0.7.3 [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 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 1m 07s [INFO] running `Command { std: "docker" "inspect" "0ef394fae1a1822309c848358271c72f36a9c5935af754a2f8210a0bf3a6335f", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "0ef394fae1a1822309c848358271c72f36a9c5935af754a2f8210a0bf3a6335f", kill_on_drop: false }` [INFO] [stdout] 0ef394fae1a1822309c848358271c72f36a9c5935af754a2f8210a0bf3a6335f [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-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:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 0cc70d6efbe4d56d90ddf63de67474d009c2b07bc8e5d32bcd4fa7c3837d0417 [INFO] running `Command { std: "docker" "start" "-a" "0cc70d6efbe4d56d90ddf63de67474d009c2b07bc8e5d32bcd4fa7c3837d0417", kill_on_drop: false }` [INFO] [stderr] Compiling log v0.4.27 [INFO] [stderr] Compiling tracing-core v0.1.34 [INFO] [stderr] Compiling regex-syntax v0.6.29 [INFO] [stderr] Compiling lazy_static v1.5.0 [INFO] [stderr] Compiling regex-syntax v0.8.5 [INFO] [stderr] Compiling tokio v1.45.1 [INFO] [stderr] Compiling overload v0.1.1 [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 nu-ansi-term v0.46.0 [INFO] [stderr] Compiling sharded-slab v0.1.7 [INFO] [stderr] Compiling pretty_assertions v1.4.1 [INFO] [stderr] Compiling serial_test v2.0.0 [INFO] [stderr] Compiling tracing v0.1.41 [INFO] [stderr] Compiling tracing-log v0.2.0 [INFO] [stderr] Compiling regex-automata v0.4.9 [INFO] [stderr] Compiling regex-automata v0.1.10 [INFO] [stderr] Compiling matchers v0.1.0 [INFO] [stderr] Compiling regex v1.11.1 [INFO] [stderr] Compiling tracing-subscriber v0.3.19 [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 21.48s [INFO] running `Command { std: "docker" "inspect" "0cc70d6efbe4d56d90ddf63de67474d009c2b07bc8e5d32bcd4fa7c3837d0417", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "0cc70d6efbe4d56d90ddf63de67474d009c2b07bc8e5d32bcd4fa7c3837d0417", kill_on_drop: false }` [INFO] [stdout] 0cc70d6efbe4d56d90ddf63de67474d009c2b07bc8e5d32bcd4fa7c3837d0417 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-2-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:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "test" "--frozen", kill_on_drop: false }` [INFO] [stdout] a4dd088a299e4e357c123249aca1965c11b7be11086466be68313948d50007ac [INFO] running `Command { std: "docker" "start" "-a" "a4dd088a299e4e357c123249aca1965c11b7be11086466be68313948d50007ac", 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" -p baichun-framework-rms` to apply 2 suggestions) [INFO] [stderr] Finished `test` profile [unoptimized + debuginfo] target(s) in 0.15s [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-11-11T08:18:13.226656Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 开始消息消费测试 [INFO] [stdout] 2025-11-11T08:18:13.226748Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 创建消费者实例 [INFO] [stdout] 2025-11-11T08:18:13.233321Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 消费者创建成功 [INFO] [stdout] 2025-11-11T08:18:13.233336Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 开始订阅主题: test-topic [INFO] [stdout] 2025-11-11T08:18:13.233344Z  INFO baichun_framework_rms::message::kafka::consumer: 开始订阅主题: test-topic [INFO] [stdout] 2025-11-11T08:18:13.233358Z ERROR baichun_framework_rms::message::kafka::consumer: 停止现有消费者失败: Channel error: channel closed [INFO] [stdout] 2025-11-11T08:18:18.234931Z  INFO baichun_framework_rms::message::kafka::consumer: 成功订阅主题: test-topic [INFO] [stdout] 2025-11-11T08:18:23.235995Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 成功订阅主题 [INFO] [stdout] 2025-11-11T08:18:23.236066Z  INFO baichun_framework_rms::message::kafka::consumer: 开始消费任务: test-topic [INFO] [stdout] 2025-11-11T08:18:23.236113Z  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-11-11T08:18:23.236139Z  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-11-11T08:18:23.236153Z  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-11-11T08:18:23.236170Z 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-11-11T08:18:23.236184Z 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-11-11T08:18:23.236195Z 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-11-11T08:18:23.236206Z 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-11-11T08:18:23.236217Z 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-11-11T08:18:23.236228Z 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-11-11T08:18:23.236240Z 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-11-11T08:18:23.236252Z 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-11-11T08:18:23.236265Z 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-11-11T08:18:23.236287Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:24.236918Z 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-11-11T08:18:24.237023Z ERROR rdkafka::client: librdkafka: Global error: AllBrokersDown (Local: All broker connections are down): 1/1 brokers are down [INFO] [stdout] 2025-11-11T08:18:24.237050Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: AllBrokersDown (Local: All broker connections are down) [INFO] [stdout] 2025-11-11T08:18:25.237932Z 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-11-11T08:18:25.237980Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:25.237993Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-11-11T08:18:30.238969Z 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-11-11T08:18:30.239031Z 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-11-11T08:18:30.239046Z 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-11-11T08:18:30.239060Z 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-11-11T08:18:30.239087Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:31.243780Z 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-11-11T08:18:31.243829Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:32.245017Z 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-11-11T08:18:32.245083Z 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-11-11T08:18:32.245116Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:32.245125Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-11-11T08:18:37.247770Z 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-11-11T08:18:37.247822Z 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-11-11T08:18:37.247839Z 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-11-11T08:18:37.247851Z 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-11-11T08:18:37.247924Z 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-11-11T08:18:37.247951Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:38.254773Z 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-11-11T08:18:38.254827Z 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-11-11T08:18:38.254856Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:39.255917Z 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-11-11T08:18:39.255972Z 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-11-11T08:18:39.256001Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:39.256010Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-11-11T08:18:44.262769Z 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-11-11T08:18:44.262834Z 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-11-11T08:18:44.262849Z 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-11-11T08:18:44.262863Z 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-11-11T08:18:44.262889Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:45.263900Z 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-11-11T08:18:45.263954Z 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-11-11T08:18:45.263978Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:46.264915Z 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-11-11T08:18:46.264971Z 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-11-11T08:18:46.265001Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:46.265010Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-11-11T08:18:51.267752Z 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-11-11T08:18:51.267804Z 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-11-11T08:18:51.267817Z 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-11-11T08:18:51.267829Z 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-11-11T08:18:51.267840Z 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-11-11T08:18:51.267853Z 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-11-11T08:18:51.267878Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:52.268848Z 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-11-11T08:18:52.268900Z 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-11-11T08:18:52.268927Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:53.269889Z 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-11-11T08:18:53.269943Z 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-11-11T08:18:53.269967Z ERROR baichun_framework_rms::message::kafka::consumer: Error while receiving message: Message consumption error: BrokerTransportFailure (Local: Broker transport failure) [INFO] [stdout] 2025-11-11T08:18:53.269975Z  WARN baichun_framework_rms::message::kafka::consumer: Too many consecutive errors (3), attempting to reconnect... [INFO] [stdout] 2025-11-11T08:18:53.298320Z  INFO baichun_framework_rms::message::kafka::consumer::tests: 接收到的消息: [] [INFO] [stdout] [INFO] [stdout] thread 'message::kafka::consumer::tests::test_message_consumption' (25) panicked at src/message/kafka/consumer.rs:823:9: [INFO] [stdout] 没有接收到任何消息 [INFO] [stdout] stack backtrace: [INFO] [stdout] 0: 0x6372cf27ca62 - std::backtrace_rs::backtrace::libunwind::trace::ha50a1f28c7a10cf8 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9 [INFO] [stdout] 1: 0x6372cf27ca62 - std::backtrace_rs::backtrace::trace_unsynchronized::h34f8c4ec82a320bc [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14 [INFO] [stdout] 2: 0x6372cf27ca62 - std::sys::backtrace::_print_fmt::h2d23e84e13d343bc [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/sys/backtrace.rs:66:9 [INFO] [stdout] 3: 0x6372cf27ca62 - ::fmt::hde21067283f7e82e [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/sys/backtrace.rs:39:26 [INFO] [stdout] 4: 0x6372cf28e32f - core::fmt::rt::Argument::fmt::he65307037dca33c6 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/fmt/rt.rs:173:76 [INFO] [stdout] 5: 0x6372cf28e32f - core::fmt::write::h24186904251c31cb [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/fmt/mod.rs:1469:25 [INFO] [stdout] 6: 0x6372cf249e43 - std::io::default_write_fmt::h4e8d11c5c4b9cafe [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/io/mod.rs:639:11 [INFO] [stdout] 7: 0x6372cf249e43 - std::io::Write::write_fmt::ha849be0824d095ef [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/io/mod.rs:1954:13 [INFO] [stdout] 8: 0x6372cf255c62 - std::sys::backtrace::BacktraceLock::print::he038489aba5894a6 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/sys/backtrace.rs:42:9 [INFO] [stdout] 9: 0x6372cf25aa1f - std::panicking::default_hook::{{closure}}::h80a26d916c49679b [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:301:27 [INFO] [stdout] 10: 0x6372cf25a8b1 - std::panicking::default_hook::he2e9efee79b3dce9 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:325:9 [INFO] [stdout] 11: 0x6372cef5693e - as core::ops::function::Fn>::call::h202f496763929329 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/alloc/src/boxed.rs:2099:9 [INFO] [stdout] 12: 0x6372cef5693e - test::test_main_with_exit_callback::{{closure}}::h805a6913adddaea3 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/test/src/lib.rs:145:21 [INFO] [stdout] 13: 0x6372cf25b0df - as core::ops::function::Fn>::call::h2883c9d2dbd4e81c [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/alloc/src/boxed.rs:2099:9 [INFO] [stdout] 14: 0x6372cf25b0df - std::panicking::panic_with_hook::hf5648b7cec6bc73e [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:842:13 [INFO] [stdout] 15: 0x6372cf25ae56 - std::panicking::panic_handler::{{closure}}::h1b2ed3864ba94359 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:700:13 [INFO] [stdout] 16: 0x6372cf255da9 - std::sys::backtrace::__rust_end_short_backtrace::hd0186b2b27f5aaa7 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/sys/backtrace.rs:174:18 [INFO] [stdout] 17: 0x6372cf23e47d - __rustc[f7dae8b92efe1d7a]::rust_begin_unwind [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:698:5 [INFO] [stdout] 18: 0x6372cf296620 - core::panicking::panic_fmt::hb5d6b83773432920 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/panicking.rs:80:14 [INFO] [stdout] 19: 0x6372cee95d2a - baichun_framework_rms::message::kafka::consumer::tests::test_message_consumption::{{closure}}::h792ab77538d4a0b9 [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/consumer.rs:823:9 [INFO] [stdout] 20: 0x6372cee8ec32 - as core::future::future::Future>::poll::h543acc9b5c9b11bc [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/future/future.rs:133:9 [INFO] [stdout] 21: 0x6372cee8eb6d - as core::future::future::Future>::poll::h0a4a440272fc0f50 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/future/future.rs:133:9 [INFO] [stdout] 22: 0x6372ceec19bd - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::{{closure}}::{{closure}}::ha05be36f13c3e6c1 [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: 0x6372ceec18bb - tokio::task::coop::with_budget::h1aa7fc05bd15f516 [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: 0x6372ceec18bb - tokio::task::coop::budget::he51c92951fdd525b [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: 0x6372ceec18bb - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::{{closure}}::h5dec162340c1d6ef [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: 0x6372ceebf050 - tokio::runtime::scheduler::current_thread::Context::enter::hf20686419fe2651e [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: 0x6372ceec0ded - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::hb8da017274e7bece [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: 0x6372ceec0004 - tokio::runtime::scheduler::current_thread::CoreGuard::enter::{{closure}}::he306536ff146351e [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: 0x6372ceeb2d8b - tokio::runtime::context::scoped::Scoped::set::h62e8cb774d4c68d7 [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: 0x6372ceee2c19 - tokio::runtime::context::set_scheduler::{{closure}}::h37bc2e8964c3c9a2 [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: 0x6372ceeed5b2 - std::thread::local::LocalKey::try_with::h84d9b99106d390ef [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/thread/local.rs:508:12 [INFO] [stdout] 32: 0x6372ceeec7ee - std::thread::local::LocalKey::with::h97a0fc173a787ef5 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/thread/local.rs:472:20 [INFO] [stdout] 33: 0x6372ceee2bcd - tokio::runtime::context::set_scheduler::h9fcf876e563cb46d [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: 0x6372ceebf990 - tokio::runtime::scheduler::current_thread::CoreGuard::enter::h2300f13ab7ed3d81 [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: 0x6372ceec0043 - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::h41291df93d5cfba7 [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: 0x6372ceebd580 - tokio::runtime::scheduler::current_thread::CurrentThread::block_on::{{closure}}::h0aae6da9265e4efd [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: 0x6372ceee3380 - tokio::runtime::context::runtime::enter_runtime::h73c3b34924f8f51a [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: 0x6372ceebd291 - tokio::runtime::scheduler::current_thread::CurrentThread::block_on::h9bd4856bebb5af7a [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: 0x6372ceeb2ef4 - tokio::runtime::runtime::Runtime::block_on_inner::h33675667a81e5950 [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: 0x6372ceeb31c7 - tokio::runtime::runtime::Runtime::block_on::h7b5425475556c4b0 [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: 0x6372cee90a23 - baichun_framework_rms::message::kafka::consumer::tests::test_message_consumption::h3633dfe72b3ec5e6 [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/consumer.rs:831:53 [INFO] [stdout] 42: 0x6372cee90ab7 - baichun_framework_rms::message::kafka::consumer::tests::test_message_consumption::{{closure}}::h0b6387cb1714c388 [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/consumer.rs:741:40 [INFO] [stdout] 43: 0x6372ceed35d6 - core::ops::function::FnOnce::call_once::hf345674226dc7d1e [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 44: 0x6372cef567ab - core::ops::function::FnOnce::call_once::h3a2d82edd1a9b770 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 45: 0x6372cef567ab - test::__rust_begin_short_backtrace::h85d4fe5033219107 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/test/src/lib.rs:663:18 [INFO] [stdout] 46: 0x6372cef6a79d - test::run_test_in_process::{{closure}}::h67b48a81b9c9d7b6 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/test/src/lib.rs:686:74 [INFO] [stdout] 47: 0x6372cef6a79d - as core::ops::function::FnOnce<()>>::call_once::h7680585480377cb5 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/panic/unwind_safe.rs:274:9 [INFO] [stdout] 48: 0x6372cef6a79d - std::panicking::catch_unwind::do_call::hf71351b2657d4002 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:590:40 [INFO] [stdout] 49: 0x6372cef6a79d - std::panicking::catch_unwind::h7fcb5c0312d9e172 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:553:19 [INFO] [stdout] 50: 0x6372cef6a79d - std::panic::catch_unwind::h5cf3c9bdee894ebe [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panic.rs:359:14 [INFO] [stdout] 51: 0x6372cef6a79d - test::run_test_in_process::h1469cb85193a3a25 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/test/src/lib.rs:686:27 [INFO] [stdout] 52: 0x6372cef6a79d - test::run_test::{{closure}}::h59d45b3cd6453d69 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/test/src/lib.rs:607:43 [INFO] [stdout] 53: 0x6372cef43ce4 - test::run_test::{{closure}}::h9baa0c3d443f28c9 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/test/src/lib.rs:637:41 [INFO] [stdout] 54: 0x6372cef43ce4 - std::sys::backtrace::__rust_begin_short_backtrace::h97ea8cee4828663e [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/sys/backtrace.rs:158:18 [INFO] [stdout] 55: 0x6372cef4753a - std::thread::Builder::spawn_unchecked_::{{closure}}::{{closure}}::h5d7539d5f78cee61 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/thread/mod.rs:562:17 [INFO] [stdout] 56: 0x6372cef4753a - as core::ops::function::FnOnce<()>>::call_once::he4c551e23c5e9b22 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/panic/unwind_safe.rs:274:9 [INFO] [stdout] 57: 0x6372cef4753a - std::panicking::catch_unwind::do_call::h522b41a6c157aaba [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:590:40 [INFO] [stdout] 58: 0x6372cef4753a - std::panicking::catch_unwind::h0efbf72006b8e365 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:553:19 [INFO] [stdout] 59: 0x6372cef4753a - std::panic::catch_unwind::h3b081041e6c97066 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panic.rs:359:14 [INFO] [stdout] 60: 0x6372cef4753a - std::thread::Builder::spawn_unchecked_::{{closure}}::ha751309815d5d8cf [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/thread/mod.rs:560:30 [INFO] [stdout] 61: 0x6372cef4753a - core::ops::function::FnOnce::call_once{{vtable.shim}}::h2084b887a5fe25a7 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 62: 0x6372cf25119f - as core::ops::function::FnOnce>::call_once::h3adbd6ccf5f737af [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/alloc/src/boxed.rs:2085:9 [INFO] [stdout] 63: 0x6372cf25119f - std::sys::thread::unix::Thread::new::thread_start::hb3dc6483caa1b987 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/sys/thread/unix.rs:124:17 [INFO] [stdout] 64: 0x7525bd5c3aa4 - [INFO] [stdout] 65: 0x7525bd650a64 - clone [INFO] [stdout] 66: 0x0 - [INFO] [stdout] 2025-11-11T08:18:53.480227Z 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] [INFO] [stdout] ---- message::kafka::producer::tests::test_message_production stdout ---- [INFO] [stdout] 2025-11-11T08:18:13.233033Z  INFO baichun_framework_rms::message::kafka::producer::tests: 生产者创建成功 [INFO] [stdout] 2025-11-11T08:18:13.233069Z  INFO baichun_framework_rms::message::kafka::producer::tests: 开始发送消息到主题: test-topic [INFO] [stdout] 2025-11-11T08:18:13.233106Z  INFO baichun_framework_rms::message::kafka::producer::tests: 发送消息 1: 测试消息1 [INFO] [stdout] 2025-11-11T08:18:13.233226Z DEBUG librdkafka: librdkafka: WAKEUPFD [thrd:app]: localhost:9092/bootstrap: Enabled low-latency ops queue wake-ups [INFO] [stdout] 2025-11-11T08:18:13.233253Z DEBUG librdkafka: librdkafka: BRKMAIN [thrd::0/internal]: :0/internal: Enter main broker thread [INFO] [stdout] 2025-11-11T08:18:13.233263Z DEBUG librdkafka: librdkafka: BROKER [thrd:app]: localhost:9092/bootstrap: Added new broker with NodeId -1 [INFO] [stdout] 2025-11-11T08:18:13.233272Z 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-11-11T08:18:13.233280Z 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-11-11T08:18:13.233289Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: Client configuration: [INFO] [stdout] 2025-11-11T08:18:13.233297Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: client.software.version = 2.3.0 [INFO] [stdout] 2025-11-11T08:18:13.233304Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: metadata.broker.list = localhost:9092 [INFO] [stdout] 2025-11-11T08:18:13.233312Z 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-11-11T08:18:13.233320Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: enabled_events = 329 [INFO] [stdout] 2025-11-11T08:18:13.233328Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: log.queue = true [INFO] [stdout] 2025-11-11T08:18:13.233340Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: opaque = 0x7525b0006a50 [INFO] [stdout] 2025-11-11T08:18:13.233348Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: default_topic_conf = 0x7525b0006a80 [INFO] [stdout] 2025-11-11T08:18:13.233356Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: Default topic configuration: [INFO] [stdout] 2025-11-11T08:18:13.233365Z DEBUG librdkafka: librdkafka: CONF [thrd:app]: message.timeout.ms = 30000 [INFO] [stdout] 2025-11-11T08:18:13.233405Z DEBUG librdkafka: librdkafka: BRKMAIN [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Enter main broker thread [INFO] [stdout] 2025-11-11T08:18:13.236694Z ERROR librdkafka: librdkafka: FAIL [thrd:localhost:9092/bootstrap]: localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 3ms in state CONNECT) [INFO] [stdout] 2025-11-11T08:18:13.236723Z ERROR rdkafka::client: librdkafka: Global error: BrokerTransportFailure (Local: Broker transport failure): localhost:9092/bootstrap: Connect to ipv6#[::1]:9092 failed: Connection refused (after 3ms in state CONNECT) [INFO] [stdout] 2025-11-11T08:18:13.236742Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:13.236751Z ERROR rdkafka::client: librdkafka: Global error: AllBrokersDown (Local: All broker connections are down): 1/1 brokers are down [INFO] [stdout] 2025-11-11T08:18:13.236759Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:14.233146Z 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-11-11T08:18:14.233207Z 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-11-11T08:18:14.233227Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:15.233250Z 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-11-11T08:18:15.233295Z 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-11-11T08:18:15.233313Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:16.233414Z 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-11-11T08:18:16.233454Z 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-11-11T08:18:16.233470Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:17.234917Z 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-11-11T08:18:17.234964Z 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-11-11T08:18:17.234980Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:19.238912Z 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-11-11T08:18:19.238956Z 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-11-11T08:18:19.238972Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:20.239096Z 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-11-11T08:18:20.239138Z 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-11-11T08:18:20.239154Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:21.238968Z 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-11-11T08:18:21.239016Z 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-11-11T08:18:21.239033Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:22.241690Z 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-11-11T08:18:22.241734Z 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-11-11T08:18:22.241751Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:23.239003Z 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-11-11T08:18:23.239055Z 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-11-11T08:18:23.239072Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:25.239013Z 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-11-11T08:18:25.239056Z 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-11-11T08:18:25.239073Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:26.242693Z 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-11-11T08:18:26.242739Z 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-11-11T08:18:26.242765Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:27.238997Z 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-11-11T08:18:27.239042Z 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-11-11T08:18:27.239059Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:28.239292Z 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-11-11T08:18:28.239335Z 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-11-11T08:18:28.239351Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:29.239052Z 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-11-11T08:18:29.239095Z 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-11-11T08:18:29.239110Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:32.258100Z 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-11-11T08:18:32.258148Z 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-11-11T08:18:32.258165Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:33.255058Z 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-11-11T08:18:33.255104Z 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-11-11T08:18:33.255121Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:34.262095Z 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-11-11T08:18:34.262145Z 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-11-11T08:18:34.262164Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:36.254952Z 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-11-11T08:18:36.254996Z 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-11-11T08:18:36.255013Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:38.260695Z 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-11-11T08:18:38.260753Z 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-11-11T08:18:38.260769Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:39.266071Z 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-11-11T08:18:39.266112Z 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-11-11T08:18:39.266127Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stderr] error: test failed, to rerun pass `--lib` [INFO] [stdout] 2025-11-11T08:18:40.258942Z 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-11-11T08:18:40.258990Z 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-11-11T08:18:40.259009Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:43.270667Z 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-11-11T08:18:43.270711Z 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-11-11T08:18:43.270728Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:44.273970Z 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-11-11T08:18:44.274016Z 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-11-11T08:18:44.274039Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:45.273899Z 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-11-11T08:18:45.273952Z 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-11-11T08:18:45.273969Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:47.273934Z 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-11-11T08:18:47.273980Z 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-11-11T08:18:47.273996Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:48.274015Z 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-11-11T08:18:48.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, 1 identical error(s) suppressed) [INFO] [stdout] 2025-11-11T08:18:48.274072Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:49.274017Z 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-11-11T08:18:49.274060Z 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-11-11T08:18:49.274075Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:51.279665Z 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-11-11T08:18:51.279703Z 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-11-11T08:18:51.279717Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:52.274402Z 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-11-11T08:18:52.274446Z 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-11-11T08:18:52.274465Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:53.274254Z 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-11-11T08:18:53.274294Z 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-11-11T08:18:53.274309Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:54.274447Z 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-11-11T08:18:54.274492Z 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-11-11T08:18:54.274509Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:55.274265Z 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-11-11T08:18:55.274306Z 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-11-11T08:18:55.274321Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:56.274461Z 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-11-11T08:18:56.274506Z 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-11-11T08:18:56.274523Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:57.274311Z 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-11-11T08:18:57.274357Z 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-11-11T08:18:57.274373Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:58.274500Z 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-11-11T08:18:58.274541Z 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-11-11T08:18:58.274556Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:18:59.277681Z 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-11-11T08:18:59.277727Z 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-11-11T08:18:59.277745Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:19:01.274493Z 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-11-11T08:19:01.274535Z 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-11-11T08:19:01.274550Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:19:04.284938Z 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-11-11T08:19:04.284987Z 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-11-11T08:19:04.285006Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:19:05.285115Z 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-11-11T08:19:05.285162Z 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-11-11T08:19:05.285182Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:19:06.284944Z 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-11-11T08:19:06.284989Z 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-11-11T08:19:06.285005Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:19:08.285085Z 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-11-11T08:19:08.285125Z 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-11-11T08:19:08.285141Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:19:09.285288Z 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-11-11T08:19:09.285328Z 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-11-11T08:19:09.285343Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:19:10.285191Z 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-11-11T08:19:10.285235Z 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-11-11T08:19:10.285251Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:19:11.286568Z 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-11-11T08:19:11.286728Z 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-11-11T08:19:11.286748Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:19:12.285281Z 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-11-11T08:19:12.285324Z 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-11-11T08:19:12.285340Z  WARN rdkafka::producer::base_producer: Ignored event 'Error' on base producer poll [INFO] [stdout] 2025-11-11T08:19:13.338953Z 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' (26) 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: 0x6372cf27ca62 - std::backtrace_rs::backtrace::libunwind::trace::ha50a1f28c7a10cf8 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/../../backtrace/src/backtrace/libunwind.rs:117:9 [INFO] [stdout] 1: 0x6372cf27ca62 - std::backtrace_rs::backtrace::trace_unsynchronized::h34f8c4ec82a320bc [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/../../backtrace/src/backtrace/mod.rs:66:14 [INFO] [stdout] 2: 0x6372cf27ca62 - std::sys::backtrace::_print_fmt::h2d23e84e13d343bc [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/sys/backtrace.rs:66:9 [INFO] [stdout] 3: 0x6372cf27ca62 - ::fmt::hde21067283f7e82e [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/sys/backtrace.rs:39:26 [INFO] [stdout] 4: 0x6372cf28e32f - core::fmt::rt::Argument::fmt::he65307037dca33c6 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/fmt/rt.rs:173:76 [INFO] [stdout] 5: 0x6372cf28e32f - core::fmt::write::h24186904251c31cb [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/fmt/mod.rs:1469:25 [INFO] [stdout] 6: 0x6372cf249e43 - std::io::default_write_fmt::h4e8d11c5c4b9cafe [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/io/mod.rs:639:11 [INFO] [stdout] 7: 0x6372cf249e43 - std::io::Write::write_fmt::ha849be0824d095ef [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/io/mod.rs:1954:13 [INFO] [stdout] 8: 0x6372cf255c62 - std::sys::backtrace::BacktraceLock::print::he038489aba5894a6 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/sys/backtrace.rs:42:9 [INFO] [stdout] 9: 0x6372cf25aa1f - std::panicking::default_hook::{{closure}}::h80a26d916c49679b [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:301:27 [INFO] [stdout] 10: 0x6372cf25a8b1 - std::panicking::default_hook::he2e9efee79b3dce9 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:325:9 [INFO] [stdout] 11: 0x6372cef5693e - as core::ops::function::Fn>::call::h202f496763929329 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/alloc/src/boxed.rs:2099:9 [INFO] [stdout] 12: 0x6372cef5693e - test::test_main_with_exit_callback::{{closure}}::h805a6913adddaea3 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/test/src/lib.rs:145:21 [INFO] [stdout] 13: 0x6372cf25b0df - as core::ops::function::Fn>::call::h2883c9d2dbd4e81c [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/alloc/src/boxed.rs:2099:9 [INFO] [stdout] 14: 0x6372cf25b0df - std::panicking::panic_with_hook::hf5648b7cec6bc73e [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:842:13 [INFO] [stdout] 15: 0x6372cf25ae8a - std::panicking::panic_handler::{{closure}}::h1b2ed3864ba94359 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:707:13 [INFO] [stdout] 16: 0x6372cf255da9 - std::sys::backtrace::__rust_end_short_backtrace::hd0186b2b27f5aaa7 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/sys/backtrace.rs:174:18 [INFO] [stdout] 17: 0x6372cf23e47d - __rustc[f7dae8b92efe1d7a]::rust_begin_unwind [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:698:5 [INFO] [stdout] 18: 0x6372cf296620 - core::panicking::panic_fmt::hb5d6b83773432920 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/panicking.rs:80:14 [INFO] [stdout] 19: 0x6372ceee0307 - baichun_framework_rms::message::kafka::producer::tests::test_message_production::{{closure}}::ha683e3fd7c744774 [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/producer.rs:193:21 [INFO] [stdout] 20: 0x6372cee8ec32 - as core::future::future::Future>::poll::h543acc9b5c9b11bc [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/future/future.rs:133:9 [INFO] [stdout] 21: 0x6372cee8eb6d - as core::future::future::Future>::poll::h0a4a440272fc0f50 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/future/future.rs:133:9 [INFO] [stdout] 22: 0x6372ceec19bd - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::{{closure}}::{{closure}}::ha05be36f13c3e6c1 [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: 0x6372ceec18bb - tokio::task::coop::with_budget::h1aa7fc05bd15f516 [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: 0x6372ceec18bb - tokio::task::coop::budget::he51c92951fdd525b [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: 0x6372ceec18bb - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::{{closure}}::h5dec162340c1d6ef [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: 0x6372ceebf050 - tokio::runtime::scheduler::current_thread::Context::enter::hf20686419fe2651e [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: 0x6372ceec0ded - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::{{closure}}::hb8da017274e7bece [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: 0x6372ceec0004 - tokio::runtime::scheduler::current_thread::CoreGuard::enter::{{closure}}::he306536ff146351e [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: 0x6372ceeb2d8b - tokio::runtime::context::scoped::Scoped::set::h62e8cb774d4c68d7 [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: 0x6372ceee2c19 - tokio::runtime::context::set_scheduler::{{closure}}::h37bc2e8964c3c9a2 [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: 0x6372ceeed5b2 - std::thread::local::LocalKey::try_with::h84d9b99106d390ef [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/thread/local.rs:508:12 [INFO] [stdout] 32: 0x6372ceeec7ee - std::thread::local::LocalKey::with::h97a0fc173a787ef5 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/thread/local.rs:472:20 [INFO] [stdout] 33: 0x6372ceee2bcd - tokio::runtime::context::set_scheduler::h9fcf876e563cb46d [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: 0x6372ceebf990 - tokio::runtime::scheduler::current_thread::CoreGuard::enter::h2300f13ab7ed3d81 [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: 0x6372ceec0043 - tokio::runtime::scheduler::current_thread::CoreGuard::block_on::h41291df93d5cfba7 [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: 0x6372ceebd580 - tokio::runtime::scheduler::current_thread::CurrentThread::block_on::{{closure}}::h0aae6da9265e4efd [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: 0x6372ceee3380 - tokio::runtime::context::runtime::enter_runtime::h73c3b34924f8f51a [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: 0x6372ceebd291 - tokio::runtime::scheduler::current_thread::CurrentThread::block_on::h9bd4856bebb5af7a [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: 0x6372ceeb2ef4 - tokio::runtime::runtime::Runtime::block_on_inner::h33675667a81e5950 [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: 0x6372ceeb31c7 - tokio::runtime::runtime::Runtime::block_on::h7b5425475556c4b0 [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: 0x6372ceeda033 - baichun_framework_rms::message::kafka::producer::tests::test_message_production::hccd73ce420016e50 [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/producer.rs:203:57 [INFO] [stdout] 42: 0x6372ceee04c7 - baichun_framework_rms::message::kafka::producer::tests::test_message_production::{{closure}}::hc40146db3ed03ebc [INFO] [stdout] at /opt/rustwide/workdir/src/message/kafka/producer.rs:147:39 [INFO] [stdout] 43: 0x6372ceed2dc6 - core::ops::function::FnOnce::call_once::h3118c661315b10b3 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 44: 0x6372cef567ab - core::ops::function::FnOnce::call_once::h3a2d82edd1a9b770 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 45: 0x6372cef567ab - test::__rust_begin_short_backtrace::h85d4fe5033219107 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/test/src/lib.rs:663:18 [INFO] [stdout] 46: 0x6372cef6a79d - test::run_test_in_process::{{closure}}::h67b48a81b9c9d7b6 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/test/src/lib.rs:686:74 [INFO] [stdout] 47: 0x6372cef6a79d - as core::ops::function::FnOnce<()>>::call_once::h7680585480377cb5 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/panic/unwind_safe.rs:274:9 [INFO] [stdout] 48: 0x6372cef6a79d - std::panicking::catch_unwind::do_call::hf71351b2657d4002 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:590:40 [INFO] [stdout] 49: 0x6372cef6a79d - std::panicking::catch_unwind::h7fcb5c0312d9e172 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:553:19 [INFO] [stdout] 50: 0x6372cef6a79d - std::panic::catch_unwind::h5cf3c9bdee894ebe [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panic.rs:359:14 [INFO] [stdout] 51: 0x6372cef6a79d - test::run_test_in_process::h1469cb85193a3a25 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/test/src/lib.rs:686:27 [INFO] [stdout] 52: 0x6372cef6a79d - test::run_test::{{closure}}::h59d45b3cd6453d69 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/test/src/lib.rs:607:43 [INFO] [stdout] 53: 0x6372cef43ce4 - test::run_test::{{closure}}::h9baa0c3d443f28c9 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/test/src/lib.rs:637:41 [INFO] [stdout] 54: 0x6372cef43ce4 - std::sys::backtrace::__rust_begin_short_backtrace::h97ea8cee4828663e [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/sys/backtrace.rs:158:18 [INFO] [stdout] 55: 0x6372cef4753a - std::thread::Builder::spawn_unchecked_::{{closure}}::{{closure}}::h5d7539d5f78cee61 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/thread/mod.rs:562:17 [INFO] [stdout] 56: 0x6372cef4753a - as core::ops::function::FnOnce<()>>::call_once::he4c551e23c5e9b22 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/panic/unwind_safe.rs:274:9 [INFO] [stdout] 57: 0x6372cef4753a - std::panicking::catch_unwind::do_call::h522b41a6c157aaba [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:590:40 [INFO] [stdout] 58: 0x6372cef4753a - std::panicking::catch_unwind::h0efbf72006b8e365 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panicking.rs:553:19 [INFO] [stdout] 59: 0x6372cef4753a - std::panic::catch_unwind::h3b081041e6c97066 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/panic.rs:359:14 [INFO] [stdout] 60: 0x6372cef4753a - std::thread::Builder::spawn_unchecked_::{{closure}}::ha751309815d5d8cf [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/thread/mod.rs:560:30 [INFO] [stdout] 61: 0x6372cef4753a - core::ops::function::FnOnce::call_once{{vtable.shim}}::h2084b887a5fe25a7 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/core/src/ops/function.rs:250:5 [INFO] [stdout] 62: 0x6372cf25119f - as core::ops::function::FnOnce>::call_once::h3adbd6ccf5f737af [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/alloc/src/boxed.rs:2085:9 [INFO] [stdout] 63: 0x6372cf25119f - std::sys::thread::unix::Thread::new::thread_start::hb3dc6483caa1b987 [INFO] [stdout] at /rustc/c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38/library/std/src/sys/thread/unix.rs:124:17 [INFO] [stdout] 64: 0x7525bd5c3aa4 - [INFO] [stdout] 65: 0x7525bd650a64 - 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.18s [INFO] [stdout] [INFO] running `Command { std: "docker" "inspect" "a4dd088a299e4e357c123249aca1965c11b7be11086466be68313948d50007ac", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "a4dd088a299e4e357c123249aca1965c11b7be11086466be68313948d50007ac", kill_on_drop: false }` [INFO] [stdout] a4dd088a299e4e357c123249aca1965c11b7be11086466be68313948d50007ac