Connection is poisoned: Cannot read framed message: Cannot read data: early eof

[TaKO8Ki]

Thank you for the great crate!

I got the following error. Can I fix this error? I would appreciate it if you could share it with me if you have a good idea,

Errors:

Failed to connect to broker","e":"cannot sync versions: Request error: Connection is poisoned: Cannot read framed message: Cannot read data: early eof

rskafka version: 0.5.0
Apache Kafka version: 2.6.2

I use Amazon MSK and have three brokers.

source code:

use rskafka::{
    client::{ClientBuilder, SaslConfig},
};

let client =
    ClientBuilder::new(connection)
        .sasl_config(SaslConfig::Plain {
            username: sasl_username,
            password: sasl_password,
        });;

debug!("start building client");
let client = client.build().await?; // This line causes errors.

[pdeva]

i am seeing this error too...

[pdeva]

mine is failing on this:

 let (record, high_water_mark) = stream
            .next()
            .await
            .expect("some records")
            .expect("no error");

[TaKO8Ki]

I found that I need to use SCRAM-SHA-512 as sasl.mechanisms in my case, so if I want to use rskafka, I have to implement SCRAM-SHA-512 in SaslConfig probably. However I guess we may be able to improve rskafka to output more reasonable errors.

[pdeva]

i am not even using sasl at all but still getting the error

[crepererum]

Sounds like the broker is cutting the connection, probably due to some protocol error. The best thing to try is to capture the network traffic (e.g. w/ wireshark) and analyze it. My rough guess is that is a bit dated and it doesn't like the newer protocol versions that we use.