Consumer group for parallelization

eventide-project / consumer-postgres

Event Sourcing and Microservices Stack for Ruby

http://eventide-project.org

MIT License

2 stars 0 forks source link

Consumer group for parallelization #4

Closed sbellware closed 5 years ago

sbellware commented 5 years ago

Goal: Facilitate declaration of consumer group so that user doesn't have to write the intricacies of a condition statement based on the consistent hashing of a stream name.

Requires declaration of consumer group size as well as the consumer group member number.

# eg:
SomeConsumer.start(stream_name, group_size: 4, group_member: 2)

Add to condition based on last digit of numerical hash of stream name.

sbellware commented 5 years ago

Done