Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- ## Purpose
- In modern system architecture, distributed applications are decoupled into smaller, independent modules
- that are easier to develop, deploy and maintain.
- Message Queue provide an effective way for these distributed applications to communicate and cordinate with each others.
- It also improve the quality of a system in term of
- * performance
- * availability
- * scalability
- Therefore understanding and working with Message Queue is an important knowledge when dealing with integrated system.
- ## Description
- Use java to build
- * kafka producer app that push message to kafka
- * queue name: "tasks"
- * message schema : {"id": "123", "status": "QUEUE", "start_time": "2019-05-01", "end_time": "2019-05-05", "properties": {"pro1": "value"}}
- * kafka consumer app that receive message from kafka
- * queue name: "tasks"
- * receive "task" message and print to console
- There will be no time constrain.
- The sooner you finish the exercise the more time we will have to discuss
- * what have you learned
- * how you can improve your code
- * plan for the next exercise
- ## Note
- If you don't know about messaging yet, below could be some good materials to get started.
- * ebook: RabbitMQ in action
- * hello world: https://www.rabbitmq.com/tutorials/tutorial-one-java.html
- RabbitMQ is a good start to learn about messaging as it is easier than kafka for beginners but note that our exercise is building kafka applications.
- hint: The kafka applications you are building is similar to hello world example of RabbitMQ
- ## What you will learn
- * know the basic of how message queue work
- * can write a producer & consumer app
- * know how to handle message with json format
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement