Apache Camel与Spring-boot和Kafka的集成开源案例

这是一个Apache Camel 与 Spring-boot 和 Kafka 集成，一个应用程序充当生产者，另一个应用程序使用消息，点击标题。

生产者和消费者：

• superhero-searcher（作为 Kafka 生产者）

• superhero-registry（充当 Kafka 消费者）

流程：

1. Superhero-searcher微服务使用Java-faker创建一个SuperHero POJO，并在每5秒后将创建的对象发布到Kafka主题superhero-information。
2. 一个死信主题superhero-information-dlx被配置为在主Kafka主题中发布失败的消息。
3. Superhero-registry消耗来自Kafka主题的消息，对其进行解析并将其保存到内存DB中。
4. Dog-adoptiion-center暴露了GET /v1/registry/superheroes API，以检索所有超级英雄的记录。

点击标题