-This project demonstrates Custom Kafka serializer/deserializer and simulates sending and receiving of a file through Kafka service
- Sends a file through Kafka
Main Class :KafkaFileSender
USAGE :
-b|--broker-list :Comma separated list of brokers
-t|--topic :topic name
-f|--file :absolute path of file to be sent
--help print help"
Example :
java KafkaFileSender -b localhost:9091 -t fileTopic -f /home/Message.txt
- Receives a file through kafka
Main Class :KafkaFileReceiver
USAGE :
-b|--broker-list :Comma separated list of brokers
-t|--topic :topic name
-g|--group-id :group id
-p|--poll-interval :Poll interval[optional]
-c|--cleint-id :client id [optional]
Example :
java KafkaFileReceiver -b localhost:9091 -t fileTopic -g group1 -p 1000
Complete steps to run a simulation
- Start Zookeeper server
- Start Kafka Server
- Create a topic
- Start Receiver
- Start Sender
Dependencies :
- kafka-clients-0.10.0.0.jar
- slf4j-api-1.7.21.jar