纯手动搭建大数据集群架构_记录018_RuoYi-Cloud-Plus-master_Kafka集成的自己创建的微服务_实现多主题数据传输---大数据之Hadoop3.x工作笔记0179

Posted 2023-03-31 脑瓜凉

首先要集成这个kafka到自己的项目中去,首先要在自己创建的微服务中的yml文件中,添加上上面的

红框中的配置

  cloud:
      stream:
        function:
          # 重点配置 与 binding 名与消费者对应
          # definition: delay;demo;log
          definition: col;log

 这个配置的意思是,col 和 log,这两个分别就对应了两个主题,kafka的主题,这个名字可以自己写.

然后再来配置,kafka的配置:

--- # kafka 配置
spring:
  cloud:
    stream:
      kafka:
        binder:
          brokers: 172.19.126.120:9092,172.19.126.121:9092,172.19.126.123:9092
      bindings:
        col-out-0:
          destination: stream-col-topic
          contentType: application/json
          group: col_group
          binder: kafka
        col-in-0:
          destination: stream-col-topic
          contentType: application