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

Defined in:

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

Overview

All code needed for messages piping in Karafka

Defined Under Namespace

Modules: Consumer