Plugin_Kafka

Apache Kafka producer / consumer module. To use Kafka feature in a content, server definitions should be specified in PACKAGE_DESC.txt.

PLUGIN_ENABLE|Kafka
PLUGIN_DISABLE|Kafka
PLUGIN_EVENT_ENABLE|Kafka
PLUGIN_EVENT_DISABLE|Kafka

KeyValues

KeyValues to be set in .mdf file to control this plugin. An app can be either producer or consumer.

As producer

Key name Value Description default
kafkaBroker hostname:port broker address
kafkaPartition number partition number
kafkaProducerTopic string topic name
kafkaCodec string compression codec name

As consumer

Key name Value Description default
kafkaBroker hostname:port broker address
kafkaPartition number partition number
kafkaConsumerTopic string topic name
kafkaCodec string compression codec name