•        0

kafkatee consumes messages from one or more Kafka topics andwrites the messages to one or more outputs - either command pipes or files.It provides simple transformation from JSON to arbitrary string outputcontrolled through configuration.Each output has a configurable sample rate.Features: * Supported input types: Kafka consumer or piped command. * Supported output types: Piped command or file. * Configuration file syntax is backwards compatible with Wikimedia's udp2log * Configurable output queue size * Memory frugal: message payload is shared by all output queues * Configured with configuration file * Operates as a daemon (daemonization, pidfile) * Closes/stops and reopens/restarts all inputs and outputs on SIGHUP.



Related Projects