Kafka application WordCountPerLineApp
(using Kafka Producer and Consumer APIs) that does the following:
- Consumes records from a topic, e.g.
input
- Counts words (in the value of a record)
- Produces records with the unique words and their occurences (counts)
- A record
key -> hello hello world
gives a record with the following valuehello -> 2, world -> 1
(and the same key as in the input record)
- A record
- (EXTRA) Produces as many records as there are unique words in the input record with their occurences (counts)
- A record
key -> hello hello world
gives two records in the output, i.e.(hello, 2)
and(world, 1)
(as (key, value))
- A record
Credits: kafka-workshop