我只是一个Kafka的初学者。我需要在PROD集群中使用来自2个不同主题(A和A1)的kafka事件,并使用我需要命中一个REST API的事件负载。来自rest api的结果应该被推送到QA集群中的主题B。对于这个问题陈述,正确的方法是什么?我了解到Kafka流只适用于同一集群中的主题。我还可以使用什么来陈述问题?
kb5ga3dv1#
您可以使用Spring for Apache Kafka来实现这一点。只需使用不同的引导服务器定义生产者和消费者工厂。如果您使用的是Sping Boot ,则更容易,因为您可以使用属性配置集群。https://spring.io/projects/spring-kafkahttps://docs.spring.io/spring-boot/docs/current/reference/html/messaging.html#messaging.kafka
1条答案
按热度按时间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