package kafka
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
-
class
CustomKafkaExecutor extends MinimalKafkaExecutor
Wrapper for a CustomKafkaExecutor that controls the lifecycle of an arbitrary collection of local Kafka connectors.
-
class
MinimalKafkaExecutor extends StatelessExecutor[ObjectId] with DelegatedPiObservable[ObjectId]
Minimal implementation of a KafkaExecutor that needs to be present on the local machine to complete the Executor interface.
Minimal implementation of a KafkaExecutor that needs to be present on the local machine to complete the Executor interface. Other components are required are required to run on the Kafka cluster but need not be situated on the local machine.
Value Members
-
object
CompleteKafkaExecutor
Implements the full functionality of a Kafka Executor locally using the standard components.
Implements the full functionality of a Kafka Executor locally using the standard components. - Independent Sequencer - Independent Reducer - Independent Atomic Process Executor