Writekafka
(since EVL 1.1)
Component calls kafka producer command, specified by ‘EVL_KAFKA_PRODUCER_COMMAND’, which is by default ‘kafka-console-producer.sh’. and run it with options:
--broker-list "<server:port>,<server2:port2>,..." \ --topic "<topic>" ``<kafka_producer_opts>``
and send there <f_in>
.
- Writekafka
-
is to be used in EVS job structure definition file.
<f_in>
is either output file or flow name. - evl writekafka
-
is intended for standalone usage, i.e. to be invoked from command line and and write to standard output.
EVS is EVL job structure definition files, for details see evl-evd(5) and evl-evs(5).
Synopsis
Writekafka <f_in> <topic> <server:port>[,<server2:port2>...] [<kafka_producer_opts>] evl writekafka <topic> <server:port>[,<server2:port2>...] [<kafka_producer_opts>] [-v|--verbose] evl writekafka ( --help | --usage | --version )
Options
- -y, --text-output
-
write the output as text, not binary
Standard options:
- --help
-
print this help and exit
- --usage
-
print short usage information and exit
- -v, --verbose
-
print to stderr info/debug messages of the component
- --version
-
print version and exit