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"
}