当前位置: 首页 > news >正文

wordpress 如何添加模板文件seo推广优化公司

wordpress 如何添加模板文件,seo推广优化公司,怎么做网页聊天室,牡丹江做网站的公司SpringBoot集成Kafka 一、前言二、项目1. pom2. application.properties4. 消息生产者-测试5. 消息消费者 三、启动测试四、有总结的不对的地方/或者问题 请指正, 我在努力中 一、前言 该文章中主要对SpringBoot 集成Kafka 主要是 application.properties 与 pom坐标就算集成完…

SpringBoot集成Kafka

  • 一、前言
  • 二、项目
    • 1. pom
    • 2. application.properties
    • 4. 消息生产者-测试
    • 5. 消息消费者
  • 三、启动测试
  • 四、有总结的不对的地方/或者问题 请指正, 我在努力中

一、前言

该文章中主要对SpringBoot 集成Kafka 主要是 application.properties 与 pom坐标就算集成完成,剩下的就是一些 消费者 / 发布者的操作了详细的请看项目代码。简简单单 快速集成

二、项目

1. pom

<dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId>
</dependency>

2. application.properties

spring.kafka.bootstrap-servers=192.168.0.113:9092
# 生产者配置
spring.kafka.producer.retries=2
spring.kafka.producer.batch-size=16384
spring.kafka.producer.buffer-memory=33554432
spring.kafka.producer.key-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.value-serializer=org.apache.kafka.common.serialization.StringSerializer
spring.kafka.producer.acks=-1# 消费者配置
spring.kafka.consumer.enable-auto-commit=true
spring.kafka.consumer.auto-commit-interval.ms=1000
spring.kafka.consumer.auto-offset-reset=latest
spring.kafka.consumer.max-poll-records=500
spring.kafka.consumer.fetch-max-wait.ms=500
spring.kafka.consumer.fetch-min-size=1
spring.kafka.consumer.heartbeat-interval.ms=3000
spring.kafka.consumer.key-deserializer=org.apache.kafka.common.serialization.StringDeserializer
spring.kafka.consumer.value-deserializer=org.apache.kafka.common.serialization.StringDeserializer

4. 消息生产者-测试

@RunWith(SpringJUnit4ClassRunner.class)
@SpringBootTest(classes = ZoheVideoStructApplication.class)
public class ZoheVideoStructApplicationTest {@Autowiredprivate KafkaTemplate<String,String> kafkaTemplate;@Testpublic void test(){kafkaTemplate.send("sb_topic","123132132132132132123132132");}
}

5. 消息消费者

@Component
public class KafkaConsumer {//监听消费@KafkaListener(topics = {"sb_topic"},groupId = "test")public void onNormalMessage(ConsumerRecord<String, Object> record) {System.out.println("简单消费:" + record.topic() + "-" + record.partition() + "="+  record.value());}//监听消费@KafkaListener(topics = {"sb_topic"},groupId = "test2")public void onNormalMessage2(ConsumerRecord<String, Object> record) {System.out.println("简单消费2:" + record.topic() + "-" + record.partition() + "=" + record.value());}}

三、启动测试

在这里插入图片描述

四、有总结的不对的地方/或者问题 请指正, 我在努力中

http://www.yayakq.cn/news/824230/

相关文章:

  • 鄂尔多斯建设局网站免费设计签名的软件
  • 宁波中科网站建设有限公司网站的建设进入哪个科目
  • 互联网兼职做网站维护比较好的建站系统
  • 网站开发平台介绍设计工作室网站源码
  • 传媒公司做网站编辑 如何教育教学网站建设
  • 一级a做爰片完整网站怎么做带数据库的网站
  • 做酒水网站陕西有哪些东莞商业网站建设常识
  • 2015年做网站行不行查询网站mx记录
  • 建设网站经验网页建站网站申请
  • 学校网站建设源码wordpress本地nginx
  • 上海网站建设商城如何干电商
  • 建设银行网站会员有什么用哪些网站用黑体做的
  • 建设一个网站的费用网站做的自适应体验差
  • 成都官方网站建设淘宝指数在哪里查询
  • 经典的响应式布局网站wordpress跳转站点
  • 专注番禺网站优化网站建设制作设计营销 上海
  • 建设工程网站建筑工程预算wordpress 托管主机
  • 桂林哪里学建设网站广州市品牌网站建设服务机构
  • 惠山区住房和建设厅网站怎么卸载windows优化大师
  • 常州高端网站建设公司特产电商网站建设报价单
  • 做企业网站合同广州开发区官网
  • wordpress 站内信 群发阿里云主机 wordpress
  • 包装设计网站有哪些大汉网站开发
  • 国内网站需要备案摄影作品
  • 具有品牌的做pc端网站网站建设的感想与建议
  • 个人网站多少钱仓库管理软件哪个好
  • 百捷网站建设重庆官方推广网站
  • 汕头多语种网站制作新品发布会手机
  • 可视化建站网站源码重庆免费发布信息网站
  • 建设建设网站的百度免费邮箱注册