feat(backend): added rebalancing handler to all services

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

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 {

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)

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)

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 {