Write a new Kafka application WordCountApp
(using Kafka Producer and Consumer APIs) that does the following:
- Consumes records from a topic, e.g.
input
- Counts words (in the values of records)
- Uses
KStream.groupBy
to group by word andcount
the occurences- Uses the state
- Produces records with the unique words and their occurences (counts)
Duration: 30 mins