diff --git a/doppelgaenger-input/src/main.rs b/doppelgaenger-input/src/main.rs index 673f186..a7b0f24 100644 --- a/doppelgaenger-input/src/main.rs +++ b/doppelgaenger-input/src/main.rs @@ -110,6 +110,7 @@ impl Processor { } } Err(err) if !err.is_temporary() => { + log::info!("Dropping event with permanent error: {}", err); if let Err(err) = self.consumer.commit_message(&msg.0, CommitMode::Async) { log::info!("Failed to ack: {err}"); break;