refactor: warn when we receive broken data from write buffer

We need to understand why this is the case and where broken data gets
stuck, because at the moment it seems that some Kafka hiccups can
poison the write buffer but it seems restarting IOx recovers the
situation.
pull/24376/head
Marco Neumann 2021-11-03 16:03:38 +01:00
parent c42a60beee
commit 10de63f9b6
1 changed files with 1 additions and 1 deletions

View File

@ -142,7 +142,7 @@ async fn stream_in_sequenced_entries<'a>(
Ok(db_write) => db_write,
// skip over invalid data in the write buffer so recovery can succeed
Err(e) => {
debug!(
warn!(
%e,
%db_name,
sequencer_id,