Maintains callback consumers for every current super-stream partition.
Partition additions and removals are reconciled every
ConsumerOptions#topology_refresh. Delivery order is preserved within each
partition, not globally across the super stream.
Constructors
new(environment :
Environment, super_stream :
String, options :
ConsumerOptions, handler :
Proc(
Delivery,
Nil))
Creates partition consumers and starts topology refresh.
Applications normally call Environment#super_stream_consumer.
Instance methods
close
Idempotently stops topology refresh and closes all partition consumers.
consumers
Returns a snapshot of the current partition consumers.
super_stream
Returns the logical super-stream name.