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.
| Name | Name | Last commit date | ||
|---|---|---|---|---|