Spark 2.3. End to End Avro Continous Structured Streaming Kafka demo using Twitter´s bijection in Java.
- Kafka: 1.0.0
- Java 8
- Maven
Configure kafka hosts and execute both the ProducerConsumerDemo and the StructuredDemo classes.
Latency measures can be seen on ProducerConsumerDemo's output.