influxdb/ingester
Marco Neumann 6b8b922fe7
fix: do not loose data when Kafka reports that offset is above watermark (#5322)
* fix: do not loose data when Kafka reports that offset is above watermark

This can happen in certain cluster rebalance settings.

This is also linked to https://github.com/influxdata/rskafka/issues/147
but for the upstream issue I currently have no idea how to fix it, so
let's at least harden IOx against it.

Fixes #5128.

* refactor: panic for `SequenceNumberAfterWatermark`
2022-08-11 07:32:04 +00:00
..
src fix: do not loose data when Kafka reports that offset is above watermark (#5322) 2022-08-11 07:32:04 +00:00
Cargo.toml chore: Update datafusion / arrow/parquet/arrow-flight and prost/tonic ecosystem (#5360) 2022-08-09 17:30:44 +00:00