Skip to content
This repository has been archived by the owner on Apr 3, 2018. It is now read-only.

Latest commit

 

History

History

kafka

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
 
 
 
 
 
 

stream-kafka

KafkaStreamFactory

This stream ingests Spans form a Kafka topic advertised by Zookeeper, using Spark Kafka libraries.

Kafka messages should contain a list of spans in json or TBinaryProtocol big-endian encoding. Details on message encode is available here

Usage

While the KafkaStreamFactory can be used directly through the provided builder interface, most users will likely find more value in the Spring Boot autoconfiguraton module. Additional information for using the module can be found here.