search

CallistoLabsNYC / samsa

Rust-native Kafka/Redpanda protocol and client implementation.
Apache License 2.0
106 stars 5 forks source link

Integration tests sometimes fail #19

Closed drauschenbach closed 8 months ago

drauschenbach commented 8 months ago 
$ docker compose up
$ KAFKA_BROKERS=localhost:9092 KAFKA_TOPIC=purchases make check
...
failures:

---- it_can_produce_and_fetch stdout ----
thread 'it_can_produce_and_fetch' panicked at tests/produce_fetch.rs:40:5:
assertion `left == right` failed
  left: NotLeaderForPartition
 right: None
note: run with `RUST_BACKTRACE=1` environment variable to display a backtrace

---- it_can_produce_and_fetch_with_functions stdout ----
Error: ParsingError(b"")

failures:
    it_can_produce_and_fetch
    it_can_produce_and_fetch_with_functions

test result: FAILED. 0 passed; 2 failed; 0 ignored; 0 measured; 0 filtered out; finished in 0.01s

During the test, Compose logs this:

redpanda-1 | WARN 2024-02-29 13:30:26,926 [shard 0] kafka - connection_context.cc:451 - Error processing request: std::runtime_error (Closing connection due to error in produce response: {responses={{name={purchases} partitions={{partition_index=0 error_code={ error_code: not_leader_for_partition [6] } base_offset=-9223372036854775808 log_append_time_ms={timestamp: missing} log_start_offset=-1 record_errors={} error_message={nullopt}}}}} throttle_time_ms=0})