Skip to content

Implement a partition filter (stop condition)

Afonso Mukai requested to merge filter_refactor_part_3_partition_filter into refactor_message_filters

Created by: SkyToGround

Description of work

Seeing as the PartitionFilter code (almost) only depends on itself, I thought that I might as well add a separate PR for that one as well. A few things to take into account:

  • This class is intended for determining if we should stop consuming from a partition based on the poll status from the Kafka library. There are other classes for other sources of information.
  • I am not super happy about the name, feel free to come up with alternatives.
  • I feel that the logic should be easy to understand from the documentation, including the PNG image that is part of the PR.

Merge request reports