spring-kafka-snowplow

An example of kafka consumer that receives and extracts the thrift serialised message from snowplow topic. If you configured scala-stream-collector to use kafka sink, then specify the same topic name for kafka.topic property.