An example of how to connect to, send, and receive messages from Kafka in several languages.
Kafka can be started in Docker using the included docker-compose.yml
file using Docker Compose
docker-compose up
For the Java example, you can open up two terminals, one opened up to kafka-getting-started/java/emitter
and the other to kafka-getting-started/java/consumer
. In both terminals, start the Spring application with
./mvnw spring-boot:run
On the emitter, you'll be prompted for input. You can begin typing a message, and send it with [Enter]. You should then see the same message written in the terminal running the consumer.