Kafka Executor

A basic Kafka executor that produces a message on a Kafka broker.

Configuration

Params

brokerAddress: "IP:port" of the broker
message:       The message to produce
topic:         The Kafka topic for this message
debug:         Turns on debugging output if not empty

Example

"executor": "kafka",
"executor_config": {
    "brokerAddress": "localhost:9092",
    "message": "My message",
    "topic": "my_topic"
}