Closed dariogoetz closed 6 months ago
For both the Fluvio.multi_partition_consumer and Fluvio.multi_topic_partition_consumer methods, the PyO3-types were wrapped in a PartitionConsumer instead of a MultiplePartitionConsumer type.
Fluvio.multi_partition_consumer
Fluvio.multi_topic_partition_consumer
PartitionConsumer
MultiplePartitionConsumer
This PR fixes this inconsistency.
Thanks @dariogoetz, looks good!
For both the
Fluvio.multi_partition_consumer
andFluvio.multi_topic_partition_consumer
methods, the PyO3-types were wrapped in aPartitionConsumer
instead of aMultiplePartitionConsumer
type.This PR fixes this inconsistency.