Skip to content

MultiProcessConsumer doesn't honor partitions argument. #373

@merginator

Description

@merginator

MultiProcessConsumer always sets partitions to None, which in turn causes Consumer to set partitions to the full list of partitions for the topic. Consumer uses this list to set the initial offsets, which is used by MultiProcessorConsumer to set its list of partitions.

Metadata

Metadata

Assignees

No one assigned

    Projects

    No projects

    Milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions