-
Notifications
You must be signed in to change notification settings - Fork 408
Open
Description
A Consumer that is subscribed to multiple partitions cannot control the mix of messages it consumes from each partition.
There are various reasons why controlling that is relevant, see eg. #719 and https://github.com/confluentinc/librdkafka/wiki/FAQ#what-are-partition-queues-and-why-are-some-partitions-slower-than-others.
That last link shows that librdkafka supports consuming from each partition separately. It would be great if that implementation is available in node-rdkafka as well. An example could be a PartitionConsumer
class, that does not have the normal .consume
methods, but .consume(topic, partition, number, callback)
.
Metadata
Metadata
Assignees
Labels
No labels