Module: Karafka::Pro::Processing::ParallelSegments::Filters
- Defined in:
- lib/karafka/pro/processing/parallel_segments/filters/base.rb,
lib/karafka/pro/processing/parallel_segments/filters/mom.rb,
lib/karafka/pro/processing/parallel_segments/filters/default.rb
Overview
Module for filters injected into the processing pipeline of each of the topics used within the parallel segmented consumer groups