Hello, I'm trying to monitor cluster-sharding. In particular, I'd like to detect rebalance operations when they happen. Using a.c.s.DDataShardCoordinator.
The cluster-events subscription model perhaps has a sharding counterpart? See https://doc.akka.io/docs/akka/2.5/cluster-usage.html#subscribe-to-cluster-events DDataShardCoordinator puts out some logs which are useful, but perhaps there are some events I could just listen to? See below for some log output. 16:05:13.965 DEBUG a.c.s.DDataShardCoordinator Shard [16] allocated at [Actor[akka.tcp://MuhServer@muh-host-3:2551/system/sharding/gremlins#106334292]] 16:05:13.972 DEBUG a.c.s.DDataShardCoordinator The coordinator state was successfully updated with ShardHomeAllocated(4,Actor[akka.tcp://MuhServer@muh-host-2:2551/system/sharding/gremlins#340317110]) 16:05:13.972 DEBUG a.c.s.DDataShardCoordinator Shard [4] allocated at [Actor[akka.tcp://MuhServer@muh-host-2:2551/system/sharding/gremlins#340317110]] 16:05:23.232 DEBUG a.c.s.DDataShardCoordinator Rebalance shard [2] from [Actor[akka://MuhServer/system/sharding/gremlins#1737908169]] 16:05:23.233 DEBUG a.c.s.DDataShardCoordinator Rebalance shard [13] from [Actor[akka://MuhServer/system/sharding/gremlins#1737908169]] 16:05:23.233 DEBUG a.c.s.DDataShardCoordinator Rebalance shard [14] from [Actor[akka://MuhServer/system/sharding/gremlins#1737908169]] 16:05:23.239 DEBUG a.c.s.DDataShardCoordinator GetShardHome [13] request ignored, because rebalance is in progress for this shard. 16:05:23.240 DEBUG a.c.s.DDataShardCoordinator GetShardHome [14] request ignored, because rebalance is in progress for this shard. 16:05:23.240 DEBUG a.c.s.DDataShardCoordinator Rebalance shard [2] done [true] 16:05:23.245 DEBUG a.c.s.DDataShardCoordinator The coordinator state was successfully updated with ShardHomeDeallocated(2) 16:05:23.245 DEBUG a.c.s.DDataShardCoordinator Shard [2] deallocated 16:05:23.245 DEBUG a.c.s.DDataShardCoordinator Rebalance shard [14] done [true] -- ***************************************************************************************************** ** New discussion forum: https://discuss.akka.io/ replacing akka-user google-group soon. ** This group will soon be put into read-only mode, and replaced by discuss.akka.io ** More details: https://akka.io/blog/news/2018/03/13/discuss.akka.io-announced ***************************************************************************************************** >>>>>>>>>> >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to akka-user+unsubscr...@googlegroups.com. To post to this group, send email to akka-user@googlegroups.com. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
