使用生产者消费者的卡夫卡和微服务

Question

我需要在我的微服务项目中使用Apache Kafka。我需要我的一个微服务来生成数据，另一个服务使用相同的数据。我怎样才能让卡夫卡在两项服务之间做到相同

Answer 1

我建议你看看Spring Cloud Stream，因为它完全符合你的需求。

从文档：

框架构建消息驱动的微服务。 Spring Cloud Stream构建于Spring Boot基础之上，以创建DevOps友好的微服务应用程序和Spring Integration，为消息代理提供连接。 Spring Cloud Stream提供了消息代理的自定义配置，介绍了跨多个中间件供应商的持久pub/sub语义，消费者组和分区的概念。这种自以为是的配置为创建流处理应用程序提供了基础。

通过将@EnableBinding添加到主应用程序中，您可以立即连接到消息代理，并通过向方法添加@StreamListener，您将接收流处理的事件。