Skip to content

Commit ccea8fe

Browse files
authored
fix(consumer): Quiet error logging on shutdown (#343)
When closing a consumer, the `event_tx` gets dropped causing an error log even on normal shutdown with no traffic. Lower the log level for this to avoid false error reporting.
1 parent 5b476d6 commit ccea8fe

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/consumer/engine.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ impl<Exe: Executor> ConsumerEngine<Exe> {
110110

111111
let send_end_res = event_tx.send(mapper(None)).await;
112112
if let Err(err) = send_end_res {
113-
log::error!("Error sending end event to channel - {err}");
113+
log::debug!("Error sending close event to channel - {err}");
114114
}
115115

116116
log::warn!("rx terminated");

0 commit comments

Comments
 (0)