多线程消息监听容器配置[ 消费者spring-kafka配置文件]
1 <?xml version="1.0" encoding="UTF-8"?> 2 <beans xmlns="http://www.springframework.org/schema/beans" 3 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 4 xsi:schemaLocation="http://www.springframework.org/schema/beans 5 http://www.springframework.org/schema/beans/spring-beans.xsd"> 6 7 8 <bean id="consumerProperties" class="java.util.HashMap"> 9 <constructor-arg> 10 <map> 11 <entry key="bootstrap.servers" value="${bootstrap.servers}"/> 12 <!-- 指定消费组名 --> 13 <entry key="group.id" value="friend-group"/> 14 <entry key="enable.auto.commit" value="true"/> 15 <entry key="auto.commit.interval.ms" value="1000"/> 16 <entry key="session.timeout.ms" value="15000"/> 17 <entry key="max.poll.records" value="1"/> 18 <entry key="key.deserializer" value="org.apache.kafka.common.serialization.IntegerDeserializer"/> 19 <!--<entry key="key.deserializer" value="org.apache.kafka.common.serialization.StringDeserializer"/>--> 20 <entry key="value.deserializer" value="org.apache.kafka.common.serialization.StringDeserializer"/> 21 </map> 22 </constructor-arg> 23 </bean> 24 25 <bean id="consumerFactory" class="org.springframework.kafka.core.DefaultKafkaConsumerFactory"> 26 <constructor-arg> 27 <ref bean="consumerProperties"/> 28 </constructor-arg> 29 </bean> 30 31 <!-- 消费消息的服务类 --> 32 <bean id="messageListernerConsumerService" class="com.zhaopin.consumer.ConsumerService"/> 33 34 <!-- 消费者容器配置信息 --> 35 <bean id="containerProperties" class="org.springframework.kafka.listener.config.ContainerProperties"> 36 <constructor-arg value="friend"/> 37 <!--<constructor-arg> 38 <list> 39 <value>zptopic</value> 40 <value>ssmk</value> 41 <value>friend</value> 42 </list> 43 </constructor-arg>--> 44 <property name="messageListener" ref="messageListernerConsumerService"/> 45 </bean> 46 47 <!-- 单线程消息监听容器 --> 48 <!--<bean id="messageListenerContainer" class="org.springframework.kafka.listener.KafkaMessageListenerContainer" init-method="doStart"> 49 <constructor-arg ref="consumerFactory"/> 50 <constructor-arg ref="containerProperties"/> 51 </bean>--> 52 53 <!-- 多线程消息监听容器 --> 54 <bean id="messageListenerContainer" class="org.springframework.kafka.listener.ConcurrentMessageListenerContainer" init-method="doStart"> 55 <constructor-arg ref="consumerFactory"/> 56 <constructor-arg ref="containerProperties"/> 57 <property name="concurrency" value="5"/> 58 </bean> 59 60 </beans>
多线程消息监听容器配置[ 消费者spring-kafka配置文件]相关推荐
- RabbitMQ消息监听(多种模式-fanout/topic)
1.rabbitmq消息监听,兼容多种模式的消息,fanout/topic等模式 MQ消息配置监听: package com.test.ddyin.conf;import java.util.Hash ...
- oracle 客户端监听文件配置
oracle 数据库 plsql 客户端的监听文件配置 tnsnames.ora ORCL =(DESCRIPTION =(ADDRESS_LIST =(ADDRESS = (PROTOCOL = T ...
- XMPP——Smack[2]会话、消息监听、字体表情和聊天窗口控制
连接之后,拿到了connection,通过它可以搞定会话 建立一个会话 [java] view plaincopyprint? MessageListener msgListener = new Me ...
- 3、配置/管理Oracle数据库---监听程序配置
3.配置/管理Oracle数据库-监听程序配置 在成功创建Oracle数据库之后,用户可以对其进行配置和管理.需要用到网络配置助手工具 网络配置助手:主要用于Oracle数据库的监听程序.命名方法 ...
- Oracle客户端监听服务配置方法
Oracle客户端监听服务配置方法 可直接修改tnsnames.oRA文件 Oracle客户端中一般有两个tnsnames.oRA文件,配置监听要修改的是Oracle客户端家目下的$ORACLE_HO ...
- 基于目标追踪算法、web、gui开发的程序,可实时监控画面、检测目标、监听电脑配置
基于目标追踪算法.web.gui开发的程序,可实时监控画面.检测目标.监听电脑配置,此项目由软件+网页设计而成,请看项目展示.
- oracle删除重新创建监听,重新配置监听程序
本步骤完成以下操作:删除并重新创建监听程序,配置监听程序的可执行文件的路径. 10.1.1 删除监听程序 (1)打开"开始"菜单->"程序"->&q ...
- springboot—监听容器启动事件—拦截器及注册
1.监听容器启动事件 2.拦截器
- Socket编程(C语言实现)——TCP协议(网络间通信AF_INET)的流式(SOCK_STREAM)+报式(SOCK_DGRAM)传输【多线程+循环监听】
Socket编程 目前较为流行的网络编程模型是客户机/服务器通信模式 客户进程向服务器进程发出要求某种服务的请求,服务器进程响应该请求.如图所示,通常,一个服务器进程会同时为多个客户端进程服务,图中服 ...
最新文章
- [BX] 和 loop 指令---汇编学习笔记
- 使用git克隆GitHub仓库时报错解决方案
- 一台PoE工业交换机可以给多少设备供电?
- 云原生人物志|Pulsar翟佳:社区的信任最重要
- 《Ansible权威指南 》一第2章 Ansible基础元素介绍
- python字符画太小_python小项目(-)图片转字符画
- 动态规划——乘积为正数的最长子数组长度(Leetcode 1567)
- mysql查询缓存优化配置_mysql 优化之查询高速缓冲配置 小记
- 填坑-关于IIC通讯
- (day 52 - 二叉搜索树) 剑指 Offer 68 - I. 二叉搜索树的最近公共祖先
- JAVA性能优化权威指南 读书笔记(一)
- Java面向对象编程,绘制思维导图(全面详细整理)
- 蓝桥杯单片机组经验分享之(三)各模块用法(1)138译码器
- android免费图标_20个免费和高质量的Android图标集—最佳
- 给初学编程的人的忠告
- 学生干部管理系统的现状分析和可行性分析
- 首次全面深度解密华为方舟编译器
- UICollectionView左对齐
- 基于Cortex-A53内核Linux系统gec6818开发板的电子自助点餐设计
- uniapp教室实验室会议室预约app源码
热门文章
- keyword-- final
- 使用mac 终端利用alias设置快捷命令
- 通过传入的栏目编号找出并返回当前栏目编号及其所有子栏目编号
- spring+mybatis 多数据源整合
- 应用jBPM4解决中国特色的流程需求 (看过之后,强烈推荐)
- UVA11419 我是SAM
- hdu4847 水题
- 【报错信息】Google Play 上架报错 ( Your app contains ads that do not comply with our Families ad | 退出亲子同乐计划 )
- 【Android 异步操作】手写 Handler ( 消息队列 MessageQueue | 消息保存到链表 | 从链表中获取消息 )
- 逃亡的准备(大数据版)