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.
magaton / spring-kafka-snowplow Goto Github PK
View Code? Open in Web Editor NEWKafka consumer for Snowplow events serialised with Thrift