diff --git a/queue-worker/main.go b/queue-worker/main.go index e8dc931..ac82d12 100644 --- a/queue-worker/main.go +++ b/queue-worker/main.go @@ -194,7 +194,7 @@ MAINLOOP: case err = <- consumer.Errors(): fmt.Println("consumer error: ",err) case ntf := <- consumer.Notifications(): - fmt.Println("Rebalanced: %+v\n", ntf) + fmt.Printf("Rebalanced: %+v\n", ntf) } } }