diff --git a/backend/cmd/assets/main.go b/backend/cmd/assets/main.go
index 220300e74..5fdc85107 100644
--- a/backend/cmd/assets/main.go
+++ b/backend/cmd/assets/main.go
@@ -73,6 +73,8 @@ func main() {
 			log.Printf("Error while caching: %v", err)
 		case <-tick:
 			cacher.UpdateTimeouts()
+		case msg := <-msgConsumer.Rebalanced():
+			log.Println(msg)
 		default:
 			if !cacher.CanCache() {
 				continue
diff --git a/backend/cmd/db/main.go b/backend/cmd/db/main.go
index c9916b03d..8db029394 100644
--- a/backend/cmd/db/main.go
+++ b/backend/cmd/db/main.go
@@ -163,6 +163,8 @@ func main() {
 			os.Exit(0)
 		case <-commitTick:
 			commitDBUpdates()
+		case msg := <-consumer.Rebalanced():
+			log.Println(msg)
 		default:
 			// Handle new message from queue
 			if err := consumer.ConsumeNext(); err != nil {
diff --git a/backend/cmd/ender/main.go b/backend/cmd/ender/main.go
index 913629f0e..beb69bd42 100644
--- a/backend/cmd/ender/main.go
+++ b/backend/cmd/ender/main.go
@@ -98,6 +98,8 @@ func main() {
 			if err := consumer.CommitBack(intervals.EVENTS_BACK_COMMIT_GAP); err != nil {
 				log.Printf("can't commit messages with offset: %s", err)
 			}
+		case msg := <-consumer.Rebalanced():
+			log.Println(msg)
 		default:
 			if err := consumer.ConsumeNext(); err != nil {
 				log.Fatalf("Error on consuming: %v", err)
diff --git a/backend/cmd/heuristics/main.go b/backend/cmd/heuristics/main.go
index 9e4804089..0a5c77ea5 100644
--- a/backend/cmd/heuristics/main.go
+++ b/backend/cmd/heuristics/main.go
@@ -82,6 +82,8 @@ func main() {
 			})
 			producer.Flush(cfg.ProducerTimeout)
 			consumer.Commit()
+		case msg := <-consumer.Rebalanced():
+			log.Println(msg)
 		default:
 			if err := consumer.ConsumeNext(); err != nil {
 				log.Fatalf("Error on consuming: %v", err)
diff --git a/backend/cmd/storage/main.go b/backend/cmd/storage/main.go
index 07c6eec91..251ce82e2 100644
--- a/backend/cmd/storage/main.go
+++ b/backend/cmd/storage/main.go
@@ -73,6 +73,8 @@ func main() {
 			os.Exit(0)
 		case <-counterTick:
 			go counter.Print()
+		case msg := <-consumer.Rebalanced():
+			log.Println(msg)
 		default:
 			err := consumer.ConsumeNext()
 			if err != nil {