Roman

Are you use `memory` or `rocksdb` storage backend?

RocksDB used only for fast recover from changelog topic. We are use memory storage too, but we store in changelog topic about 30k records and it recovers in seconds. Please...

Please check partitioning (what instance consume partition) and rocksdb storage use different paths on instances

@Hamdiovish @dario-collavini how many partitions on GlobalTable topic you have?

@Hamdiovish so, you need same table data across all workers, right? Maybe set topic to 1 partition and use_partitioner=True in table config help you?

@Hamdiovish show output of `kafka-topics.sh` with table topic. I think in Kafka you have default (3 maybe) partitions count. Also, please check which consumer consume partition. We are using global...

@Hamdiovish okay, i'll try to reproduce this and maybe debug this behavior

Bump issue. @vir-mir In you example, if websocket_handler return websocket var, test will fail. In docs handler always return WebSocketResponse. So, in my tests when i use wscat and handler...