A Sample application of Kafka Producer and Consumer and its unit testing using Embedded Kafka.
-
Updated
Apr 25, 2018 - Scala
A Sample application of Kafka Producer and Consumer and its unit testing using Embedded Kafka.
A Sample application of Kafka Producer/Consumer API and its unit testing using Embedded Kafka.
Seeks a message in a kafka topic.
Kafka consumer example based on spark streaming with message formatting to spark dataframe
An example kafka log consumer using Alp-Akka and Akka Streams
Repository with sample code to build Kafka Streaming Application in Scala.
Lambda architecture built in Scala and Java, made with love (and Kafka & Spark).
Kafka consumer that is listening a topic, upon a new event arrive in that topic it will trigger several NLP processes to be able to respond that event via twitter api (update status method)
The project consist to develop a real-time solution to monitoring civilians in order to prevent any acts of rebelion. The project is fully-developped in scala and spark is used for the statistics part (dataframe) and architecture part for the stream kafka for example.
spark-kafka-integration
This is a simple example application to showcase how to talk to Apache Kafka in Scala.
Practice of read and write to Kafka topics
Kafka Consumer sample by using Akka for sent to data Http
This is a basic example to show CEP in flink with kafka
Add a description, image, and links to the kafka-consumer topic page so that developers can more easily learn about it.
To associate your repository with the kafka-consumer topic, visit your repo's landing page and select "manage topics."