[INFO] fetching crate kafka-threadpool 1.0.12...
[INFO] testing kafka-threadpool-1.0.12 against 1.76.0 for beta-1.77-1
[INFO] extracting crate kafka-threadpool 1.0.12 into /workspace/builds/worker-1-tc1/source
[INFO] validating manifest of crates.io crate kafka-threadpool 1.0.12 on toolchain 1.76.0
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+1.76.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-1-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.76.0" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Updating crates.io index
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded rdkafka v0.28.0
[INFO] [stderr]   Downloaded syn v1.0.100
[INFO] [stderr]   Downloaded tokio v1.21.1
[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-1-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-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.76.0" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 5d82f1ee29c5aeb4af98b3423fcbe75c0ed3598c625941b29419aef0ece049b5
[INFO] running `Command { std: "docker" "start" "-a" "5d82f1ee29c5aeb4af98b3423fcbe75c0ed3598c625941b29419aef0ece049b5", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "5d82f1ee29c5aeb4af98b3423fcbe75c0ed3598c625941b29419aef0ece049b5", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "5d82f1ee29c5aeb4af98b3423fcbe75c0ed3598c625941b29419aef0ece049b5", kill_on_drop: false }`
[INFO] [stdout] 5d82f1ee29c5aeb4af98b3423fcbe75c0ed3598c625941b29419aef0ece049b5
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-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.76.0" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 76dc89d82847e057795714bda11f8d5d45e7b2b17e3b5429e6659a0d95ba56c0
[INFO] running `Command { std: "docker" "start" "-a" "76dc89d82847e057795714bda11f8d5d45e7b2b17e3b5429e6659a0d95ba56c0", kill_on_drop: false }`
[INFO] [stderr]    Compiling proc-macro2 v1.0.43
[INFO] [stderr]    Compiling unicode-ident v1.0.4
[INFO] [stderr]    Compiling quote v1.0.21
[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 futures-channel v0.3.24
[INFO] [stderr]    Compiling once_cell v1.14.0
[INFO] [stderr]    Compiling futures-task v0.3.24
[INFO] [stderr]    Compiling pin-project-lite v0.2.9
[INFO] [stderr]    Compiling slab v0.4.7
[INFO] [stderr]    Compiling futures-sink v0.3.24
[INFO] [stderr]    Compiling serde_derive v1.0.144
[INFO] [stderr]    Compiling log v0.4.17
[INFO] [stderr]    Compiling futures-util v0.3.24
[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 serde_json v1.0.85
[INFO] [stderr]    Compiling quick-error v1.2.3
[INFO] [stderr]    Compiling regex-syntax v0.6.27
[INFO] [stderr]    Compiling humantime v1.3.0
[INFO] [stderr]    Compiling termcolor v1.1.3
[INFO] [stderr]    Compiling openssl-src v111.22.0+1.1.1q
[INFO] [stderr]    Compiling cmake v0.1.48
[INFO] [stderr]    Compiling ryu v1.0.11
[INFO] [stderr]    Compiling itoa v1.0.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 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 toml v0.5.9
[INFO] [stderr]    Compiling pretty_env_logger v0.4.0
[INFO] [stderr]    Compiling thiserror-impl v1.0.35
[INFO] [stderr]    Compiling futures-macro v0.3.24
[INFO] [stderr]    Compiling tokio-macros v1.8.0
[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 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 21.93s
[INFO] running `Command { std: "docker" "inspect" "76dc89d82847e057795714bda11f8d5d45e7b2b17e3b5429e6659a0d95ba56c0", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "76dc89d82847e057795714bda11f8d5d45e7b2b17e3b5429e6659a0d95ba56c0", kill_on_drop: false }`
[INFO] [stdout] 76dc89d82847e057795714bda11f8d5d45e7b2b17e3b5429e6659a0d95ba56c0
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-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.76.0" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 0e2104e8cb349ee70a57fd32f6ff1a8fd6deacba2996d47b8b63acf21b531bbb
[INFO] running `Command { std: "docker" "start" "-a" "0e2104e8cb349ee70a57fd32f6ff1a8fd6deacba2996d47b8b63acf21b531bbb", 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.43s
[INFO] running `Command { std: "docker" "inspect" "0e2104e8cb349ee70a57fd32f6ff1a8fd6deacba2996d47b8b63acf21b531bbb", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "0e2104e8cb349ee70a57fd32f6ff1a8fd6deacba2996d47b8b63acf21b531bbb", kill_on_drop: false }`
[INFO] [stdout] 0e2104e8cb349ee70a57fd32f6ff1a8fd6deacba2996d47b8b63acf21b531bbb
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-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.76.0" "test" "--frozen", kill_on_drop: false }`
[INFO] [stdout] eab5f2d40ac1a849cef6c0b4e4b93017b7c1cf1416ea92ec697b7726b10efcab
[INFO] running `Command { std: "docker" "start" "-a" "eab5f2d40ac1a849cef6c0b4e4b93017b7c1cf1416ea92ec697b7726b10efcab", kill_on_drop: false }`
[INFO] [stderr]     Finished test [unoptimized + debuginfo] target(s) in 0.03s
[INFO] [stderr]      Running unittests src/lib.rs (/opt/rustwide/target/debug/deps/kafka_threadpool-854551c088c66b54)
[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/kafka_publisher.rs - kafka_publisher (line 11) ... 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::KafkaPublisher::shutdown (line 230) ... 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/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/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/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::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/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/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.64s
[INFO] [stdout] 
[INFO] [stderr] error: doctest failed, to rerun pass `--doc`
[INFO] running `Command { std: "docker" "inspect" "eab5f2d40ac1a849cef6c0b4e4b93017b7c1cf1416ea92ec697b7726b10efcab", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "eab5f2d40ac1a849cef6c0b4e4b93017b7c1cf1416ea92ec697b7726b10efcab", kill_on_drop: false }`
[INFO] [stdout] eab5f2d40ac1a849cef6c0b4e4b93017b7c1cf1416ea92ec697b7726b10efcab
[INFO] testing kafka-threadpool-1.0.12 against beta-2024-02-10 for beta-1.77-1
[INFO] extracting crate kafka-threadpool 1.0.12 into /workspace/builds/worker-1-tc2/source
[INFO] validating manifest of crates.io crate kafka-threadpool 1.0.12 on toolchain beta-2024-02-10
[INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+beta-2024-02-10" "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-1-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-2024-02-10" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-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-2024-02-10" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 84e61ddda0ef29cb4ab3264248400beaa04ddc82a7046dd067ddc40617604912
[INFO] running `Command { std: "docker" "start" "-a" "84e61ddda0ef29cb4ab3264248400beaa04ddc82a7046dd067ddc40617604912", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "84e61ddda0ef29cb4ab3264248400beaa04ddc82a7046dd067ddc40617604912", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "84e61ddda0ef29cb4ab3264248400beaa04ddc82a7046dd067ddc40617604912", kill_on_drop: false }`
[INFO] [stdout] 84e61ddda0ef29cb4ab3264248400beaa04ddc82a7046dd067ddc40617604912
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-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-2024-02-10" "build" "--frozen" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] c552c9e765b2143ddc63fafb9aafb438052d74f945382ae94abaa968956be512
[INFO] running `Command { std: "docker" "start" "-a" "c552c9e765b2143ddc63fafb9aafb438052d74f945382ae94abaa968956be512", kill_on_drop: false }`
[INFO] [stderr]    Compiling proc-macro2 v1.0.43
[INFO] [stderr]    Compiling unicode-ident v1.0.4
[INFO] [stderr]    Compiling quote v1.0.21
[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 futures-task v0.3.24
[INFO] [stderr]    Compiling futures-channel v0.3.24
[INFO] [stderr]    Compiling once_cell v1.14.0
[INFO] [stderr]    Compiling log v0.4.17
[INFO] [stderr]    Compiling slab v0.4.7
[INFO] [stderr]    Compiling futures-sink v0.3.24
[INFO] [stderr]    Compiling pin-project-lite v0.2.9
[INFO] [stderr]    Compiling serde_derive v1.0.144
[INFO] [stderr]    Compiling futures-util v0.3.24
[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 serde_json v1.0.85
[INFO] [stderr]    Compiling quick-error v1.2.3
[INFO] [stderr]    Compiling regex-syntax v0.6.27
[INFO] [stderr]    Compiling termcolor v1.1.3
[INFO] [stderr]    Compiling itoa v1.0.3
[INFO] [stderr]    Compiling humantime v1.3.0
[INFO] [stderr]    Compiling ryu v1.0.11
[INFO] [stderr]    Compiling openssl-src v111.22.0+1.1.1q
[INFO] [stderr]    Compiling cmake v0.1.48
[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 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 tokio-macros v1.8.0
[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 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 19.32s
[INFO] running `Command { std: "docker" "inspect" "c552c9e765b2143ddc63fafb9aafb438052d74f945382ae94abaa968956be512", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "c552c9e765b2143ddc63fafb9aafb438052d74f945382ae94abaa968956be512", kill_on_drop: false }`
[INFO] [stdout] c552c9e765b2143ddc63fafb9aafb438052d74f945382ae94abaa968956be512
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-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-2024-02-10" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 9c5408fe4b0e9f4a559f1bee0726227a3116e24f6b3ea9609ae32471060f63b0
[INFO] running `Command { std: "docker" "start" "-a" "9c5408fe4b0e9f4a559f1bee0726227a3116e24f6b3ea9609ae32471060f63b0", 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.43s
[INFO] running `Command { std: "docker" "inspect" "9c5408fe4b0e9f4a559f1bee0726227a3116e24f6b3ea9609ae32471060f63b0", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "9c5408fe4b0e9f4a559f1bee0726227a3116e24f6b3ea9609ae32471060f63b0", kill_on_drop: false }`
[INFO] [stdout] 9c5408fe4b0e9f4a559f1bee0726227a3116e24f6b3ea9609ae32471060f63b0
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-tc2/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-1-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-2024-02-10" "test" "--frozen", kill_on_drop: false }`
[INFO] [stdout] dd8d57f20ef1a205bddc1f9cbaf3d52605ff21865ecd5dede653ebfe9ead0d52
[INFO] running `Command { std: "docker" "start" "-a" "dd8d57f20ef1a205bddc1f9cbaf3d52605ff21865ecd5dede653ebfe9ead0d52", 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-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_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/api/build_kafka_client_config.rs - api::build_kafka_client_config::build_kafka_client_config (line 33) ... 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_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/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/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.60s
[INFO] [stdout] 
[INFO] [stderr] error: doctest failed, to rerun pass `--doc`
[INFO] running `Command { std: "docker" "inspect" "dd8d57f20ef1a205bddc1f9cbaf3d52605ff21865ecd5dede653ebfe9ead0d52", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "dd8d57f20ef1a205bddc1f9cbaf3d52605ff21865ecd5dede653ebfe9ead0d52", kill_on_drop: false }`
[INFO] [stdout] dd8d57f20ef1a205bddc1f9cbaf3d52605ff21865ecd5dede653ebfe9ead0d52
