Skip to content

Kafka Executor

James Vaughan edited this page Nov 14, 2018 · 11 revisions

Purpose

Components

Object: KafkaExecutor

Topic: ReduceRequest

Object: Reducer

Topic: Assignment

Object: AtomicProcessExecutor

Topic: PiiHistory

Object: Sequencer

Topic: Results

(really Logs or PiEvents)

Object: ResultsListener

Clone this wiki locally