[INFO] cloning repository https://github.com/gregberns/materialize-writer
[INFO] running `Command { std: "git" "-c" "credential.helper=" "-c" "credential.helper=/workspace/cargo-home/bin/git-credential-null" "clone" "--bare" "https://github.com/gregberns/materialize-writer" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fgregberns%2Fmaterialize-writer", kill_on_drop: false }`
[INFO] [stderr] Cloning into bare repository '/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fgregberns%2Fmaterialize-writer'...
[INFO] running `Command { std: "git" "rev-parse" "HEAD", kill_on_drop: false }`
[INFO] [stdout] 4c8cb9ca1f10ae2ff0a1130e21426309e74f020b
[INFO] checking gregberns/materialize-writer against try#a7a572ce3edd6d476191fbfe92c9c1986e009b34 for pr-87190-3
[INFO] running `Command { std: "git" "clone" "/workspace/cache/git-repos/https%3A%2F%2Fgithub.com%2Fgregberns%2Fmaterialize-writer" "/workspace/builds/worker-107/source", kill_on_drop: false }`
[INFO] [stderr] Cloning into '/workspace/builds/worker-107/source'...
[INFO] [stderr] done.
[INFO] validating manifest of git repo https://github.com/gregberns/materialize-writer on toolchain a7a572ce3edd6d476191fbfe92c9c1986e009b34
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+a7a572ce3edd6d476191fbfe92c9c1986e009b34" "metadata" "--manifest-path" "Cargo.toml" "--no-deps", kill_on_drop: false }`
[INFO] started tweaking git repo https://github.com/gregberns/materialize-writer
[INFO] finished tweaking git repo https://github.com/gregberns/materialize-writer
[INFO] tweaked toml for git repo https://github.com/gregberns/materialize-writer written to /workspace/builds/worker-107/source/Cargo.toml
[INFO] crate git repo https://github.com/gregberns/materialize-writer already has a lockfile, it will not be regenerated
[INFO] running `Command { std: "/workspace/cargo-home/bin/cargo" "+a7a572ce3edd6d476191fbfe92c9c1986e009b34" "fetch" "--manifest-path" "Cargo.toml", kill_on_drop: false }`
[INFO] [stderr]     Blocking waiting for file lock on package cache
[INFO] [stderr]     Updating git repository `https://github.com/MaterializeInc/avro-rs.git`
[INFO] [stderr]     Blocking waiting for file lock on package cache
[INFO] [stderr]  Downloading crates ...
[INFO] [stderr]   Downloaded num_enum_derive v0.4.2
[INFO] [stderr]   Downloaded rdkafka v0.23.1
[INFO] [stderr]   Downloaded num_enum v0.4.2
[INFO] [stderr]   Downloaded rdkafka-sys v1.3.1
[INFO] [stderr]   Downloaded openssl-src v111.6.1+1.1.1d
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-107/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-107/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" "+a7a572ce3edd6d476191fbfe92c9c1986e009b34" "metadata" "--no-deps" "--format-version=1", kill_on_drop: false }`
[INFO] [stdout] 640683ea7ecb65907f21de6901e2c7529eb1d3f82b77fd7cf803f356b8968050
[INFO] running `Command { std: "docker" "start" "-a" "640683ea7ecb65907f21de6901e2c7529eb1d3f82b77fd7cf803f356b8968050", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "inspect" "640683ea7ecb65907f21de6901e2c7529eb1d3f82b77fd7cf803f356b8968050", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "640683ea7ecb65907f21de6901e2c7529eb1d3f82b77fd7cf803f356b8968050", kill_on_drop: false }`
[INFO] [stdout] 640683ea7ecb65907f21de6901e2c7529eb1d3f82b77fd7cf803f356b8968050
[INFO] running `Command { std: "docker" "create" "-v" "/var/lib/crater-agent-workspace/builds/worker-107/target:/opt/rustwide/target:rw,Z" "-v" "/var/lib/crater-agent-workspace/builds/worker-107/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" "+a7a572ce3edd6d476191fbfe92c9c1986e009b34" "check" "--frozen" "--all" "--all-targets" "--message-format=json", kill_on_drop: false }`
[INFO] [stdout] d488f5bc1c70a2519d1590ef7aee16b7fe18b86e3a00081b2af527127807ff4b
[INFO] running `Command { std: "docker" "start" "-a" "d488f5bc1c70a2519d1590ef7aee16b7fe18b86e3a00081b2af527127807ff4b", kill_on_drop: false }`
[INFO] [stderr] Copying to /tmp/fixit
[INFO] [stderr] Running `cargo fix --edition`
[INFO] [stderr]     Blocking waiting for file lock on package cache
[INFO] [stderr] note: Switching to Edition 2021 will enable the use of the version 2 feature resolver in Cargo.
[INFO] [stderr] This may cause some dependencies to be built with fewer features enabled than previously.
[INFO] [stderr] More information about the resolver changes may be found at https://doc.rust-lang.org/nightly/edition-guide/rust-2021/default-cargo-resolver.html
[INFO] [stderr] When building the following dependencies, the given features will no longer be used:
[INFO] [stderr] 
[INFO] [stderr]   serde v1.0.104 (as host dependency): derive, serde_derive
[INFO] [stderr]   tokio v0.2.11: winapi
[INFO] [stderr] 
[INFO] [stderr]    Compiling proc-macro2 v1.0.8
[INFO] [stderr]    Compiling syn v1.0.14
[INFO] [stderr]    Compiling libc v0.2.66
[INFO] [stderr]    Compiling cc v1.0.50
[INFO] [stderr]    Compiling pkg-config v0.3.17
[INFO] [stderr]    Compiling log v0.4.8
[INFO] [stderr]    Compiling memchr v2.3.2
[INFO] [stderr]    Compiling syn v0.15.44
[INFO] [stderr]    Compiling typenum v1.11.2
[INFO] [stderr]     Checking futures-sink v0.3.4
[INFO] [stderr]     Checking itoa v0.4.5
[INFO] [stderr]     Checking traitobject v0.1.0
[INFO] [stderr]     Checking unicode-width v0.1.7
[INFO] [stderr]     Checking rle-decode-fast v1.0.1
[INFO] [stderr]     Checking quick-error v1.2.3
[INFO] [stderr]     Checking take_mut v0.2.2
[INFO] [stderr]     Checking arc-swap v0.3.11
[INFO] [stderr]     Checking antidote v1.0.0
[INFO] [stderr]     Checking log-mdc v0.1.0
[INFO] [stderr]    Compiling serde v1.0.104
[INFO] [stderr]    Compiling num-traits v0.2.11
[INFO] [stderr]    Compiling proc-macro-nested v0.1.3
[INFO] [stderr]    Compiling ryu v1.0.2
[INFO] [stderr]    Compiling failure_derive v0.1.6
[INFO] [stderr]     Checking yaml-rust v0.4.3
[INFO] [stderr]     Checking miniz_oxide v0.3.6
[INFO] [stderr]     Checking crc32fast v1.2.0
[INFO] [stderr]    Compiling num-integer v0.1.42
[INFO] [stderr]     Checking unsafe-any v0.4.2
[INFO] [stderr]     Checking textwrap v0.11.0
[INFO] [stderr]     Checking libflate v0.1.27
[INFO] [stderr]     Checking typemap v0.3.3
[INFO] [stderr]     Checking futures-channel v0.3.4
[INFO] [stderr]     Checking humantime v1.3.0
[INFO] [stderr]    Compiling openssl-src v111.6.1+1.1.1d
[INFO] [stderr]    Compiling cmake v0.1.42
[INFO] [stderr]    Compiling libz-sys v1.0.25
[INFO] [stderr]    Compiling backtrace-sys v0.1.32
[INFO] [stderr]     Checking iovec v0.1.4
[INFO] [stderr]     Checking net2 v0.2.33
[INFO] [stderr]     Checking time v0.1.42
[INFO] [stderr]     Checking num_cpus v1.12.0
[INFO] [stderr]     Checking signal-hook-registry v1.2.0
[INFO] [stderr]     Checking thread-id v3.3.0
[INFO] [stderr]     Checking rand v0.4.6
[INFO] [stderr]     Checking atty v0.2.14
[INFO] [stderr]     Checking flate2 v1.0.13
[INFO] [stderr]    Compiling openssl-sys v0.9.54
[INFO] [stderr]     Checking ordered-float v1.0.2
[INFO] [stderr]    Compiling rdkafka-sys v1.3.1
[INFO] [stderr]    Compiling quote v1.0.2
[INFO] [stderr]     Checking clap v2.33.0
[INFO] [stderr]     Checking generic-array v0.12.3
[INFO] [stderr]     Checking chrono v0.4.10
[INFO] [stderr]     Checking digest v0.8.1
[INFO] [stderr]     Checking backtrace v0.3.44
[INFO] [stderr]    Compiling derivative v1.0.3
[INFO] [stderr]    Compiling synstructure v0.12.3
[INFO] [stderr]    Compiling serde_derive v1.0.104
[INFO] [stderr]    Compiling proc-macro-hack v0.5.11
[INFO] [stderr]    Compiling tokio-macros v0.2.4
[INFO] [stderr]     Checking failure v0.1.6
[INFO] [stderr]    Compiling futures-macro v0.3.4
[INFO] [stderr]     Checking futures-util v0.3.4
[INFO] [stderr]     Checking futures-executor v0.3.4
[INFO] [stderr]     Checking futures v0.3.4
[INFO] [stderr]     Checking serde_json v1.0.48
[INFO] [stderr]     Checking serde-value v0.5.3
[INFO] [stderr]     Checking serde_yaml v0.8.11
[INFO] [stderr]     Checking mio v0.6.21
[INFO] [stderr]    Compiling toml v0.5.6
[INFO] [stderr]     Checking mio-uds v0.6.7
[INFO] [stderr]     Checking avro-rs v0.6.5 (https://github.com/MaterializeInc/avro-rs.git#dd965e45)
[INFO] [stderr]     Checking log4rs v0.8.3
[INFO] [stderr]     Checking tokio v0.2.11
[INFO] [stderr]    Compiling proc-macro-crate v0.1.4
[INFO] [stderr]    Compiling num_enum_derive v0.4.2
[INFO] [stderr]     Checking num_enum v0.4.2
[INFO] [stderr]     Checking rdkafka v0.23.1
[INFO] [stderr]     Checking reader v0.1.0 (/tmp/fixit)
[INFO] [stderr]    Migrating src/main.rs from 2018 edition to 2021
[INFO] [stderr]        Fixed src/main.rs (16 fixes)
[INFO] [stdout] warning: unused import: `futures::StreamExt`
[INFO] [stdout]  --> src/main.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use futures::StreamExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `futures_util::future::FutureExt`
[INFO] [stdout]  --> src/main.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 | use futures_util::future::FutureExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Message`
[INFO] [stdout]   --> src/main.rs:17:24
[INFO] [stdout]    |
[INFO] [stdout] 17 | use rdkafka::message::{Message};
[INFO] [stdout]    |                        ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::future::Future`
[INFO] [stdout]   --> src/main.rs:24:5
[INFO] [stdout]    |
[INFO] [stdout] 24 | use std::future::Future;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `futures::StreamExt`
[INFO] [stdout]  --> src/main.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use futures::StreamExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `futures_util::future::FutureExt`
[INFO] [stdout]  --> src/main.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 | use futures_util::future::FutureExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Message`
[INFO] [stdout]   --> src/main.rs:17:24
[INFO] [stdout]    |
[INFO] [stdout] 17 | use rdkafka::message::{Message};
[INFO] [stdout]    |                        ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::future::Future`
[INFO] [stdout]   --> src/main.rs:24:5
[INFO] [stdout]    |
[INFO] [stdout] 24 | use std::future::Future;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `encode_to_vec`
[INFO] [stdout]    --> src/avro_encode.rs:175:8
[INFO] [stdout]     |
[INFO] [stdout] 175 | pub fn encode_to_vec(value: &Value, schema: &Schema) -> Vec<u8> {
[INFO] [stdout]     |        ^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type alias is never used: `LoggingConsumer`
[INFO] [stdout]   --> src/main.rs:47:1
[INFO] [stdout]    |
[INFO] [stdout] 47 | type LoggingConsumer = StreamConsumer<CustomContext>;
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `get_consumer`
[INFO] [stdout]    --> src/main.rs:135:4
[INFO] [stdout]     |
[INFO] [stdout] 135 | fn get_consumer<'a>(
[INFO] [stdout]     |    ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `serialize`
[INFO] [stdout]    --> src/main.rs:199:4
[INFO] [stdout]     |
[INFO] [stdout] 199 | fn serialize() -> Result<Vec<u8>, Error> {
[INFO] [stdout]     |    ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `process_message_stream`
[INFO] [stdout]    --> src/main.rs:319:10
[INFO] [stdout]     |
[INFO] [stdout] 319 | async fn process_message_stream(consumer: &LoggingConsumer) {
[INFO] [stdout]     |          ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `decode`
[INFO] [stdout]    --> src/main.rs:342:4
[INFO] [stdout]     |
[INFO] [stdout] 342 | fn decode(schema: &Schema, bytes: &mut &[u8]) -> Result<DiffPair, failure::Error> {
[INFO] [stdout]     |    ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `encode_to_vec`
[INFO] [stdout]    --> src/avro_encode.rs:175:8
[INFO] [stdout]     |
[INFO] [stdout] 175 | pub fn encode_to_vec(value: &Value, schema: &Schema) -> Vec<u8> {
[INFO] [stdout]     |        ^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type alias is never used: `LoggingConsumer`
[INFO] [stdout]   --> src/main.rs:47:1
[INFO] [stdout]    |
[INFO] [stdout] 47 | type LoggingConsumer = StreamConsumer<CustomContext>;
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `get_consumer`
[INFO] [stdout]    --> src/main.rs:135:4
[INFO] [stdout]     |
[INFO] [stdout] 135 | fn get_consumer<'a>(
[INFO] [stdout]     |    ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `serialize`
[INFO] [stdout]    --> src/main.rs:199:4
[INFO] [stdout]     |
[INFO] [stdout] 199 | fn serialize() -> Result<Vec<u8>, Error> {
[INFO] [stdout]     |    ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `deserialize`
[INFO] [stdout]    --> src/main.rs:274:4
[INFO] [stdout]     |
[INFO] [stdout] 274 | fn deserialize(bytes: &Vec<u8>) -> Result<String, Error> {
[INFO] [stdout]     |    ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `process_message_stream`
[INFO] [stdout]    --> src/main.rs:319:10
[INFO] [stdout]     |
[INFO] [stdout] 319 | async fn process_message_stream(consumer: &LoggingConsumer) {
[INFO] [stdout]     |          ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `decode`
[INFO] [stdout]    --> src/main.rs:342:4
[INFO] [stdout]     |
[INFO] [stdout] 342 | fn decode(schema: &Schema, bytes: &mut &[u8]) -> Result<DiffPair, failure::Error> {
[INFO] [stdout]     |    ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 10 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 11 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 40.16s
[INFO] [stderr] Running `cargo check` to verify 2021
[INFO] [stderr]     Blocking waiting for file lock on package cache
[INFO] [stderr]    Compiling serde v1.0.104
[INFO] [stderr]     Checking tokio v0.2.11
[INFO] [stderr]    Compiling toml v0.5.6
[INFO] [stderr]    Compiling proc-macro-crate v0.1.4
[INFO] [stderr]    Compiling num_enum_derive v0.4.2
[INFO] [stderr]     Checking num_enum v0.4.2
[INFO] [stderr]     Checking rdkafka-sys v1.3.1
[INFO] [stderr]     Checking rdkafka v0.23.1
[INFO] [stderr]     Checking reader v0.1.0 (/tmp/fixit)
[INFO] [stdout] warning: unused import: `futures::StreamExt`
[INFO] [stdout]  --> src/main.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use futures::StreamExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `futures_util::future::FutureExt`
[INFO] [stdout]  --> src/main.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 | use futures_util::future::FutureExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Message`
[INFO] [stdout]   --> src/main.rs:17:24
[INFO] [stdout]    |
[INFO] [stdout] 17 | use rdkafka::message::{Message};
[INFO] [stdout]    |                        ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::future::Future`
[INFO] [stdout]   --> src/main.rs:24:5
[INFO] [stdout]    |
[INFO] [stdout] 24 | use std::future::Future;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `futures::StreamExt`
[INFO] [stdout]  --> src/main.rs:8:5
[INFO] [stdout]   |
[INFO] [stdout] 8 | use futures::StreamExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^
[INFO] [stdout]   |
[INFO] [stdout]   = note: `#[warn(unused_imports)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `futures_util::future::FutureExt`
[INFO] [stdout]  --> src/main.rs:9:5
[INFO] [stdout]   |
[INFO] [stdout] 9 | use futures_util::future::FutureExt;
[INFO] [stdout]   |     ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `Message`
[INFO] [stdout]   --> src/main.rs:17:24
[INFO] [stdout]    |
[INFO] [stdout] 17 | use rdkafka::message::{Message};
[INFO] [stdout]    |                        ^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: unused import: `std::future::Future`
[INFO] [stdout]   --> src/main.rs:24:5
[INFO] [stdout]    |
[INFO] [stdout] 24 | use std::future::Future;
[INFO] [stdout]    |     ^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `encode_to_vec`
[INFO] [stdout]    --> src/avro_encode.rs:175:8
[INFO] [stdout]     |
[INFO] [stdout] 175 | pub fn encode_to_vec(value: &Value, schema: &Schema) -> Vec<u8> {
[INFO] [stdout]     |        ^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type alias is never used: `LoggingConsumer`
[INFO] [stdout]   --> src/main.rs:47:1
[INFO] [stdout]    |
[INFO] [stdout] 47 | type LoggingConsumer = StreamConsumer<CustomContext>;
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `get_consumer`
[INFO] [stdout]    --> src/main.rs:135:4
[INFO] [stdout]     |
[INFO] [stdout] 135 | fn get_consumer<'a>(
[INFO] [stdout]     |    ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `serialize`
[INFO] [stdout]    --> src/main.rs:199:4
[INFO] [stdout]     |
[INFO] [stdout] 199 | fn serialize() -> Result<Vec<u8>, Error> {
[INFO] [stdout]     |    ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `deserialize`
[INFO] [stdout]    --> src/main.rs:274:4
[INFO] [stdout]     |
[INFO] [stdout] 274 | fn deserialize(bytes: &Vec<u8>) -> Result<String, Error> {
[INFO] [stdout]     |    ^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `process_message_stream`
[INFO] [stdout]    --> src/main.rs:319:10
[INFO] [stdout]     |
[INFO] [stdout] 319 | async fn process_message_stream(consumer: &LoggingConsumer) {
[INFO] [stdout]     |          ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `decode`
[INFO] [stdout]    --> src/main.rs:342:4
[INFO] [stdout]     |
[INFO] [stdout] 342 | fn decode(schema: &Schema, bytes: &mut &[u8]) -> Result<DiffPair, failure::Error> {
[INFO] [stdout]     |    ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 11 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `encode_to_vec`
[INFO] [stdout]    --> src/avro_encode.rs:175:8
[INFO] [stdout]     |
[INFO] [stdout] 175 | pub fn encode_to_vec(value: &Value, schema: &Schema) -> Vec<u8> {
[INFO] [stdout]     |        ^^^^^^^^^^^^^
[INFO] [stdout]     |
[INFO] [stdout]     = note: `#[warn(dead_code)]` on by default
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: type alias is never used: `LoggingConsumer`
[INFO] [stdout]   --> src/main.rs:47:1
[INFO] [stdout]    |
[INFO] [stdout] 47 | type LoggingConsumer = StreamConsumer<CustomContext>;
[INFO] [stdout]    | ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `get_consumer`
[INFO] [stdout]    --> src/main.rs:135:4
[INFO] [stdout]     |
[INFO] [stdout] 135 | fn get_consumer<'a>(
[INFO] [stdout]     |    ^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `serialize`
[INFO] [stdout]    --> src/main.rs:199:4
[INFO] [stdout]     |
[INFO] [stdout] 199 | fn serialize() -> Result<Vec<u8>, Error> {
[INFO] [stdout]     |    ^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `process_message_stream`
[INFO] [stdout]    --> src/main.rs:319:10
[INFO] [stdout]     |
[INFO] [stdout] 319 | async fn process_message_stream(consumer: &LoggingConsumer) {
[INFO] [stdout]     |          ^^^^^^^^^^^^^^^^^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: function is never used: `decode`
[INFO] [stdout]    --> src/main.rs:342:4
[INFO] [stdout]     |
[INFO] [stdout] 342 | fn decode(schema: &Schema, bytes: &mut &[u8]) -> Result<DiffPair, failure::Error> {
[INFO] [stdout]     |    ^^^^^^
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stdout] warning: 10 warnings emitted
[INFO] [stdout] 
[INFO] [stdout] 
[INFO] [stderr]     Finished dev [unoptimized + debuginfo] target(s) in 46.73s
[INFO] running `Command { std: "docker" "inspect" "d488f5bc1c70a2519d1590ef7aee16b7fe18b86e3a00081b2af527127807ff4b", kill_on_drop: false }`
[INFO] running `Command { std: "docker" "rm" "-f" "d488f5bc1c70a2519d1590ef7aee16b7fe18b86e3a00081b2af527127807ff4b", kill_on_drop: false }`
[INFO] [stdout] d488f5bc1c70a2519d1590ef7aee16b7fe18b86e3a00081b2af527127807ff4b