Get a feed from Kentik and either print to stdout or else write to kafka.
196
Listen for a feed of data from Kentik and pass on in a common form. Run with:
docker run -p 8082:8082 kkc:v1
All flags:
Usage of ./bin/kkc:
-bootstrap.servers string
bootstrap.servers
-city string
City mapping file
-compression string
compression algo to use (none|gzip|snappy|deflate|null) (default "none")
-file_out string
Write flows seen to log to this directory if set (default "./")
-format string
Format to convert kflow to: (json|avro|netflow) (default "json")
-healthcheck string
Bind to this interface to allow healthchecks
-kafka.debug string
debug contexts to enable for kafka
-kafka_topic string
kafka topic to produce on
-kentik_email string
Email to use for sending flow on to Kentik
-kentik_url string
URL to use for sending flow on to Kentik (default "https://flow.kentik.com/chf")
-listen string
IP:Port to listen on (default "127.0.0.1:8081")
-log_level string
Logging Level (default "debug")
-mapping string
Mapping file to use for enums (default "config.json")
-max_flows_per_message int
Max number of flows to put in each emitted message (default 10000)
-max_sql_conns int
Max concurrent SQL connections (default 16)
-metalisten string
HTTP port to bind on (default "localhost:0")
-metrics string
Metrics Configuration. none|syslog|stderr|graphite:127.0.0.1:2003 (default "syslog")
-net_protocol string
Use this protocol for writing data (udp|tcp|unix) (default "udp")
-net_server string
Write flows seen to this address (host and port)
-netflow_version string
Version of netflow to produce: (netflow9|ipfix) (default "ipfix")
-nr_account_id string
If set, sends flow to New Relic
-nr_url string
URL to use to send into NR (default "https://insights-collector.newrelic.com/v1/accounts/%s/events")
-olly_dataset string
Olly dataset name
-olly_write_key string
Olly dataset name
-region string
Region mapping file
-sasl.kerberos.keytab string
sasl.kerberos.keytab
-sasl.kerberos.kinit.cmd string
sasl.kerberos.kinit.cmd (default "kinit -R -t \"%{sasl.kerberos.keytab}\" -k %{sasl.kerberos.principal} || kinit -t \"%{sasl.kerberos.keytab}\" -k %{sasl.kerberos.principal}")
-sasl.kerberos.principal string
sasl.kerberos.principal
-sasl.kerberos.service.name string
sasl.kerberos.service.name (default "kafka")
-sasl.mechanism string
sasl.mechanism
-security.protocol string
security.protocol
-service_name string
Service identifier (default "kkc")
-sinks string
List of sinks to send data to. Options: kafka|stdout|new_relic|kentik|net (default "stdout")
-ssl.ca.location string
ssl.ca.location
-stdout
Log to stdout (default true)
-tag_lookup string
Tag service port to run lookups on
-threads int
Number of threads to run for processing
-v Show version and build information
Content type
Image
Digest
Size
82.8 MB
Last updated
about 6 years ago
docker pull kentik/kkc:v1