Advertisement
Guest User

Untitled

a guest
May 21st, 2019
123
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.67 KB | None | 0 0
  1. ## Purpose
  2.  
  3. In modern system architecture, distributed applications are decoupled into smaller, independent modules
  4. that are easier to develop, deploy and maintain.
  5.  
  6. Message Queue provide an effective way for these distributed applications to communicate and cordinate with each others.
  7. It also improve the quality of a system in term of
  8. * performance
  9. * availability
  10. * scalability
  11.  
  12. Therefore understanding and working with Message Queue is an important knowledge when dealing with integrated system.
  13.  
  14. ## Description
  15.  
  16. Use java to build
  17. * kafka producer app that push message to kafka
  18. * queue name: "tasks"
  19. * message schema : {"id": "123", "status": "QUEUE", "start_time": "2019-05-01", "end_time": "2019-05-05", "properties": {"pro1": "value"}}
  20. * kafka consumer app that receive message from kafka
  21. * queue name: "tasks"
  22. * receive "task" message and print to console
  23.  
  24. There will be no time constrain.
  25. The sooner you finish the exercise the more time we will have to discuss
  26. * what have you learned
  27. * how you can improve your code
  28. * plan for the next exercise
  29.  
  30. ## Note
  31.  
  32. If you don't know about messaging yet, below could be some good materials to get started.
  33. * ebook: RabbitMQ in action
  34. * hello world: https://www.rabbitmq.com/tutorials/tutorial-one-java.html
  35.  
  36. 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.
  37. hint: The kafka applications you are building is similar to hello world example of RabbitMQ
  38.  
  39. ## What you will learn
  40. * know the basic of how message queue work
  41. * can write a producer & consumer app
  42. * know how to handle message with json format
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement