Kafka 如何在数据中进行一些转换之后,从消费者(cluster1)生成到cluster2中主题的事件?

bqjvbblv  于 2023-04-05  发布在  Apache
关注(0)|答案(1)|浏览(126)

我只是一个Kafka的初学者。我需要在PROD集群中使用来自2个不同主题(A和A1)的kafka事件,并使用我需要命中一个REST API的事件负载。来自rest api的结果应该被推送到QA集群中的主题B。对于这个问题陈述,正确的方法是什么?
我了解到Kafka流只适用于同一集群中的主题。我还可以使用什么来陈述问题?

kb5ga3dv

kb5ga3dv1#

您可以使用Spring for Apache Kafka来实现这一点。只需使用不同的引导服务器定义生产者和消费者工厂。
如果您使用的是Sping Boot ,则更容易,因为您可以使用属性配置集群。
https://spring.io/projects/spring-kafka
https://docs.spring.io/spring-boot/docs/current/reference/html/messaging.html#messaging.kafka

相关问题