Readkafka
(since EVL 1.1)
Component calls kafka consumer command, specified by ‘EVL_KAFKA_CONSUMER_COMMAND’, which is by default ‘kafka-console-consumer.sh’. and run it with options:
--bootstrap-server "<server>:<port>" --topic "<topic>" ``<kafka_consumer_opts>``
and send the output to <f_out>
.
- Readkafka
-
is to be used in EVS job structure definition file.
<f_out>
is either output file or flow name. - evl readkafka
-
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
Readkafka <topic> <f_out> <server:port> [<kafka_consumer_opts>] evl readkafka <topic> <server:port> [<kafka_consumer_opts>] [-v|--verbose] evl readkafka ( --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