Added the ability to configure the log message format for kafka

cloudflare / goflow

The high-scalability sFlow/NetFlow/IPFIX collector used internally at Cloudflare.

BSD 3-Clause "New" or "Revised" License

859 stars 172 forks source link

Added the ability to configure the log message format for kafka #47

Closed dwayn closed 4 years ago

dwayn commented 4 years ago

Updated the default log message format to version 0.11.0.0 as this is the minimum needed to support kafka 2.x If needed, the message format version can be overridden with the kafka.version flag on any of the cli tools and by calling transport.SetKafkaVersion() if using as a library

lspgn commented 4 years ago

Thank you!