[INFO] fetching crate rocketmq 0.0.4...
[INFO] checking rocketmq-0.0.4 against master#5a8a44196b3cf099f8c9b0156bd902eaec0b4e5f for pr-87248
[INFO] extracting crate rocketmq 0.0.4 into /workspace/builds/worker-5/source
[INFO] validating manifest of crates.io crate rocketmq 0.0.4 on toolchain 5a8a44196b3cf099f8c9b0156bd902eaec0b4e5f
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+5a8a44196b3cf099f8c9b0156bd902eaec0b4e5f" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking crates.io crate rocketmq 0.0.4
[INFO] finished tweaking crates.io crate rocketmq 0.0.4
[INFO] tweaked toml for crates.io crate rocketmq 0.0.4 written to /workspace/builds/worker-5/source/Cargo.toml
[INFO] crate crates.io crate rocketmq 0.0.4 already has a lockfile, it will not be regenerated
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+5a8a44196b3cf099f8c9b0156bd902eaec0b4e5f" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5/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:34b6a614d2c27851fe6cbf88fbd1137609cefab8b10d0615aaeb6fd47975d74e" "/opt/rustwide/cargo-home/bin/cargo" "+5a8a44196b3cf099f8c9b0156bd902eaec0b4e5f" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] df1e947523a2467aa34489243d74fd6877ba2e12222cab4a54a62c545b79f9e9
[INFO] running `Command { std: "docker" "start" "-a" "df1e947523a2467aa34489243d74fd6877ba2e12222cab4a54a62c545b79f9e9", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "df1e947523a2467aa34489243d74fd6877ba2e12222cab4a54a62c545b79f9e9", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "df1e947523a2467aa34489243d74fd6877ba2e12222cab4a54a62c545b79f9e9", kill_on_drop: false }`
[INFO] [stdout] df1e947523a2467aa34489243d74fd6877ba2e12222cab4a54a62c545b79f9e9
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-5/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-5/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "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:34b6a614d2c27851fe6cbf88fbd1137609cefab8b10d0615aaeb6fd47975d74e" "/opt/rustwide/cargo-home/bin/cargo" "+5a8a44196b3cf099f8c9b0156bd902eaec0b4e5f" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] 9570099dc8fdb53c0d38b3c0741fe83d69ec0dde9020ab36b90f48d359aa7a87
[INFO] running `Command { std: "docker" "start" "-a" "9570099dc8fdb53c0d38b3c0741fe83d69ec0dde9020ab36b90f48d359aa7a87", kill_on_drop: false }`
[INFO] [stderr]    Compiling syn v1.0.73
[INFO] [stderr]     Checking pin-project-lite v0.2.6
[INFO] [stderr]    Compiling proc-macro-hack v0.5.19
[INFO] [stderr]    Compiling typenum v1.13.0
[INFO] [stderr]    Compiling proc-macro-nested v0.1.7
[INFO] [stderr]     Checking hashbrown v0.9.1
[INFO] [stderr]     Checking smallvec v1.6.1
[INFO] [stderr]     Checking ppv-lite86 v0.2.10
[INFO] [stderr]     Checking subtle v2.4.0
[INFO] [stderr]     Checking scopeguard v1.1.0
[INFO] [stderr]     Checking json-tools v1.1.2
[INFO] [stderr]     Checking opaque-debug v0.3.0
[INFO] [stderr]     Checking ansi_term v0.12.1
[INFO] [stderr]     Checking hex v0.4.3
[INFO] [stderr]     Checking tracing-core v0.1.18
[INFO] [stderr]    Compiling futures-macro v0.3.15
[INFO] [stderr]    Compiling generic-array v0.14.4
[INFO] [stderr]    Compiling futures-util v0.3.15
[INFO] [stderr]    Compiling standback v0.2.17
[INFO] [stderr]    Compiling tokio v1.7.1
[INFO] [stderr]    Compiling indexmap v1.6.2
[INFO] [stderr]     Checking tinyvec v1.2.0
[INFO] [stderr]    Compiling miniz_oxide v0.4.4
[INFO] [stderr]     Checking instant v0.1.9
[INFO] [stderr]    Compiling time v0.2.27
[INFO] [stderr]     Checking regex-automata v0.1.10
[INFO] [stderr]     Checking regex v1.5.4
[INFO] [stderr]     Checking consistent_hash_ring v0.8.0
[INFO] [stderr]     Checking sharded-slab v0.1.1
[INFO] [stderr]    Compiling proc-macro2 v1.0.27
[INFO] [stderr]     Checking getrandom v0.2.3
[INFO] [stderr]     Checking socket2 v0.4.0
[INFO] [stderr]     Checking if-addrs v0.6.5
[INFO] [stderr]     Checking mio v0.7.13
[INFO] [stderr]     Checking http-body v0.4.2
[INFO] [stderr]     Checking chrono v0.4.19
[INFO] [stderr]     Checking lock_api v0.4.4
[INFO] [stderr]     Checking tracing-log v0.1.2
[INFO] [stderr]     Checking parking_lot_core v0.8.3
[INFO] [stderr]     Checking rand_core v0.6.3
[INFO] [stderr]     Checking dirty-json v0.1.0
[INFO] [stderr]    Compiling quote v1.0.9
[INFO] [stderr]     Checking parking_lot v0.11.1
[INFO] [stderr]     Checking matchers v0.0.1
[INFO] [stderr]     Checking rand_chacha v0.3.1
[INFO] [stderr]     Checking flate2 v1.0.20
[INFO] [stderr]     Checking rand v0.8.4
[INFO] [stderr]     Checking unicode-normalization v0.1.19
[INFO] [stderr]     Checking digest v0.9.0
[INFO] [stderr]     Checking block-buffer v0.9.0
[INFO] [stderr]     Checking crypto-mac v0.11.0
[INFO] [stderr]     Checking hmac v0.11.0
[INFO] [stderr]     Checking sha-1 v0.9.6
[INFO] [stderr]     Checking idna v0.2.3
[INFO] [stderr]     Checking url v2.2.2
[INFO] [stderr]    Compiling serde_derive v1.0.126
[INFO] [stderr]    Compiling tracing-attributes v0.1.15
[INFO] [stderr]    Compiling tokio-macros v1.2.0
[INFO] [stderr]    Compiling time-macros-impl v0.1.2
[INFO] [stderr]    Compiling pin-project-internal v1.0.7
[INFO] [stderr]    Compiling derivative v2.2.0
[INFO] [stderr]    Compiling async-trait v0.1.50
[INFO] [stderr]     Checking time-macros v0.1.1
[INFO] [stderr]     Checking pin-project v1.0.7
[INFO] [stderr]     Checking tracing v0.1.26
[INFO] [stderr]     Checking tracing-futures v0.2.5
[INFO] [stderr]     Checking futures-executor v0.3.15
[INFO] [stderr]     Checking serde v1.0.126
[INFO] [stderr]     Checking tokio-util v0.6.7
[INFO] [stderr]     Checking futures v0.3.15
[INFO] [stderr]     Checking h2 v0.3.3
[INFO] [stderr]     Checking serde_json v1.0.64
[INFO] [stderr]     Checking serde_urlencoded v0.7.0
[INFO] [stderr]     Checking tracing-serde v0.1.2
[INFO] [stderr]     Checking bitflags_serde_shim v0.2.2
[INFO] [stderr]    Compiling toml v0.5.8
[INFO] [stderr]     Checking tracing-subscriber v0.2.18
[INFO] [stderr]     Checking hyper v0.14.9
[INFO] [stderr]    Compiling proc-macro-crate v0.1.5
[INFO] [stderr]    Compiling num_enum_derive v0.5.1
[INFO] [stderr]     Checking reqwest v0.11.4
[INFO] [stderr]     Checking num_enum v0.5.1
[INFO] [stderr]     Checking rocketmq v0.0.4 (/opt/rustwide/workdir)
[INFO] [stdout] warning: unused import: `std::collections::BTreeMap`
[INFO] [stdout]  --> src/consumer/process_queue.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use std::collections::BTreeMap;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `parking_lot::RwLock`
[INFO] [stdout]  --> src/consumer/process_queue.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use parking_lot::RwLock;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::collections::BTreeMap`
[INFO] [stdout]  --> src/consumer/process_queue.rs:1:5
[INFO] [stdout]   |
[INFO] [stdout] 1 | use std::collections::BTreeMap;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `parking_lot::RwLock`
[INFO] [stdout]  --> src/consumer/process_queue.rs:4:5
[INFO] [stdout]   |
[INFO] [stdout] 4 | use parking_lot::RwLock;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: use of deprecated associated function `time::OffsetDateTime::now_local`: UTC is returned if the local offset cannot be determined
[INFO] [stdout]   --> src/consumer/process_queue.rs:23:34
[INFO] [stdout]    |
[INFO] [stdout] 23 |         let ts = OffsetDateTime::now_local().unix_timestamp();
[INFO] [stdout]    |                                  ^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(deprecated)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: use of deprecated associated function `time::OffsetDateTime::now_local`: UTC is returned if the local offset cannot be determined
[INFO] [stdout]    --> src/message.rs:398:39
[INFO] [stdout]     |
[INFO] [stdout] 398 |             let now = OffsetDateTime::now_local();
[INFO] [stdout]     |                                       ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: use of deprecated associated function `time::OffsetDateTime::now_local`: UTC is returned if the local offset cannot be determined
[INFO] [stdout]    --> src/message.rs:418:31
[INFO] [stdout]     |
[INFO] [stdout] 418 |             ((OffsetDateTime::now_local().unix_timestamp() - self.start_timestamp) * 1000) as i32,
[INFO] [stdout]     |                               ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: use of deprecated associated function `time::OffsetDateTime::now_local`: UTC is returned if the local offset cannot be determined
[INFO] [stdout]   --> src/consumer/process_queue.rs:23:34
[INFO] [stdout]    |
[INFO] [stdout] 23 |         let ts = OffsetDateTime::now_local().unix_timestamp();
[INFO] [stdout]    |                                  ^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(deprecated)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: use of deprecated associated function `time::OffsetDateTime::now_local`: UTC is returned if the local offset cannot be determined
[INFO] [stdout]    --> src/message.rs:398:39
[INFO] [stdout]     |
[INFO] [stdout] 398 |             let now = OffsetDateTime::now_local();
[INFO] [stdout]     |                                       ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: use of deprecated associated function `time::OffsetDateTime::now_local`: UTC is returned if the local offset cannot be determined
[INFO] [stdout]    --> src/message.rs:418:31
[INFO] [stdout]     |
[INFO] [stdout] 418 |             ((OffsetDateTime::now_local().unix_timestamp() - self.start_timestamp) * 1000) as i32,
[INFO] [stdout]     |                               ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `SingleTag`
[INFO] [stdout]   --> src/client/model.rs:59:5
[INFO] [stdout]    |
[INFO] [stdout] 59 |     SingleTag,
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `MultiTag`
[INFO] [stdout]   --> src/client/model.rs:60:5
[INFO] [stdout]    |
[INFO] [stdout] 60 |     MultiTag,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `new`
[INFO] [stdout]   --> src/client/model.rs:84:12
[INFO] [stdout]    |
[INFO] [stdout] 84 |     pub fn new<S: Into<String>>(topic_name: S) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `new`
[INFO] [stdout]   --> src/client/mod.rs:45:12
[INFO] [stdout]    |
[INFO] [stdout] 45 |     pub fn new<S: Into<String>>(access_key: S, secret_key: S) -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `Found`
[INFO] [stdout]   --> src/client/mod.rs:57:5
[INFO] [stdout]    |
[INFO] [stdout] 57 |     Found = 0,
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `NoNewMsg`
[INFO] [stdout]   --> src/client/mod.rs:58:5
[INFO] [stdout]    |
[INFO] [stdout] 58 |     NoNewMsg = 1,
[INFO] [stdout]    |     ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `NoMsgMatched`
[INFO] [stdout]   --> src/client/mod.rs:59:5
[INFO] [stdout]    |
[INFO] [stdout] 59 |     NoMsgMatched = 2,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `OffsetIllegal`
[INFO] [stdout]   --> src/client/mod.rs:60:5
[INFO] [stdout]    |
[INFO] [stdout] 60 |     OffsetIllegal = 3,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `BrokerTimeout`
[INFO] [stdout]   --> src/client/mod.rs:61:5
[INFO] [stdout]    |
[INFO] [stdout] 61 |     BrokerTimeout = 4,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `pull_message`
[INFO] [stdout]    --> src/client/mod.rs:309:18
[INFO] [stdout]     |
[INFO] [stdout] 309 |     pub async fn pull_message(
[INFO] [stdout]     |                  ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `register_consumer`
[INFO] [stdout]    --> src/client/mod.rs:360:19
[INFO] [stdout]     |
[INFO] [stdout] 360 |     pub(crate) fn register_consumer(&self, group: &str, consumer: Arc<Mutex<ConsumerInner>>) {
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `unregister_consumer`
[INFO] [stdout]    --> src/client/mod.rs:365:19
[INFO] [stdout]     |
[INFO] [stdout] 365 |     pub(crate) fn unregister_consumer(&self, group: &str) {
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `rebalance_immediately`
[INFO] [stdout]    --> src/client/mod.rs:380:8
[INFO] [stdout]     |
[INFO] [stdout] 380 |     fn rebalance_immediately(&self) {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `unregister_client`
[INFO] [stdout]    --> src/client/mod.rs:517:14
[INFO] [stdout]     |
[INFO] [stdout] 517 |     async fn unregister_client(&self, producer_group: &str, consumer_group: &str) {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `create_topic`
[INFO] [stdout]    --> src/client/mod.rs:539:18
[INFO] [stdout]     |
[INFO] [stdout] 539 |     pub async fn create_topic(
[INFO] [stdout]     |                  ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `send_message_back`
[INFO] [stdout]    --> src/client/mod.rs:589:18
[INFO] [stdout]     |
[INFO] [stdout] 589 |     pub async fn send_message_back(
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `Memory`
[INFO] [stdout]   --> src/consumer/offset_store.rs:21:5
[INFO] [stdout]    |
[INFO] [stdout] 21 |     Memory,
[INFO] [stdout]    |     ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `Store`
[INFO] [stdout]   --> src/consumer/offset_store.rs:22:5
[INFO] [stdout]    |
[INFO] [stdout] 22 |     Store,
[INFO] [stdout]    |     ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `MemoryThenStore`
[INFO] [stdout]   --> src/consumer/offset_store.rs:23:5
[INFO] [stdout]    |
[INFO] [stdout] 23 |     MemoryThenStore,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `new`
[INFO] [stdout]   --> src/consumer/process_queue.rs:22:12
[INFO] [stdout]    |
[INFO] [stdout] 22 |     pub fn new() -> Self {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `rebalance`
[INFO] [stdout]    --> src/consumer/mod.rs:156:12
[INFO] [stdout]     |
[INFO] [stdout] 156 |     pub fn rebalance(&self) {
[INFO] [stdout]     |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `address`
[INFO] [stdout]   --> src/namesrv.rs:51:12
[INFO] [stdout]    |
[INFO] [stdout] 51 |     pub fn address(&self) -> String {
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `len`
[INFO] [stdout]   --> src/namesrv.rs:64:12
[INFO] [stdout]    |
[INFO] [stdout] 64 |     pub fn len(&self) -> usize {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `is_empty`
[INFO] [stdout]   --> src/namesrv.rs:68:12
[INFO] [stdout]    |
[INFO] [stdout] 68 |     pub fn is_empty(&self) -> bool {
[INFO] [stdout]    |            ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `fetch_subscribe_message_queues`
[INFO] [stdout]    --> src/namesrv.rs:180:18
[INFO] [stdout]     |
[INFO] [stdout] 180 |     pub async fn fetch_subscribe_message_queues(
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `fetch_publish_message_queues`
[INFO] [stdout]    --> src/namesrv.rs:205:18
[INFO] [stdout]     |
[INFO] [stdout] 205 |     pub async fn fetch_publish_message_queues(
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `is_unit_mode`
[INFO] [stdout]    --> src/producer/mod.rs:166:19
[INFO] [stdout]     |
[INFO] [stdout] 166 |     pub(crate) fn is_unit_mode(&self) -> bool {
[INFO] [stdout]     |                   ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `mark_response_type`
[INFO] [stdout]   --> src/protocol/mod.rs:78:12
[INFO] [stdout]    |
[INFO] [stdout] 78 |     pub fn mark_response_type(&mut self) {
[INFO] [stdout]    |            ^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field is never read: `outbound`
[INFO] [stdout]   --> src/remoting/connection.rs:86:5
[INFO] [stdout]    |
[INFO] [stdout] 86 |     outbound: mpsc::UnboundedSender<RemotingCommand>,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `MultiTag`
[INFO] [stdout]   --> src/client/model.rs:60:5
[INFO] [stdout]    |
[INFO] [stdout] 60 |     MultiTag,
[INFO] [stdout]    |     ^^^^^^^^
[INFO] [stdout]    |
[INFO] [stdout]    = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `Found`
[INFO] [stdout]   --> src/client/mod.rs:57:5
[INFO] [stdout]    |
[INFO] [stdout] 57 |     Found = 0,
[INFO] [stdout]    |     ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `NoNewMsg`
[INFO] [stdout]   --> src/client/mod.rs:58:5
[INFO] [stdout]    |
[INFO] [stdout] 58 |     NoNewMsg = 1,
[INFO] [stdout]    |     ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `NoMsgMatched`
[INFO] [stdout]   --> src/client/mod.rs:59:5
[INFO] [stdout]    |
[INFO] [stdout] 59 |     NoMsgMatched = 2,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `OffsetIllegal`
[INFO] [stdout]   --> src/client/mod.rs:60:5
[INFO] [stdout]    |
[INFO] [stdout] 60 |     OffsetIllegal = 3,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `BrokerTimeout`
[INFO] [stdout]   --> src/client/mod.rs:61:5
[INFO] [stdout]    |
[INFO] [stdout] 61 |     BrokerTimeout = 4,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `pull_message`
[INFO] [stdout]    --> src/client/mod.rs:309:18
[INFO] [stdout]     |
[INFO] [stdout] 309 |     pub async fn pull_message(
[INFO] [stdout]     |                  ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `register_consumer`
[INFO] [stdout]    --> src/client/mod.rs:360:19
[INFO] [stdout]     |
[INFO] [stdout] 360 |     pub(crate) fn register_consumer(&self, group: &str, consumer: Arc<Mutex<ConsumerInner>>) {
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `unregister_consumer`
[INFO] [stdout]    --> src/client/mod.rs:365:19
[INFO] [stdout]     |
[INFO] [stdout] 365 |     pub(crate) fn unregister_consumer(&self, group: &str) {
[INFO] [stdout]     |                   ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `rebalance_immediately`
[INFO] [stdout]    --> src/client/mod.rs:380:8
[INFO] [stdout]     |
[INFO] [stdout] 380 |     fn rebalance_immediately(&self) {
[INFO] [stdout]     |        ^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `unregister_client`
[INFO] [stdout]    --> src/client/mod.rs:517:14
[INFO] [stdout]     |
[INFO] [stdout] 517 |     async fn unregister_client(&self, producer_group: &str, consumer_group: &str) {
[INFO] [stdout]     |              ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `send_message_back`
[INFO] [stdout]    --> src/client/mod.rs:589:18
[INFO] [stdout]     |
[INFO] [stdout] 589 |     pub async fn send_message_back(
[INFO] [stdout]     |                  ^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `Memory`
[INFO] [stdout]   --> src/consumer/offset_store.rs:21:5
[INFO] [stdout]    |
[INFO] [stdout] 21 |     Memory,
[INFO] [stdout]    |     ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `Store`
[INFO] [stdout]   --> src/consumer/offset_store.rs:22:5
[INFO] [stdout]    |
[INFO] [stdout] 22 |     Store,
[INFO] [stdout]    |     ^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: variant is never constructed: `MemoryThenStore`
[INFO] [stdout]   --> src/consumer/offset_store.rs:23:5
[INFO] [stdout]    |
[INFO] [stdout] 23 |     MemoryThenStore,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `rebalance`
[INFO] [stdout]    --> src/consumer/mod.rs:156:12
[INFO] [stdout]     |
[INFO] [stdout] 156 |     pub fn rebalance(&self) {
[INFO] [stdout]     |            ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `address`
[INFO] [stdout]   --> src/namesrv.rs:51:12
[INFO] [stdout]    |
[INFO] [stdout] 51 |     pub fn address(&self) -> String {
[INFO] [stdout]    |            ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `len`
[INFO] [stdout]   --> src/namesrv.rs:64:12
[INFO] [stdout]    |
[INFO] [stdout] 64 |     pub fn len(&self) -> usize {
[INFO] [stdout]    |            ^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `is_empty`
[INFO] [stdout]   --> src/namesrv.rs:68:12
[INFO] [stdout]    |
[INFO] [stdout] 68 |     pub fn is_empty(&self) -> bool {
[INFO] [stdout]    |            ^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: associated function is never used: `is_unit_mode`
[INFO] [stdout]    --> src/producer/mod.rs:166:19
[INFO] [stdout]     |
[INFO] [stdout] 166 |     pub(crate) fn is_unit_mode(&self) -> bool {
[INFO] [stdout]     |                   ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: field is never read: `outbound`
[INFO] [stdout]   --> src/remoting/connection.rs:86:5
[INFO] [stdout]    |
[INFO] [stdout] 86 |     outbound: mpsc::UnboundedSender<RemotingCommand>,
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 34 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 26 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 56.54s
[INFO] running `Command { std: "docker" "inspect" "9570099dc8fdb53c0d38b3c0741fe83d69ec0dde9020ab36b90f48d359aa7a87", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "9570099dc8fdb53c0d38b3c0741fe83d69ec0dde9020ab36b90f48d359aa7a87", kill_on_drop: false }`
[INFO] [stdout] 9570099dc8fdb53c0d38b3c0741fe83d69ec0dde9020ab36b90f48d359aa7a87