[INFO] fetching crate kawadb-broker 0.1.0... [INFO] testing kawadb-broker-0.1.0 against master#c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38 for pr-146098-7 [INFO] extracting crate kawadb-broker 0.1.0 into /workspace/builds/worker-0-tc1/source [INFO] started tweaking crates.io crate kawadb-broker 0.1.0 [INFO] removed 0 missing tests [INFO] finished tweaking crates.io crate kawadb-broker 0.1.0 [INFO] tweaked toml for crates.io crate kawadb-broker 0.1.0 written to /workspace/builds/worker-0-tc1/source/Cargo.toml [INFO] validating manifest of crates.io crate kawadb-broker 0.1.0 on toolchain c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38 [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }` [INFO] crate crates.io crate kawadb-broker 0.1.0 already has a lockfile, it will not be regenerated [INFO] running `Command { std: CARGO_HOME="/workspace/cargo-home" RUSTUP_HOME="/workspace/rustup-home" "/workspace/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }` [INFO] [stderr] Updating crates.io index [INFO] [stderr] Downloading crates ... [INFO] [stderr] Downloaded num_enum_derive v0.7.4 [INFO] [stderr] Downloaded num_enum v0.7.4 [INFO] [stderr] Downloaded rdkafka v0.37.0 [INFO] [stderr] Downloaded cc v1.2.29 [INFO] [stderr] Downloaded proptest v1.7.0 [INFO] [stderr] Downloaded rdkafka-sys v4.9.0+2.10.0 [INFO] [stderr] Downloaded kawadb-storage v0.1.0 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }` [INFO] [stdout] 8a6ed0b18ffd00084f1da2934dca3fcbbe861274aa917cb756f0763cedce9b29 [INFO] running `Command { std: "docker" "start" "-a" "8a6ed0b18ffd00084f1da2934dca3fcbbe861274aa917cb756f0763cedce9b29", kill_on_drop: false }` [INFO] running `Command { std: "docker" "inspect" "8a6ed0b18ffd00084f1da2934dca3fcbbe861274aa917cb756f0763cedce9b29", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "8a6ed0b18ffd00084f1da2934dca3fcbbe861274aa917cb756f0763cedce9b29", kill_on_drop: false }` [INFO] [stdout] 8a6ed0b18ffd00084f1da2934dca3fcbbe861274aa917cb756f0763cedce9b29 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "build" "--frozen" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 6106537250d027d0005edc7c57d84725fee249a2c812444075a60a9f56070f61 [INFO] running `Command { std: "docker" "start" "-a" "6106537250d027d0005edc7c57d84725fee249a2c812444075a60a9f56070f61", kill_on_drop: false }` [INFO] [stderr] Compiling syn v2.0.104 [INFO] [stderr] Compiling libc v0.2.174 [INFO] [stderr] Compiling cfg-if v1.0.1 [INFO] [stderr] Compiling winnow v0.7.11 [INFO] [stderr] Compiling parking_lot_core v0.9.11 [INFO] [stderr] Compiling cc v1.2.29 [INFO] [stderr] Compiling indexmap v2.10.0 [INFO] [stderr] Compiling lock_api v0.4.13 [INFO] [stderr] Compiling memchr v2.7.5 [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling getrandom v0.3.3 [INFO] [stderr] Compiling rustversion v1.0.21 [INFO] [stderr] Compiling slab v0.4.10 [INFO] [stderr] Compiling zeroize v1.8.1 [INFO] [stderr] Compiling rustix v1.0.7 [INFO] [stderr] Compiling serde_json v1.0.140 [INFO] [stderr] Compiling rdkafka-sys v4.9.0+2.10.0 [INFO] [stderr] Compiling rustls-pki-types v1.12.0 [INFO] [stderr] Compiling linux-raw-sys v0.9.4 [INFO] [stderr] Compiling rustls v0.22.4 [INFO] [stderr] Compiling bitflags v2.9.1 [INFO] [stderr] Compiling subtle v2.6.1 [INFO] [stderr] Compiling convert_case v0.4.0 [INFO] [stderr] Compiling crossbeam-queue v0.3.12 [INFO] [stderr] Compiling crc32fast v1.4.2 [INFO] [stderr] Compiling getrandom v0.2.16 [INFO] [stderr] Compiling signal-hook-registry v1.4.5 [INFO] [stderr] Compiling socket2 v0.5.10 [INFO] [stderr] Compiling mio v1.0.4 [INFO] [stderr] Compiling num_cpus v1.17.0 [INFO] [stderr] Compiling memmap2 v0.9.5 [INFO] [stderr] Compiling mio v0.8.11 [INFO] [stderr] Compiling parking_lot v0.12.4 [INFO] [stderr] Compiling ring v0.17.14 [INFO] [stderr] Compiling libz-sys v1.1.22 [INFO] [stderr] Compiling toml_edit v0.22.27 [INFO] [stderr] Compiling serde_derive v1.0.219 [INFO] [stderr] Compiling futures-macro v0.3.31 [INFO] [stderr] Compiling tokio-macros v2.5.0 [INFO] [stderr] Compiling tracing-attributes v0.1.30 [INFO] [stderr] Compiling thiserror-impl v1.0.69 [INFO] [stderr] Compiling derive_more v0.99.20 [INFO] [stderr] Compiling async-trait v0.1.88 [INFO] [stderr] Compiling tempfile v3.20.0 [INFO] [stderr] Compiling tokio v1.46.1 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling thiserror v1.0.69 [INFO] [stderr] Compiling tracing v0.1.41 [INFO] [stderr] Compiling proc-macro-crate v3.3.0 [INFO] [stderr] Compiling num_enum_derive v0.7.4 [INFO] [stderr] Compiling serde v1.0.219 [INFO] [stderr] Compiling rustls-webpki v0.102.8 [INFO] [stderr] Compiling num_enum v0.7.4 [INFO] [stderr] Compiling toml_datetime v0.6.11 [INFO] [stderr] Compiling serde_spanned v0.6.9 [INFO] [stderr] Compiling uuid v1.17.0 [INFO] [stderr] Compiling bincode v1.3.3 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling kawadb-storage v0.1.0 [INFO] [stderr] Compiling toml v0.8.23 [INFO] [stderr] Compiling tokio-rustls v0.25.0 [INFO] [stderr] Compiling rdkafka v0.37.0 [INFO] [stderr] Compiling kawadb-broker v0.1.0 (/opt/rustwide/workdir) [INFO] [stdout] warning: field `client_id` is never read [INFO] [stdout] --> src/client.rs:21:5 [INFO] [stdout] | [INFO] [stdout] 19 | pub struct BrokerClient { [INFO] [stdout] | ------------ field in this struct [INFO] [stdout] 20 | /// クライアントID [INFO] [stdout] 21 | client_id: ClientId, [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `BrokerClient` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `register_session` and `unregister_session` are never used [INFO] [stdout] --> src/server.rs:113:14 [INFO] [stdout] | [INFO] [stdout] 59 | impl BrokerServer { [INFO] [stdout] | ----------------- methods in this implementation [INFO] [stdout] ... [INFO] [stdout] 113 | async fn register_session(&self, session_id: SessionId, client_id: ClientId, remote_addr: std::net::SocketAddr) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 130 | async fn unregister_session(&self, session_id: SessionId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `storage` is never read [INFO] [stdout] --> src/messaging/topic.rs:103:5 [INFO] [stdout] | [INFO] [stdout] 99 | pub struct TopicManager { [INFO] [stdout] | ------------ field in this struct [INFO] [stdout] ... [INFO] [stdout] 103 | storage: Arc, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `TopicManager` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stderr] Finished `dev` profile [unoptimized + debuginfo] target(s) in 1m 42s [INFO] running `Command { std: "docker" "inspect" "6106537250d027d0005edc7c57d84725fee249a2c812444075a60a9f56070f61", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "6106537250d027d0005edc7c57d84725fee249a2c812444075a60a9f56070f61", kill_on_drop: false }` [INFO] [stdout] 6106537250d027d0005edc7c57d84725fee249a2c812444075a60a9f56070f61 [INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-0-tc1/source:/opt/rustwide/workdir:ro,Z" "-v" "/var/lib/crater-agent-workspace/cargo-home:/opt/rustwide/cargo-home:ro,Z" "-v" "/var/lib/crater-agent-workspace/rustup-home:/opt/rustwide/rustup-home:ro,Z" "-e" "SOURCE_DIR=/opt/rustwide/workdir" "-e" "CARGO_TARGET_DIR=/opt/rustwide/target" "-e" "CARGO_INCREMENTAL=0" "-e" "RUST_BACKTRACE=full" "-e" "RUSTFLAGS=--cap-lints=forbid" "-e" "RUSTDOCFLAGS=--cap-lints=forbid" "-e" "CARGO_HOME=/opt/rustwide/cargo-home" "-e" "RUSTUP_HOME=/opt/rustwide/rustup-home" "-w" "/opt/rustwide/workdir" "-m" "1610612736" "--user" "0:0" "--network" "none" "ghcr.io/rust-lang/crates-build-env/linux@sha256:4848fb76d95f26979359cc7e45710b1dbc8f3acb7aeedee7c460d7702230f228" "/opt/rustwide/cargo-home/bin/cargo" "+c90bcb9571b7aab0d8beaa2ce8a998ffaf079d38" "test" "--frozen" "--no-run" "--message-format=json", kill_on_drop: false }` [INFO] [stdout] 493d0428098f452dfc79adb2f844f1bd1ae21f352dffd75a636bcacae07e3b57 [INFO] running `Command { std: "docker" "start" "-a" "493d0428098f452dfc79adb2f844f1bd1ae21f352dffd75a636bcacae07e3b57", kill_on_drop: false }` [INFO] [stderr] Compiling futures-channel v0.3.31 [INFO] [stderr] Compiling zerocopy v0.8.26 [INFO] [stderr] Compiling getrandom v0.3.3 [INFO] [stderr] Compiling tokio v1.46.1 [INFO] [stderr] Compiling async-stream-impl v0.3.6 [INFO] [stderr] Compiling wait-timeout v0.2.1 [INFO] [stderr] Compiling regex-syntax v0.8.5 [INFO] [stderr] Compiling futures-util v0.3.31 [INFO] [stderr] Compiling tempfile v3.20.0 [INFO] [stderr] Compiling rand_core v0.9.3 [INFO] [stderr] Compiling uuid v1.17.0 [INFO] [stderr] Compiling rusty-fork v0.3.0 [INFO] [stderr] Compiling rand_xorshift v0.4.0 [INFO] [stderr] Compiling rand v0.9.1 [INFO] [stderr] Compiling async-stream v0.3.6 [INFO] [stderr] Compiling ppv-lite86 v0.2.21 [INFO] [stderr] Compiling rand_chacha v0.9.0 [INFO] [stderr] Compiling proptest v1.7.0 [INFO] [stderr] Compiling futures-executor v0.3.31 [INFO] [stderr] Compiling futures v0.3.31 [INFO] [stderr] Compiling tokio-rustls v0.25.0 [INFO] [stderr] Compiling tokio-stream v0.1.17 [INFO] [stderr] Compiling rdkafka v0.37.0 [INFO] [stderr] Compiling kawadb-storage v0.1.0 [INFO] [stderr] Compiling tokio-test v0.4.4 [INFO] [stderr] Compiling kawadb-broker v0.1.0 (/opt/rustwide/workdir) [INFO] [stdout] warning: field `client_id` is never read [INFO] [stdout] --> src/client.rs:21:5 [INFO] [stdout] | [INFO] [stdout] 19 | pub struct BrokerClient { [INFO] [stdout] | ------------ field in this struct [INFO] [stdout] 20 | /// クライアントID [INFO] [stdout] 21 | client_id: ClientId, [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `BrokerClient` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `register_session` and `unregister_session` are never used [INFO] [stdout] --> src/server.rs:113:14 [INFO] [stdout] | [INFO] [stdout] 59 | impl BrokerServer { [INFO] [stdout] | ----------------- methods in this implementation [INFO] [stdout] ... [INFO] [stdout] 113 | async fn register_session(&self, session_id: SessionId, client_id: ClientId, remote_addr: std::net::SocketAddr) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 130 | async fn unregister_session(&self, session_id: SessionId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `storage` is never read [INFO] [stdout] --> src/messaging/topic.rs:103:5 [INFO] [stdout] | [INFO] [stdout] 99 | pub struct TopicManager { [INFO] [stdout] | ------------ field in this struct [INFO] [stdout] ... [INFO] [stdout] 103 | storage: Arc, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `TopicManager` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `client_id` is never read [INFO] [stdout] --> src/client.rs:21:5 [INFO] [stdout] | [INFO] [stdout] 19 | pub struct BrokerClient { [INFO] [stdout] | ------------ field in this struct [INFO] [stdout] 20 | /// クライアントID [INFO] [stdout] 21 | client_id: ClientId, [INFO] [stdout] | ^^^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `BrokerClient` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] = note: `#[warn(dead_code)]` (part of `#[warn(unused)]`) on by default [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: methods `register_session` and `unregister_session` are never used [INFO] [stdout] --> src/server.rs:113:14 [INFO] [stdout] | [INFO] [stdout] 59 | impl BrokerServer { [INFO] [stdout] | ----------------- methods in this implementation [INFO] [stdout] ... [INFO] [stdout] 113 | async fn register_session(&self, session_id: SessionId, client_id: ClientId, remote_addr: std::net::SocketAddr) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 130 | async fn unregister_session(&self, session_id: SessionId) { [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] warning: field `storage` is never read [INFO] [stdout] --> src/messaging/topic.rs:103:5 [INFO] [stdout] | [INFO] [stdout] 99 | pub struct TopicManager { [INFO] [stdout] | ------------ field in this struct [INFO] [stdout] ... [INFO] [stdout] 103 | storage: Arc, [INFO] [stdout] | ^^^^^^^ [INFO] [stdout] | [INFO] [stdout] = note: `TopicManager` has a derived impl for the trait `Debug`, but this is intentionally ignored during dead code analysis [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0432]: unresolved import `kawa_broker` [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:6:5 [INFO] [stdout] | [INFO] [stdout] 6 | use kawa_broker::{ [INFO] [stdout] | ^^^^^^^^^^^ use of unresolved module or unlinked crate `kawa_broker` [INFO] [stdout] | [INFO] [stdout] help: there is a crate or module with a similar name [INFO] [stdout] | [INFO] [stdout] 6 | use kawadb_broker::{ [INFO] [stdout] | ++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:18:18 [INFO] [stdout] | [INFO] [stdout] 18 | let broker = MessageBroker::new(config).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed for `(_, _)` [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:25:9 [INFO] [stdout] | [INFO] [stdout] 25 | let (mut broker, _temp_dir) = create_test_broker().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 29 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving this pattern a type, where the placeholders `_` are specified [INFO] [stdout] | [INFO] [stdout] 25 | let (mut broker, _temp_dir): (_, _) = create_test_broker().await; [INFO] [stdout] | ++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:29:17 [INFO] [stdout] | [INFO] [stdout] 29 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:32:5 [INFO] [stdout] | [INFO] [stdout] 32 | broker.create_topic("test_topic", 1, 1).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:36:18 [INFO] [stdout] | [INFO] [stdout] 36 | let offset = broker.produce_message("test_topic", 0, message, session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:44:22 [INFO] [stdout] | [INFO] [stdout] 44 | let offset = broker.produce_message("test_topic", 0, msg.as_bytes(), session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:49:5 [INFO] [stdout] | [INFO] [stdout] 49 | broker.stop().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed for `(_, _)` [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:55:9 [INFO] [stdout] | [INFO] [stdout] 55 | let (mut broker, _temp_dir) = create_test_broker().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 59 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving this pattern a type, where the placeholders `_` are specified [INFO] [stdout] | [INFO] [stdout] 55 | let (mut broker, _temp_dir): (_, _) = create_test_broker().await; [INFO] [stdout] | ++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:59:17 [INFO] [stdout] | [INFO] [stdout] 59 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:62:5 [INFO] [stdout] | [INFO] [stdout] 62 | broker.create_topic("test_topic", 1, 1).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:72:22 [INFO] [stdout] | [INFO] [stdout] 72 | let offset = broker.produce_message("test_topic", 0, msg.as_bytes(), session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:78:29 [INFO] [stdout] | [INFO] [stdout] 78 | let consumed_messages = broker.fetch_messages("test_topic", 0, 0, 10, session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:91:5 [INFO] [stdout] | [INFO] [stdout] 91 | broker.stop().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed for `(_, _)` [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:97:9 [INFO] [stdout] | [INFO] [stdout] 97 | let (mut broker, _temp_dir) = create_test_broker().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 101 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving this pattern a type, where the placeholders `_` are specified [INFO] [stdout] | [INFO] [stdout] 97 | let (mut broker, _temp_dir): (_, _) = create_test_broker().await; [INFO] [stdout] | ++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:101:17 [INFO] [stdout] | [INFO] [stdout] 101 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:104:5 [INFO] [stdout] | [INFO] [stdout] 104 | broker.create_topic("multi_partition_topic", 3, 1).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:110:26 [INFO] [stdout] | [INFO] [stdout] 110 | let offset = broker.produce_message("multi_partition_topic", partition, msg.as_bytes(), session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:117:24 [INFO] [stdout] | [INFO] [stdout] 117 | let messages = broker.fetch_messages("multi_partition_topic", partition, 0, 10, session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:129:5 [INFO] [stdout] | [INFO] [stdout] 129 | broker.stop().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed for `(_, _)` [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:135:9 [INFO] [stdout] | [INFO] [stdout] 135 | let (mut broker, _temp_dir) = create_test_broker().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 139 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving this pattern a type, where the placeholders `_` are specified [INFO] [stdout] | [INFO] [stdout] 135 | let (mut broker, _temp_dir): (_, _) = create_test_broker().await; [INFO] [stdout] | ++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:139:17 [INFO] [stdout] | [INFO] [stdout] 139 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:142:5 [INFO] [stdout] | [INFO] [stdout] 142 | broker.create_topic("group_topic", 2, 1).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:145:5 [INFO] [stdout] | [INFO] [stdout] 145 | broker.create_consumer_group("test_group", "range").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:151:22 [INFO] [stdout] | [INFO] [stdout] 151 | let offset = broker.produce_message("group_topic", partition, msg.as_bytes(), session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:156:5 [INFO] [stdout] | [INFO] [stdout] 156 | broker.stop().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed for `(_, _)` [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:162:9 [INFO] [stdout] | [INFO] [stdout] 162 | let (mut broker, _temp_dir) = create_test_broker().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 166 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving this pattern a type, where the placeholders `_` are specified [INFO] [stdout] | [INFO] [stdout] 162 | let (mut broker, _temp_dir): (_, _) = create_test_broker().await; [INFO] [stdout] | ++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:166:17 [INFO] [stdout] | [INFO] [stdout] 166 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:169:5 [INFO] [stdout] | [INFO] [stdout] 169 | broker.create_topic("offset_topic", 1, 1).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:174:22 [INFO] [stdout] | [INFO] [stdout] 174 | let offset = broker.produce_message("offset_topic", 0, msg.as_bytes(), session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:179:20 [INFO] [stdout] | [INFO] [stdout] 179 | let messages = broker.fetch_messages("offset_topic", 0, 1, 10, session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:186:20 [INFO] [stdout] | [INFO] [stdout] 186 | let messages = broker.fetch_messages("offset_topic", 0, 3, 2, session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:192:5 [INFO] [stdout] | [INFO] [stdout] 192 | broker.stop().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed for `(_, _)` [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:198:9 [INFO] [stdout] | [INFO] [stdout] 198 | let (mut broker, _temp_dir) = create_test_broker().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 202 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving this pattern a type, where the placeholders `_` are specified [INFO] [stdout] | [INFO] [stdout] 198 | let (mut broker, _temp_dir): (_, _) = create_test_broker().await; [INFO] [stdout] | ++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:202:17 [INFO] [stdout] | [INFO] [stdout] 202 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:205:9 [INFO] [stdout] | [INFO] [stdout] 205 | let result = broker.produce_message("nonexistent_topic", 0, b"test", session_id).await; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 206 | assert!(result.is_err()); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `result` an explicit type [INFO] [stdout] | [INFO] [stdout] 205 | let result: /* Type */ = broker.produce_message("nonexistent_topic", 0, b"test", session_id).await; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:210:9 [INFO] [stdout] | [INFO] [stdout] 210 | let result = broker.fetch_messages("nonexistent_topic", 0, 0, 1, session_id).await; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 211 | assert!(result.is_err()); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `result` an explicit type [INFO] [stdout] | [INFO] [stdout] 210 | let result: /* Type */ = broker.fetch_messages("nonexistent_topic", 0, 0, 1, session_id).await; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:215:5 [INFO] [stdout] | [INFO] [stdout] 215 | broker.create_topic("test_topic", 2, 1).await.unwrap(); // 2パーティション [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:217:9 [INFO] [stdout] | [INFO] [stdout] 217 | let result = broker.produce_message("test_topic", 5, b"test", session_id).await; // パーティション5は無効 [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 218 | assert!(result.is_err()); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `result` an explicit type [INFO] [stdout] | [INFO] [stdout] 217 | let result: /* Type */ = broker.produce_message("test_topic", 5, b"test", session_id).await; // パーティション5は無効 [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:221:5 [INFO] [stdout] | [INFO] [stdout] 221 | broker.stop().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed for `(_, _)` [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:227:9 [INFO] [stdout] | [INFO] [stdout] 227 | let (mut broker, _temp_dir) = create_test_broker().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 231 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving this pattern a type, where the placeholders `_` are specified [INFO] [stdout] | [INFO] [stdout] 227 | let (mut broker, _temp_dir): (_, _) = create_test_broker().await; [INFO] [stdout] | ++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:231:17 [INFO] [stdout] | [INFO] [stdout] 231 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:234:5 [INFO] [stdout] | [INFO] [stdout] 234 | broker.create_topic("perf_topic", 1, 1).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:242:23 [INFO] [stdout] | [INFO] [stdout] 242 | let _offset = broker.produce_message("perf_topic", 0, message, session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:259:24 [INFO] [stdout] | [INFO] [stdout] 259 | let messages = broker.fetch_messages("perf_topic", 0, offset, 100, session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:283:5 [INFO] [stdout] | [INFO] [stdout] 283 | broker.stop().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed for `(_, _)` [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:289:9 [INFO] [stdout] | [INFO] [stdout] 289 | let (mut broker, _temp_dir) = create_test_broker().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 292 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving this pattern a type, where the placeholders `_` are specified [INFO] [stdout] | [INFO] [stdout] 289 | let (mut broker, _temp_dir): (_, _) = create_test_broker().await; [INFO] [stdout] | ++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:292:17 [INFO] [stdout] | [INFO] [stdout] 292 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:295:18 [INFO] [stdout] | [INFO] [stdout] 295 | let topics = broker.list_topics().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:300:5 [INFO] [stdout] | [INFO] [stdout] 300 | broker.create_topic("topic1", 1, 1).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:301:5 [INFO] [stdout] | [INFO] [stdout] 301 | broker.create_topic("topic2", 3, 1).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:302:5 [INFO] [stdout] | [INFO] [stdout] 302 | broker.create_topic("topic3", 2, 1).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:305:18 [INFO] [stdout] | [INFO] [stdout] 305 | let topics = broker.list_topics().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:313:5 [INFO] [stdout] | [INFO] [stdout] 313 | broker.delete_topic("topic2").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:314:18 [INFO] [stdout] | [INFO] [stdout] 314 | let topics = broker.list_topics().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:320:9 [INFO] [stdout] | [INFO] [stdout] 320 | let result = broker.create_topic("topic1", 1, 1).await; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 321 | assert!(result.is_err()); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `result` an explicit type [INFO] [stdout] | [INFO] [stdout] 320 | let result: /* Type */ = broker.create_topic("topic1", 1, 1).await; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:325:9 [INFO] [stdout] | [INFO] [stdout] 325 | let result = broker.delete_topic("nonexistent").await; [INFO] [stdout] | ^^^^^^ [INFO] [stdout] 326 | assert!(result.is_err()); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving `result` an explicit type [INFO] [stdout] | [INFO] [stdout] 325 | let result: /* Type */ = broker.delete_topic("nonexistent").await; [INFO] [stdout] | ++++++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:329:5 [INFO] [stdout] | [INFO] [stdout] 329 | broker.stop().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed for `(_, _)` [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:335:9 [INFO] [stdout] | [INFO] [stdout] 335 | let (mut broker, _temp_dir) = create_test_broker().await; [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^ [INFO] [stdout] ... [INFO] [stdout] 339 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ------ type must be known at this point [INFO] [stdout] | [INFO] [stdout] help: consider giving this pattern a type, where the placeholders `_` are specified [INFO] [stdout] | [INFO] [stdout] 335 | let (mut broker, _temp_dir): (_, _) = create_test_broker().await; [INFO] [stdout] | ++++++++ [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:339:17 [INFO] [stdout] | [INFO] [stdout] 339 | let _addr = broker.start().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:342:17 [INFO] [stdout] | [INFO] [stdout] 342 | let stats = broker.get_stats().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:348:5 [INFO] [stdout] | [INFO] [stdout] 348 | broker.create_topic("stats_topic", 2, 1).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:349:5 [INFO] [stdout] | [INFO] [stdout] 349 | broker.create_consumer_group("stats_group", "range").await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:354:23 [INFO] [stdout] | [INFO] [stdout] 354 | let _offset = broker.produce_message("stats_topic", 0, msg.as_bytes(), session_id).await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:358:17 [INFO] [stdout] | [INFO] [stdout] 358 | let stats = broker.get_stats().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] error[E0282]: type annotations needed [INFO] [stdout] --> tests/producer_consumer_integration_test.rs:363:5 [INFO] [stdout] | [INFO] [stdout] 363 | broker.stop().await.unwrap(); [INFO] [stdout] | ^^^^^^^^^^^^^^^^^^^ cannot infer type [INFO] [stdout] [INFO] [stdout] [INFO] [stdout] Some errors have detailed explanations: E0282, E0432. [INFO] [stdout] [INFO] [stdout] For more information about an error, try `rustc --explain E0282`. [INFO] [stdout] [INFO] [stderr] error: could not compile `kawadb-broker` (test "producer_consumer_integration_test") due to 66 previous errors [INFO] [stderr] warning: build failed, waiting for other jobs to finish... [INFO] running `Command { std: "docker" "inspect" "493d0428098f452dfc79adb2f844f1bd1ae21f352dffd75a636bcacae07e3b57", kill_on_drop: false }` [INFO] running `Command { std: "docker" "rm" "-f" "493d0428098f452dfc79adb2f844f1bd1ae21f352dffd75a636bcacae07e3b57", kill_on_drop: false }` [INFO] [stdout] 493d0428098f452dfc79adb2f844f1bd1ae21f352dffd75a636bcacae07e3b57