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

Question

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

Answer 1

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

从文档：

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

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