当前位置:   article > 正文

消息队列kafka(二)--与spring整合(kafkaTemplate方式)_kafka手动配置类kafkatrmplate

kafka手动配置类kafkatrmplate

一、简介

在这里介绍kafka与spring的整合,这里采用kafkaTemplate方式。

二、生产者开发步骤

1、添加maven依赖(略去spring依赖,请自行添加)

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka_2.9.2</artifactId>
    <version>0.8.2.1</version>
</dependency>
<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>1.0.0</version>
</dependency>
2、添加生产者spring配置

主要包含配置kafka生产者连接参数,产生kafka生产者工厂bean以及产生kafkaTemplate的bean。

实例如下:

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:context="http://www.springframework.org/schema/context"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <bean id="kafkaProducerProperites" class="java.util.HashMap">
        <constructor-arg>
            <map>
                <entry key="bootstrap.servers" value="192.168.0.107:9092" />
                <entry key="group.id" value="0"/>
                <entry key="retries" value="3"/>
                <entry key="batch.size" value="16384"/>
声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/在线问答5/article/detail/879656
推荐阅读
相关标签
  

闽ICP备14008679号