amarkum/twitter-spark-processor

it consumes message from multiple kafka topic, parses the required attribute and serialize it into AVRO format and stores it into local filesystem.

Java