KStreams Application

We wanted to include an example of using KStreams! Even when using multi-tenancy, the materialized data will be stored in the public tenant.

The example uses the following code:

• KSN-Training/src/main/java/sn_training/KStreams/SNWordCountApplication.java

The word count application is currently setup to consume messages from sharedtopic in the georep namespace of your student tenant. To produce input messages, feel free to use KProducer.java or PulsarProducer.java in the SharedTopic package.