zoukankan      html  css  js  c++  java
  • 项目中引入kafka

    项目如果需要引入kafka,可以从以下几个流程走:

    1.pom文件引对应的jar包

    <dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.9.2</artifactId>
    <version>0.8.2.1</version>
    </dependency>
    有的项目还需要将对应使用kafka的包、类作为groupId、artifactId引入
    例:
    <!-- kafka -->
    <!-- <dependency>
    <groupId>com.xxx.bis</groupId>
    <artifactId>OCC_KAFKA_Client</artifactId>
    <version>0.0.1</version>
    </dependency>-->
    如果项目已经做了相应配置,则只需要引入最上面的jar包即可。
     
    2.配置kafka

    spring配置文件引入Kafka

    基础配置完成之后,根据需求,分为生产者和消费者两种,无论哪种,都需要由运维先创建kafka主题

    并在application等配置信息中声明主题。

    生产者

    1)在需要的类中根据需求,引入Kafka,发送信息

    @Autowired
    private KafkaTemplate kafkaTemplate;
    String topic = ConfigHelper.getString("运维创建的kafka主题");
    //enrolment_web_space_modify_topic
    System.out.println("kafka主题名:" + topic);
    kafkaTemplate.send(topic, JsonHelper.toString(config));

    消费者

    1)进行消费者订阅配置

     2.spring配置Kafka

    3.业务订阅Kafka信息

     
     
     
  • 相关阅读:
    poj2253 青蛙
    这代码真是好,真是文艺,转来的
    java.text.MessageFormat
    java多线程的两种实现方式
    javascript with
    面向接口编程
    java 多线程 读写锁
    java 多线程 资源共享
    UML:继承、实现、依赖、关联、聚合、组合
    javascript 语言精粹 学习笔记
  • 原文地址:https://www.cnblogs.com/koudaiyoutang/p/9721183.html
Copyright © 2011-2022 走看看