Skip to content

Commit 3d5fe96

Browse files
committed
fix code style
1 parent 35e564c commit 3d5fe96

1 file changed

Lines changed: 1 addition & 4 deletions

File tree

rocketmq-broker/src/processor/consumer_manage_processor.rs

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -224,10 +224,7 @@ where
224224
info!(
225225
"Update consumer offset is rejected because of previous offset-reset. \
226226
Group={},Topic={}, QueueId={}, Offset={}",
227-
topic,
228-
group,
229-
queue_id,
230-
offset
227+
topic, group, queue_id, offset
231228
);
232229
return Some(response.set_remark("Offset has been previously reset"));
233230
}

0 commit comments

Comments
 (0)