diff --git a/src/drivers/monitor/mod.rs b/src/drivers/monitor/mod.rs index b20e8fc..709c464 100644 --- a/src/drivers/monitor/mod.rs +++ b/src/drivers/monitor/mod.rs @@ -95,11 +95,11 @@ pub async fn subscribe(config: MonitorConfig) -> Result<()> { ), } - consumer.commit_message(&message, CommitMode::Async)?; + consumer.commit_message(message, CommitMode::Async)?; } Err(error) => { error!(?error, "fail to convert message to event"); - consumer.commit_message(&message, CommitMode::Async)?; + consumer.commit_message(message, CommitMode::Async)?; } } }