[INFO] fetching crate kafka-threadpool 1.0.12...
[INFO] testing kafka-threadpool-1.0.12 against 1.75.0 for beta-1.76-1
[INFO] extracting crate kafka-threadpool 1.0.12 into /workspace/builds/worker-5-tc1/source
[INFO] validating manifest of crates.io crate kafka-threadpool 1.0.12 on toolchain 1.75.0
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.75.0" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking crates.io crate kafka-threadpool 1.0.12
[INFO] finished tweaking crates.io crate kafka-threadpool 1.0.12
[INFO] tweaked toml for crates.io crate kafka-threadpool 1.0.12 written to /workspace/builds/worker-5-tc1/source/Cargo.toml
[INFO] crate crates.io crate kafka-threadpool 1.0.12 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" "+1.75.0" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Updating crates.io index
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded futures-macro v0.3.24
[INFO] [stderr]   Downloaded rdkafka v0.28.0
[INFO] [stderr]   Downloaded syn v1.0.100
[INFO] [stderr]   Downloaded tokio v1.21.1
[INFO] [stderr]   Downloaded libc v0.2.133
[INFO] [stderr]   Downloaded openssl-src v111.22.0+1.1.1q
[INFO] [stderr]   Downloaded rdkafka-sys v4.2.0+1.8.2
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+1.75.0" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 6e4be0d0f41ac6e5d87184158adb7581dc212ba8eef9fef6544e2d2c40acbc85
[INFO] running `Command { std: "docker" "start" "-a" "6e4be0d0f41ac6e5d87184158adb7581dc212ba8eef9fef6544e2d2c40acbc85", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "6e4be0d0f41ac6e5d87184158adb7581dc212ba8eef9fef6544e2d2c40acbc85", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "6e4be0d0f41ac6e5d87184158adb7581dc212ba8eef9fef6544e2d2c40acbc85", kill_on_drop: false }`
[INFO] [stdout] 6e4be0d0f41ac6e5d87184158adb7581dc212ba8eef9fef6544e2d2c40acbc85
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-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:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+1.75.0" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 93b139fdb01f1b6c9d304fc267eda272e45aea7b28fe10c9460e3829b7b2d66e
[INFO] running `Command { std: "docker" "start" "-a" "93b139fdb01f1b6c9d304fc267eda272e45aea7b28fe10c9460e3829b7b2d66e", kill_on_drop: false }`
[INFO] [stderr]    Compiling unicode-ident v1.0.4
[INFO] [stderr]    Compiling syn v1.0.100
[INFO] [stderr]    Compiling cc v1.0.73
[INFO] [stderr]    Compiling libc v0.2.133
[INFO] [stderr]    Compiling pkg-config v0.3.25
[INFO] [stderr]    Compiling serde v1.0.144
[INFO] [stderr]    Compiling thiserror v1.0.35
[INFO] [stderr]    Compiling futures-core v0.3.24
[INFO] [stderr]    Compiling proc-macro2 v1.0.43
[INFO] [stderr]    Compiling futures-channel v0.3.24
[INFO] [stderr]    Compiling once_cell v1.14.0
[INFO] [stderr]    Compiling futures-task v0.3.24
[INFO] [stderr]    Compiling quote v1.0.21
[INFO] [stderr]    Compiling openssl-src v111.22.0+1.1.1q
[INFO] [stderr]    Compiling futures-util v0.3.24
[INFO] [stderr]    Compiling futures-sink v0.3.24
[INFO] [stderr]    Compiling serde_derive v1.0.144
[INFO] [stderr]    Compiling cmake v0.1.48
[INFO] [stderr]    Compiling futures-io v0.3.24
[INFO] [stderr]    Compiling aho-corasick v0.7.19
[INFO] [stderr]    Compiling tokio v1.21.1
[INFO] [stderr]    Compiling quick-error v1.2.3
[INFO] [stderr]    Compiling openssl-sys v0.9.75
[INFO] [stderr]    Compiling libz-sys v1.1.8
[INFO] [stderr]    Compiling rdkafka-sys v4.2.0+1.8.2
[INFO] [stderr]    Compiling serde_json v1.0.85
[INFO] [stderr]    Compiling humantime v1.3.0
[INFO] [stderr]    Compiling atty v0.2.14
[INFO] [stderr]    Compiling num_cpus v1.13.1
[INFO] [stderr]    Compiling regex v1.6.0
[INFO] [stderr]    Compiling env_logger v0.7.1
[INFO] [stderr]    Compiling pretty_env_logger v0.4.0
[INFO] [stderr]    Compiling toml v0.5.9
[INFO] [stderr]    Compiling thiserror-impl v1.0.35
[INFO] [stderr]    Compiling futures-macro v0.3.24
[INFO] [stderr]    Compiling proc-macro-crate v1.2.1
[INFO] [stderr]    Compiling num_enum_derive v0.5.7
[INFO] [stderr]    Compiling num_enum v0.5.7
[INFO] [stderr]    Compiling tokio-macros v1.8.0
[INFO] [stderr]    Compiling futures-executor v0.3.24
[INFO] [stderr]    Compiling futures v0.3.24
[INFO] [stderr]    Compiling rdkafka v0.28.0
[INFO] [stderr]    Compiling kafka-threadpool v1.0.12 (/opt/rustwide/workdir)
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 35.14s
[INFO] running `Command { std: "docker" "inspect" "93b139fdb01f1b6c9d304fc267eda272e45aea7b28fe10c9460e3829b7b2d66e", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "93b139fdb01f1b6c9d304fc267eda272e45aea7b28fe10c9460e3829b7b2d66e", kill_on_drop: false }`
[INFO] [stdout] 93b139fdb01f1b6c9d304fc267eda272e45aea7b28fe10c9460e3829b7b2d66e
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-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:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+1.75.0" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 8d00e35c9c3806537497133af531bcd0b0b7024dda545b02562eeade05e6fefc
[INFO] running `Command { std: "docker" "start" "-a" "8d00e35c9c3806537497133af531bcd0b0b7024dda545b02562eeade05e6fefc", kill_on_drop: false }`
[INFO] [stderr]    Compiling kafka-threadpool v1.0.12 (/opt/rustwide/workdir)
[INFO] [stderr]     Finished test [unoptimized + debuginfo] target(s) in 1.62s
[INFO] running `Command { std: "docker" "inspect" "8d00e35c9c3806537497133af531bcd0b0b7024dda545b02562eeade05e6fefc", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "8d00e35c9c3806537497133af531bcd0b0b7024dda545b02562eeade05e6fefc", kill_on_drop: false }`
[INFO] [stdout] 8d00e35c9c3806537497133af531bcd0b0b7024dda545b02562eeade05e6fefc
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-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:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+1.75.0" "test" "--frozen", kill_on_drop: false }`
[INFO] [stdout] fb87c94a3fa45293d33d73ece2be518008f41c738511d6180624688f488df637
[INFO] running `Command { std: "docker" "start" "-a" "fb87c94a3fa45293d33d73ece2be518008f41c738511d6180624688f488df637", kill_on_drop: false }`
[INFO] [stderr]     Finished test [unoptimized + debuginfo] target(s) in 0.04s
[INFO] [stderr]      Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/kafka_threadpool-0e1616a27dd33fc0)
[INFO] [stdout] 
[INFO] [stdout] running 0 tests
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s
[INFO] [stdout] 
[INFO] [stderr]    Doc-tests kafka_threadpool
[INFO] [stdout] 
[INFO] [stdout] running 8 tests
[INFO] [stdout] test src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::new (line 56) ... FAILED
[INFO] [stdout] test src/api/build_kafka_publish_message.rs - api::build_kafka_publish_message::build_kafka_publish_message (line 25) ... FAILED
[INFO] [stdout] test src/api/build_kafka_client_config.rs - api::build_kafka_client_config::build_kafka_client_config (line 33) ... FAILED
[INFO] [stdout] test src/kafka_publisher.rs - kafka_publisher (line 11) ... FAILED
[INFO] [stdout] test src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::shutdown (line 230) ... FAILED
[INFO] [stdout] test src/start_threadpool.rs - start_threadpool::start_threadpool (line 20) ... FAILED
[INFO] [stdout] test src/pool/start_threads_from_config.rs - pool::start_threads_from_config::start_threads_from_config (line 21) ... FAILED
[INFO] [stdout] test src/api/kafka_publish_message.rs - api::kafka_publish_message::KafkaPublishMessage::new_from (line 69) ... ok
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout] 
[INFO] [stdout] ---- src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::new (line 56) stdout ----
[INFO] [stdout] error[E0432]: unresolved import `crate::kafka_publisher`
[INFO] [stdout]  --> src/kafka_publisher.rs:57:12
[INFO] [stdout]   |
[INFO] [stdout] 3 | use crate::kafka_publisher::KafkaPublisher;
[INFO] [stdout]   |            ^^^^^^^^^^^^^^^
[INFO] [stdout]   |            |
[INFO] [stdout]   |            unresolved import
[INFO] [stdout]   |            help: a similar path exists: `kafka_threadpool::kafka_publisher`
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to previous error
[INFO] [stdout] 
[INFO] [stdout] For more information about this error, try `rustc --explain E0432`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/api/build_kafka_publish_message.rs - api::build_kafka_publish_message::build_kafka_publish_message (line 25) stdout ----
[INFO] [stdout] error[E0412]: cannot find type `KafkaPublishMessage` in this scope
[INFO] [stdout]   --> src/api/build_kafka_publish_message.rs:32:14
[INFO] [stdout]    |
[INFO] [stdout] 10 | let new_msg: KafkaPublishMessage = build_kafka_publish_message(
[INFO] [stdout]    |              ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]   ::: /opt/rustwide/workdir/src/api/kafka_publish_message_type.rs:20:1
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub enum KafkaPublishMessageType {
[INFO] [stdout]    | -------------------------------- similarly named enum `KafkaPublishMessageType` defined here
[INFO] [stdout]    |
[INFO] [stdout] help: an enum with a similar name exists
[INFO] [stdout]    |
[INFO] [stdout] 10 | let new_msg: KafkaPublishMessageType = build_kafka_publish_message(
[INFO] [stdout]    |              ~~~~~~~~~~~~~~~~~~~~~~~
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 2  + use kafka_threadpool::api::kafka_publish_message::KafkaPublishMessage;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to previous error
[INFO] [stdout] 
[INFO] [stdout] For more information about this error, try `rustc --explain E0412`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/api/build_kafka_client_config.rs - api::build_kafka_client_config::build_kafka_client_config (line 33) stdout ----
[INFO] [stdout] error: expected `;`, found `}`
[INFO] [stdout]  --> src/api/build_kafka_client_config.rs:36:71
[INFO] [stdout]   |
[INFO] [stdout] 6 | let kafka_config: KafkaClientConfig = build_kafka_client_config("ktp")
[INFO] [stdout]   |                                                                       ^ help: add `;` here
[INFO] [stdout] 7 | } _doctest_main_src_api_build_kafka_client_config_rs_33_0() }
[INFO] [stdout]   | - unexpected token
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `kafka_threadpool::config::kafka_client_config::build_kafka_client_config`
[INFO] [stdout]  --> src/api/build_kafka_client_config.rs:35:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use kafka_threadpool::config::kafka_client_config::build_kafka_client_config;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no `build_kafka_client_config` in `config::kafka_client_config`
[INFO] [stdout]   |
[INFO] [stdout] help: consider importing this module instead
[INFO] [stdout]   |
[INFO] [stdout] 5 | use kafka_threadpool::api::build_kafka_client_config;
[INFO] [stdout]   |     ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `KafkaClientConfig` in this scope
[INFO] [stdout]  --> src/api/build_kafka_client_config.rs:36:19
[INFO] [stdout]   |
[INFO] [stdout] 6 | let kafka_config: KafkaClientConfig = build_kafka_client_config("ktp")
[INFO] [stdout]   |                   ^^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]   |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]   |
[INFO] [stdout] 2 + use kafka_threadpool::config::kafka_client_config::KafkaClientConfig;
[INFO] [stdout]   |
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 3 previous errors
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0412, E0432.
[INFO] [stdout] For more information about an error, try `rustc --explain E0412`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/kafka_publisher.rs - kafka_publisher (line 11) stdout ----
[INFO] [stdout] error[E0425]: cannot find value `my_kafka_publisher` in this scope
[INFO] [stdout]  --> src/kafka_publisher.rs:12:1
[INFO] [stdout]   |
[INFO] [stdout] 3 | my_kafka_publisher.shutdown().await.unwrap();
[INFO] [stdout]   | ^^^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks
[INFO] [stdout]  --> src/kafka_publisher.rs:12:31
[INFO] [stdout]   |
[INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_kafka_publisher_rs_11_0() {
[INFO] [stdout]   |                                         ----------------------------------------- this is not `async`
[INFO] [stdout] 3 | my_kafka_publisher.shutdown().await.unwrap();
[INFO] [stdout]   |                               ^^^^^ only allowed inside `async` functions and blocks
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 2 previous errors
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0425, E0728.
[INFO] [stdout] For more information about an error, try `rustc --explain E0425`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::shutdown (line 230) stdout ----
[INFO] [stdout] error[E0425]: cannot find value `my_threadpool` in this scope
[INFO] [stdout]  --> src/kafka_publisher.rs:231:1
[INFO] [stdout]   |
[INFO] [stdout] 3 | my_threadpool.shutdown().await.unwrap();
[INFO] [stdout]   | ^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks
[INFO] [stdout]  --> src/kafka_publisher.rs:231:26
[INFO] [stdout]   |
[INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_kafka_publisher_rs_230_0() {
[INFO] [stdout]   |                                         ------------------------------------------ this is not `async`
[INFO] [stdout] 3 | my_threadpool.shutdown().await.unwrap();
[INFO] [stdout]   |                          ^^^^^ only allowed inside `async` functions and blocks
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 2 previous errors
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0425, E0728.
[INFO] [stdout] For more information about an error, try `rustc --explain E0425`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/start_threadpool.rs - start_threadpool::start_threadpool (line 20) stdout ----
[INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks
[INFO] [stdout]  --> src/start_threadpool.rs:24:51
[INFO] [stdout]   |
[INFO] [stdout] 4 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_start_threadpool_rs_20_0() {
[INFO] [stdout]   |                                         ------------------------------------------ this is not `async`
[INFO] [stdout] ...
[INFO] [stdout] 7 | let kafka_publisher = start_threadpool(log_label).await;
[INFO] [stdout]   |                                                   ^^^^^ only allowed inside `async` functions and blocks
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/start_threadpool.rs:24:40
[INFO] [stdout]    |
[INFO] [stdout] 7  | let kafka_publisher = start_threadpool(log_label).await;
[INFO] [stdout]    |                       ---------------- ^^^^^^^^^ expected `Option<&str>`, found `&str`
[INFO] [stdout]    |                       |
[INFO] [stdout]    |                       arguments to this function are incorrect
[INFO] [stdout]    |
[INFO] [stdout]    = note:   expected enum `Option<&str>`
[INFO] [stdout]            found reference `&str`
[INFO] [stdout] note: function defined here
[INFO] [stdout]   --> /opt/rustwide/workdir/src/start_threadpool.rs:26:14
[INFO] [stdout]    |
[INFO] [stdout] 26 | pub async fn start_threadpool(label: Option<&str>) -> KafkaPublisher {
[INFO] [stdout]    |              ^^^^^^^^^^^^^^^^
[INFO] [stdout] help: try wrapping the expression in `Some`
[INFO] [stdout]    |
[INFO] [stdout] 7  | let kafka_publisher = start_threadpool(Some(log_label)).await;
[INFO] [stdout]    |                                        +++++         +
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 2 previous errors
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0308, E0728.
[INFO] [stdout] For more information about an error, try `rustc --explain E0308`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/pool/start_threads_from_config.rs - pool::start_threads_from_config::start_threads_from_config (line 21) stdout ----
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/pool/start_threads_from_config.rs:26:55
[INFO] [stdout]    |
[INFO] [stdout] 8  | let kafka_publisher = match start_threads_from_config(&config) {
[INFO] [stdout]    |                             ------------------------- ^^^^^^^ expected `KafkaClientConfig`, found `&KafkaClientConfig`
[INFO] [stdout]    |                             |
[INFO] [stdout]    |                             arguments to this function are incorrect
[INFO] [stdout]    |
[INFO] [stdout] note: function defined here
[INFO] [stdout]   --> /opt/rustwide/workdir/src/pool/start_threads_from_config.rs:32:14
[INFO] [stdout]    |
[INFO] [stdout] 32 | pub async fn start_threads_from_config(
[INFO] [stdout]    |              ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] help: consider removing the borrow
[INFO] [stdout]    |
[INFO] [stdout] 8  - let kafka_publisher = match start_threads_from_config(&config) {
[INFO] [stdout] 8  + let kafka_publisher = match start_threads_from_config(config) {
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]  --> src/pool/start_threads_from_config.rs:27:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | let kafka_publisher = match start_threads_from_config(&config) {
[INFO] [stdout]   |                             ---------------------------------- this expression has type `impl Future<Output = Result<KafkaPublisher, String>>`
[INFO] [stdout] 9 |     Ok(kp) => kp,
[INFO] [stdout]   |     ^^^^^^ expected future, found `Result<_, _>`
[INFO] [stdout]   |
[INFO] [stdout]   = note: expected opaque type `impl Future<Output = Result<KafkaPublisher, String>>`
[INFO] [stdout]                     found enum `Result<_, _>`
[INFO] [stdout] help: consider `await`ing on the `Future`
[INFO] [stdout]   |
[INFO] [stdout] 8 | let kafka_publisher = match start_threads_from_config(&config).await {
[INFO] [stdout]   |                                                               ++++++
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/pool/start_threads_from_config.rs:28:5
[INFO] [stdout]    |
[INFO] [stdout] 8  | let kafka_publisher = match start_threads_from_config(&config) {
[INFO] [stdout]    |                             ---------------------------------- this expression has type `impl Future<Output = Result<KafkaPublisher, String>>`
[INFO] [stdout] 9  |     Ok(kp) => kp,
[INFO] [stdout] 10 |     Err(e) => panic!("failed to start threads with err={e}")
[INFO] [stdout]    |     ^^^^^^ expected future, found `Result<_, _>`
[INFO] [stdout]    |
[INFO] [stdout]    = note: expected opaque type `impl Future<Output = Result<KafkaPublisher, String>>`
[INFO] [stdout]                      found enum `Result<_, _>`
[INFO] [stdout] help: consider `await`ing on the `Future`
[INFO] [stdout]    |
[INFO] [stdout] 8  | let kafka_publisher = match start_threads_from_config(&config).await {
[INFO] [stdout]    |                                                               ++++++
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 3 previous errors
[INFO] [stdout] 
[INFO] [stdout] For more information about this error, try `rustc --explain E0308`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout]     src/api/build_kafka_client_config.rs - api::build_kafka_client_config::build_kafka_client_config (line 33)
[INFO] [stdout]     src/api/build_kafka_publish_message.rs - api::build_kafka_publish_message::build_kafka_publish_message (line 25)
[INFO] [stdout]     src/kafka_publisher.rs - kafka_publisher (line 11)
[INFO] [stdout]     src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::new (line 56)
[INFO] [stdout]     src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::shutdown (line 230)
[INFO] [stdout]     src/pool/start_threads_from_config.rs - pool::start_threads_from_config::start_threads_from_config (line 21)
[INFO] [stdout]     src/start_threadpool.rs - start_threadpool::start_threadpool (line 20)
[INFO] [stdout] 
[INFO] [stdout] test result: FAILED. 1 passed; 7 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.73s
[INFO] [stdout] 
[INFO] [stderr] error: doctest failed, to rerun pass `--doc`
[INFO] running `Command { std: "docker" "inspect" "fb87c94a3fa45293d33d73ece2be518008f41c738511d6180624688f488df637", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "fb87c94a3fa45293d33d73ece2be518008f41c738511d6180624688f488df637", kill_on_drop: false }`
[INFO] [stdout] fb87c94a3fa45293d33d73ece2be518008f41c738511d6180624688f488df637
[INFO] testing kafka-threadpool-1.0.12 against beta-2023-12-22 for beta-1.76-1
[INFO] extracting crate kafka-threadpool 1.0.12 into /workspace/builds/worker-5-tc2/source
[INFO] validating manifest of crates.io crate kafka-threadpool 1.0.12 on toolchain beta-2023-12-22
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+beta-2023-12-22" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking crates.io crate kafka-threadpool 1.0.12
[INFO] finished tweaking crates.io crate kafka-threadpool 1.0.12
[INFO] tweaked toml for crates.io crate kafka-threadpool 1.0.12 written to /workspace/builds/worker-5-tc2/source/Cargo.toml
[INFO] crate crates.io crate kafka-threadpool 1.0.12 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" "+beta-2023-12-22" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2023-12-22" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] a59eb55a0f7a56b28f28f66f50ec1944fa81038bb83a2ed0cf2f71b6d15b6c60
[INFO] running `Command { std: "docker" "start" "-a" "a59eb55a0f7a56b28f28f66f50ec1944fa81038bb83a2ed0cf2f71b6d15b6c60", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "a59eb55a0f7a56b28f28f66f50ec1944fa81038bb83a2ed0cf2f71b6d15b6c60", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "a59eb55a0f7a56b28f28f66f50ec1944fa81038bb83a2ed0cf2f71b6d15b6c60", kill_on_drop: false }`
[INFO] [stdout] a59eb55a0f7a56b28f28f66f50ec1944fa81038bb83a2ed0cf2f71b6d15b6c60
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-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:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2023-12-22" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 46b71e28d6d14a9a2c88804eed0ba254a25b9396e780530a146ef1c3c7f71fc2
[INFO] running `Command { std: "docker" "start" "-a" "46b71e28d6d14a9a2c88804eed0ba254a25b9396e780530a146ef1c3c7f71fc2", kill_on_drop: false }`
[INFO] [stderr]    Compiling unicode-ident v1.0.4
[INFO] [stderr]    Compiling syn v1.0.100
[INFO] [stderr]    Compiling cc v1.0.73
[INFO] [stderr]    Compiling libc v0.2.133
[INFO] [stderr]    Compiling pkg-config v0.3.25
[INFO] [stderr]    Compiling serde v1.0.144
[INFO] [stderr]    Compiling futures-core v0.3.24
[INFO] [stderr]    Compiling thiserror v1.0.35
[INFO] [stderr]    Compiling proc-macro2 v1.0.43
[INFO] [stderr]    Compiling futures-task v0.3.24
[INFO] [stderr]    Compiling once_cell v1.14.0
[INFO] [stderr]    Compiling futures-channel v0.3.24
[INFO] [stderr]    Compiling openssl-src v111.22.0+1.1.1q
[INFO] [stderr]    Compiling quote v1.0.21
[INFO] [stderr]    Compiling serde_derive v1.0.144
[INFO] [stderr]    Compiling futures-util v0.3.24
[INFO] [stderr]    Compiling futures-sink v0.3.24
[INFO] [stderr]    Compiling cmake v0.1.48
[INFO] [stderr]    Compiling futures-io v0.3.24
[INFO] [stderr]    Compiling aho-corasick v0.7.19
[INFO] [stderr]    Compiling tokio v1.21.1
[INFO] [stderr]    Compiling quick-error v1.2.3
[INFO] [stderr]    Compiling openssl-sys v0.9.75
[INFO] [stderr]    Compiling libz-sys v1.1.8
[INFO] [stderr]    Compiling serde_json v1.0.85
[INFO] [stderr]    Compiling rdkafka-sys v4.2.0+1.8.2
[INFO] [stderr]    Compiling humantime v1.3.0
[INFO] [stderr]    Compiling num_cpus v1.13.1
[INFO] [stderr]    Compiling atty v0.2.14
[INFO] [stderr]    Compiling regex v1.6.0
[INFO] [stderr]    Compiling env_logger v0.7.1
[INFO] [stderr]    Compiling pretty_env_logger v0.4.0
[INFO] [stderr]    Compiling toml v0.5.9
[INFO] [stderr]    Compiling thiserror-impl v1.0.35
[INFO] [stderr]    Compiling futures-macro v0.3.24
[INFO] [stderr]    Compiling proc-macro-crate v1.2.1
[INFO] [stderr]    Compiling num_enum_derive v0.5.7
[INFO] [stderr]    Compiling tokio-macros v1.8.0
[INFO] [stderr]    Compiling num_enum v0.5.7
[INFO] [stderr]    Compiling futures-executor v0.3.24
[INFO] [stderr]    Compiling futures v0.3.24
[INFO] [stderr]    Compiling rdkafka v0.28.0
[INFO] [stderr]    Compiling kafka-threadpool v1.0.12 (/opt/rustwide/workdir)
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 29.38s
[INFO] running `Command { std: "docker" "inspect" "46b71e28d6d14a9a2c88804eed0ba254a25b9396e780530a146ef1c3c7f71fc2", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "46b71e28d6d14a9a2c88804eed0ba254a25b9396e780530a146ef1c3c7f71fc2", kill_on_drop: false }`
[INFO] [stdout] 46b71e28d6d14a9a2c88804eed0ba254a25b9396e780530a146ef1c3c7f71fc2
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-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:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2023-12-22" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 5f2049f4c8ebc7ec845e72f9a153cc40b2e8b2884c4ecb4e16788e024f70e283
[INFO] running `Command { std: "docker" "start" "-a" "5f2049f4c8ebc7ec845e72f9a153cc40b2e8b2884c4ecb4e16788e024f70e283", kill_on_drop: false }`
[INFO] [stderr]    Compiling kafka-threadpool v1.0.12 (/opt/rustwide/workdir)
[INFO] [stderr]     Finished test [unoptimized + debuginfo] target(s) in 1.67s
[INFO] running `Command { std: "docker" "inspect" "5f2049f4c8ebc7ec845e72f9a153cc40b2e8b2884c4ecb4e16788e024f70e283", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "5f2049f4c8ebc7ec845e72f9a153cc40b2e8b2884c4ecb4e16788e024f70e283", kill_on_drop: false }`
[INFO] [stdout] 5f2049f4c8ebc7ec845e72f9a153cc40b2e8b2884c4ecb4e16788e024f70e283
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5-tc2/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=warn" "-e" "RUSTDOCFLAGS=--cap-lints=warn" "-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:2788e3201cd34a07e3172128adcd8b3090168a8e3bcc40d7c032b9dda1df7d1c" "/opt/rustwide/cargo-home/bin/cargo" "+beta-2023-12-22" "test" "--frozen", kill_on_drop: false }`
[INFO] [stdout] 7caac20cf48a9e9b58aaa94665b41572466f065d92e81da7e8c1efc1c8a35845
[INFO] running `Command { std: "docker" "start" "-a" "7caac20cf48a9e9b58aaa94665b41572466f065d92e81da7e8c1efc1c8a35845", kill_on_drop: false }`
[INFO] [stderr]     Finished test [unoptimized + debuginfo] target(s) in 0.05s
[INFO] [stderr]      Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/kafka_threadpool-676f556b314612e1)
[INFO] [stdout] 
[INFO] [stdout] running 0 tests
[INFO] [stdout] 
[INFO] [stdout] test result: ok. 0 passed; 0 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.00s
[INFO] [stdout] 
[INFO] [stderr]    Doc-tests kafka_threadpool
[INFO] [stdout] 
[INFO] [stdout] running 8 tests
[INFO] [stdout] test src/start_threadpool.rs - start_threadpool::start_threadpool (line 20) ... FAILED
[INFO] [stdout] test src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::new (line 56) ... FAILED
[INFO] [stdout] test src/api/build_kafka_client_config.rs - api::build_kafka_client_config::build_kafka_client_config (line 33) ... FAILED
[INFO] [stdout] test src/api/build_kafka_publish_message.rs - api::build_kafka_publish_message::build_kafka_publish_message (line 25) ... FAILED
[INFO] [stdout] test src/kafka_publisher.rs - kafka_publisher (line 11) ... FAILED
[INFO] [stdout] test src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::shutdown (line 230) ... FAILED
[INFO] [stdout] test src/pool/start_threads_from_config.rs - pool::start_threads_from_config::start_threads_from_config (line 21) ... FAILED
[INFO] [stdout] test src/api/kafka_publish_message.rs - api::kafka_publish_message::KafkaPublishMessage::new_from (line 69) ... ok
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout] 
[INFO] [stdout] ---- src/start_threadpool.rs - start_threadpool::start_threadpool (line 20) stdout ----
[INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks
[INFO] [stdout]  --> src/start_threadpool.rs:24:51
[INFO] [stdout]   |
[INFO] [stdout] 4 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_start_threadpool_rs_20_0() {
[INFO] [stdout]   |                                         ------------------------------------------ this is not `async`
[INFO] [stdout] ...
[INFO] [stdout] 7 | let kafka_publisher = start_threadpool(log_label).await;
[INFO] [stdout]   |                                                   ^^^^^ only allowed inside `async` functions and blocks
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 1 previous error
[INFO] [stdout] 
[INFO] [stdout] For more information about this error, try `rustc --explain E0728`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::new (line 56) stdout ----
[INFO] [stdout] error[E0432]: unresolved import `crate::kafka_publisher`
[INFO] [stdout]  --> src/kafka_publisher.rs:57:12
[INFO] [stdout]   |
[INFO] [stdout] 3 | use crate::kafka_publisher::KafkaPublisher;
[INFO] [stdout]   |            ^^^^^^^^^^^^^^^
[INFO] [stdout]   |            |
[INFO] [stdout]   |            unresolved import
[INFO] [stdout]   |            help: a similar path exists: `kafka_threadpool::kafka_publisher`
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 1 previous error
[INFO] [stdout] 
[INFO] [stdout] For more information about this error, try `rustc --explain E0432`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/api/build_kafka_client_config.rs - api::build_kafka_client_config::build_kafka_client_config (line 33) stdout ----
[INFO] [stdout] error: expected `;`, found `}`
[INFO] [stdout]  --> src/api/build_kafka_client_config.rs:36:71
[INFO] [stdout]   |
[INFO] [stdout] 6 | let kafka_config: KafkaClientConfig = build_kafka_client_config("ktp")
[INFO] [stdout]   |                                                                       ^ help: add `;` here
[INFO] [stdout] 7 | } _doctest_main_src_api_build_kafka_client_config_rs_33_0() }
[INFO] [stdout]   | - unexpected token
[INFO] [stdout] 
[INFO] [stdout] error[E0432]: unresolved import `kafka_threadpool::config::kafka_client_config::build_kafka_client_config`
[INFO] [stdout]  --> src/api/build_kafka_client_config.rs:35:5
[INFO] [stdout]   |
[INFO] [stdout] 5 | use kafka_threadpool::config::kafka_client_config::build_kafka_client_config;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ no `build_kafka_client_config` in `config::kafka_client_config`
[INFO] [stdout]   |
[INFO] [stdout] help: consider importing this module instead
[INFO] [stdout]   |
[INFO] [stdout] 5 | use kafka_threadpool::api::build_kafka_client_config;
[INFO] [stdout]   |     ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
[INFO] [stdout] 
[INFO] [stdout] error[E0412]: cannot find type `KafkaClientConfig` in this scope
[INFO] [stdout]  --> src/api/build_kafka_client_config.rs:36:19
[INFO] [stdout]   |
[INFO] [stdout] 6 | let kafka_config: KafkaClientConfig = build_kafka_client_config("ktp")
[INFO] [stdout]   |                   ^^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout]   |
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]   |
[INFO] [stdout] 2 + use kafka_threadpool::config::kafka_client_config::KafkaClientConfig;
[INFO] [stdout]   |
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 3 previous errors
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0412, E0432.
[INFO] [stdout] For more information about an error, try `rustc --explain E0412`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/api/build_kafka_publish_message.rs - api::build_kafka_publish_message::build_kafka_publish_message (line 25) stdout ----
[INFO] [stdout] error[E0412]: cannot find type `KafkaPublishMessage` in this scope
[INFO] [stdout]   --> src/api/build_kafka_publish_message.rs:32:14
[INFO] [stdout]    |
[INFO] [stdout] 10 | let new_msg: KafkaPublishMessage = build_kafka_publish_message(
[INFO] [stdout]    |              ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]   ::: /opt/rustwide/workdir/src/api/kafka_publish_message_type.rs:20:1
[INFO] [stdout]    |
[INFO] [stdout] 20 | pub enum KafkaPublishMessageType {
[INFO] [stdout]    | -------------------------------- similarly named enum `KafkaPublishMessageType` defined here
[INFO] [stdout]    |
[INFO] [stdout] help: an enum with a similar name exists
[INFO] [stdout]    |
[INFO] [stdout] 10 | let new_msg: KafkaPublishMessageType = build_kafka_publish_message(
[INFO] [stdout]    |              ~~~~~~~~~~~~~~~~~~~~~~~
[INFO] [stdout] help: consider importing this struct
[INFO] [stdout]    |
[INFO] [stdout] 2  + use kafka_threadpool::api::kafka_publish_message::KafkaPublishMessage;
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 1 previous error
[INFO] [stdout] 
[INFO] [stdout] For more information about this error, try `rustc --explain E0412`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/kafka_publisher.rs - kafka_publisher (line 11) stdout ----
[INFO] [stdout] error[E0425]: cannot find value `my_kafka_publisher` in this scope
[INFO] [stdout]  --> src/kafka_publisher.rs:12:1
[INFO] [stdout]   |
[INFO] [stdout] 3 | my_kafka_publisher.shutdown().await.unwrap();
[INFO] [stdout]   | ^^^^^^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks
[INFO] [stdout]  --> src/kafka_publisher.rs:12:31
[INFO] [stdout]   |
[INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_kafka_publisher_rs_11_0() {
[INFO] [stdout]   |                                         ----------------------------------------- this is not `async`
[INFO] [stdout] 3 | my_kafka_publisher.shutdown().await.unwrap();
[INFO] [stdout]   |                               ^^^^^ only allowed inside `async` functions and blocks
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 2 previous errors
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0425, E0728.
[INFO] [stdout] For more information about an error, try `rustc --explain E0425`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::shutdown (line 230) stdout ----
[INFO] [stdout] error[E0425]: cannot find value `my_threadpool` in this scope
[INFO] [stdout]  --> src/kafka_publisher.rs:231:1
[INFO] [stdout]   |
[INFO] [stdout] 3 | my_threadpool.shutdown().await.unwrap();
[INFO] [stdout]   | ^^^^^^^^^^^^^ not found in this scope
[INFO] [stdout] 
[INFO] [stdout] error[E0728]: `await` is only allowed inside `async` functions and blocks
[INFO] [stdout]  --> src/kafka_publisher.rs:231:26
[INFO] [stdout]   |
[INFO] [stdout] 2 | fn main() { #[allow(non_snake_case)] fn _doctest_main_src_kafka_publisher_rs_230_0() {
[INFO] [stdout]   |                                         ------------------------------------------ this is not `async`
[INFO] [stdout] 3 | my_threadpool.shutdown().await.unwrap();
[INFO] [stdout]   |                          ^^^^^ only allowed inside `async` functions and blocks
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 2 previous errors
[INFO] [stdout] 
[INFO] [stdout] Some errors have detailed explanations: E0425, E0728.
[INFO] [stdout] For more information about an error, try `rustc --explain E0425`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] ---- src/pool/start_threads_from_config.rs - pool::start_threads_from_config::start_threads_from_config (line 21) stdout ----
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/pool/start_threads_from_config.rs:26:55
[INFO] [stdout]    |
[INFO] [stdout] 8  | let kafka_publisher = match start_threads_from_config(&config) {
[INFO] [stdout]    |                             ------------------------- ^^^^^^^ expected `KafkaClientConfig`, found `&KafkaClientConfig`
[INFO] [stdout]    |                             |
[INFO] [stdout]    |                             arguments to this function are incorrect
[INFO] [stdout]    |
[INFO] [stdout] note: function defined here
[INFO] [stdout]   --> /opt/rustwide/workdir/src/pool/start_threads_from_config.rs:32:14
[INFO] [stdout]    |
[INFO] [stdout] 32 | pub async fn start_threads_from_config(
[INFO] [stdout]    |              ^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] help: consider removing the borrow
[INFO] [stdout]    |
[INFO] [stdout] 8  - let kafka_publisher = match start_threads_from_config(&config) {
[INFO] [stdout] 8  + let kafka_publisher = match start_threads_from_config(config) {
[INFO] [stdout]    |
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]  --> src/pool/start_threads_from_config.rs:27:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | let kafka_publisher = match start_threads_from_config(&config) {
[INFO] [stdout]   |                             ---------------------------------- this expression has type `impl Future<Output = Result<KafkaPublisher, String>>`
[INFO] [stdout] 9 |     Ok(kp) => kp,
[INFO] [stdout]   |     ^^^^^^ expected future, found `Result<_, _>`
[INFO] [stdout]   |
[INFO] [stdout]   = note: expected opaque type `impl Future<Output = Result<KafkaPublisher, String>>`
[INFO] [stdout]                     found enum `Result<_, _>`
[INFO] [stdout] help: consider `await`ing on the `Future`
[INFO] [stdout]   |
[INFO] [stdout] 8 | let kafka_publisher = match start_threads_from_config(&config).await {
[INFO] [stdout]   |                                                               ++++++
[INFO] [stdout] 
[INFO] [stdout] error[E0308]: mismatched types
[INFO] [stdout]   --> src/pool/start_threads_from_config.rs:28:5
[INFO] [stdout]    |
[INFO] [stdout] 8  | let kafka_publisher = match start_threads_from_config(&config) {
[INFO] [stdout]    |                             ---------------------------------- this expression has type `impl Future<Output = Result<KafkaPublisher, String>>`
[INFO] [stdout] 9  |     Ok(kp) => kp,
[INFO] [stdout] 10 |     Err(e) => panic!("failed to start threads with err={e}")
[INFO] [stdout]    |     ^^^^^^ expected future, found `Result<_, _>`
[INFO] [stdout]    |
[INFO] [stdout]    = note: expected opaque type `impl Future<Output = Result<KafkaPublisher, String>>`
[INFO] [stdout]                      found enum `Result<_, _>`
[INFO] [stdout] help: consider `await`ing on the `Future`
[INFO] [stdout]    |
[INFO] [stdout] 8  | let kafka_publisher = match start_threads_from_config(&config).await {
[INFO] [stdout]    |                                                               ++++++
[INFO] [stdout] 
[INFO] [stdout] error: aborting due to 3 previous errors
[INFO] [stdout] 
[INFO] [stdout] For more information about this error, try `rustc --explain E0308`.
[INFO] [stdout] Couldn't compile the test.
[INFO] [stdout] 
[INFO] [stdout] failures:
[INFO] [stdout]     src/api/build_kafka_client_config.rs - api::build_kafka_client_config::build_kafka_client_config (line 33)
[INFO] [stdout]     src/api/build_kafka_publish_message.rs - api::build_kafka_publish_message::build_kafka_publish_message (line 25)
[INFO] [stdout]     src/kafka_publisher.rs - kafka_publisher (line 11)
[INFO] [stdout]     src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::new (line 56)
[INFO] [stdout]     src/kafka_publisher.rs - kafka_publisher::KafkaPublisher::shutdown (line 230)
[INFO] [stdout]     src/pool/start_threads_from_config.rs - pool::start_threads_from_config::start_threads_from_config (line 21)
[INFO] [stdout]     src/start_threadpool.rs - start_threadpool::start_threadpool (line 20)
[INFO] [stdout] 
[INFO] [stdout] test result: FAILED. 1 passed; 7 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.65s
[INFO] [stdout] 
[INFO] [stderr] error: doctest failed, to rerun pass `--doc`
[INFO] running `Command { std: "docker" "inspect" "7caac20cf48a9e9b58aaa94665b41572466f065d92e81da7e8c1efc1c8a35845", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "7caac20cf48a9e9b58aaa94665b41572466f065d92e81da7e8c1efc1c8a35845", kill_on_drop: false }`
[INFO] [stdout] 7caac20cf48a9e9b58aaa94665b41572466f065d92e81da7e8c1efc1c8a35845
