Module: Karafka::Pro::Processing::ConsumerGroups::Piping

Defined in:

lib/karafka/pro/processing/consumer_groups/piping/consumer.rb

Overview

All code needed for messages piping in Karafka

Defined Under Namespace

Modules: Consumer