Before running these examples, make sure you install the kafka in your system.
Here, the kafka is running in 9093 port. You can change the port of running in your application. default broker port is 9092
To install the kafka you can go through Apache Kafka or if you are interested in the confluent open source edition
To change the port, specify in the server.properties of the kafka "port=".
maven project example kafka log4j appender
Spring boot example kafka log4j appender
simple project producer & Consumer
spring boot Consumer & its Configuration. Producer & it's configuration
The spring boot Kafka streams example configuration shows how to configure kafka streams to process multiple topics/enities/app. e.g. This example stream configuration has 3 named beans for stream builder. The example Enrollment Stream uses the "enrollmentStreamBuilder" to build enrollment notification streams through @Qualifier("enrollmentStreamBuilder") tag.