-
Notifications
You must be signed in to change notification settings - Fork 148
Home
Apache kafka is yet another precious gem from Apache Software Foundation. Kafka was originally developed at Linkedin and later on became a member of Apache project. Apache Kafka is a distributed publish-subscribe messaging system. Kafka differs from traditional messaging system as it is designed as distributed system, persist messages on disk and supports multiple subscribers.
Kafka-message-Server is a sample application to show Kafka usage as message server and it's benefit over traditional message server like jms. Kafka sample application currently have following features -
-
Producer program read the content of the message from file present at particular directory and publish it on kafka broker. Each file content is published as one message. Producer default functionality is read file content, publish it on kafka broker as message and delete the file.
-
Consumer program shows the consumption of the message from kafka broker and print it's content on the console. Consumer pull the data from the same topic in which data is published by producer.
-
Third program, file creation program creates the file with time stamp at particular directory from where producer program is reading the data.
Please follow the instructions present in Read.md file or How to run sample application