danthegoodman1 / UltraQueue

Distributed pull queue based on Segment's Centrifuge. Zero dependency p2p clustering.
GNU Affero General Public License v3.0
1 stars 0 forks source link

32 partition draining #41

Closed danthegoodman1 closed 2 years ago

danthegoodman1 commented 2 years ago

working but tests grpc can cause issues since grpc

2022/06/02 19:40:32 FATAL: [core] grpc: Server.RegisterService found duplicate service registration for "UltraQueueInternal"

sometimes, other times it just uses the first partition grpc in the second partition server... super weird