improve log
This commit is contained in:
parent
edcc5f5b67
commit
1690c81510
|
@ -61,7 +61,7 @@ async fn main() -> anyhow::Result<()> {
|
|||
|
||||
// ANCHOR: consume
|
||||
match consumer.subscribe(["topic_meters"]).await{
|
||||
Ok(_) => println!("subscribe topics successfully."),
|
||||
Ok(_) => println!("Subscribe topics successfully."),
|
||||
Err(err) => {
|
||||
eprintln!("Failed to subscribe topic_meters, dsn: {}; ErrMessage: {}", dsn, err);
|
||||
return Err(err.into());
|
||||
|
|
Loading…
Reference in New Issue