JEESZ’s message service platform has abandoned the former ActiveMQ and adopted the Kafka distributed message middleware scheme with high throughput:
Jeesz-kafka message platform using Spring + Kafka integration solution, details are as follows:
1. Use the latest version 2.1.0.release integration JAR package: Spring-integration-kafka
2. Use init.properties to configure the Zookeeper and Kafka distributed clusters.
3. Use message producer Spring-context-producer to configure schemes.
4. Configure the scheme using message consumer Spring-context-producer.
5. Inject message types using annotations
@Autowired
private KafkaTemplate kafkaTemplate;
6. Rewrite MessageListener’s getMessage method to get messages (business implementation)
7. Test the message service RestFul
Willing to understand the framework technology or source code of friends directly beg exchange to share technology: 2042849237 distributed some solutions, there are willing to understand friends can find our team to discuss more detailed source code reference sources