技术分析

jsfx
数据可视化技术分析

实战:SpringBoot+KafKa实现生产者和消费者功能

技术分析1702年前 (2019-06-25)大数据

1.配置pom包

<dependency>

  <groupId>org.springframework.kafka</groupId>

  <artifactId>spring-kafka</artifactId>

</dependency>

2.配置application.yml kafka部分:

kafka:    # 指定kafka 代理地址,可以多个

    bootstrap-servers: hadoop:9092, slave1:9092

    template:    # 指定默认topic id

      default-topic: producer

    listener:  # 指定listener 容器中的线程数,用于提高并发量

      concurrency: 5

    consumer:

      group-id: myGroup # 指定默认消费者group id

      client-id: 200

      max-poll-records: 200

      auto-offset-reset: earliest # 最早未被消费的offset

    producer:

      batch-size: 10 # 每次批量发送消息的数量

      retries: 3

      client-id: 200

3.定义生产者类:

 

4.定义消费者类:

 

5.定义生产者controller:

 

扫描二维码至手机访问

扫描二维码推送至手机访问。

版权声明:本文由策意data发布,如需转载请注明出处。

转载请注明出处:http://dsj.ceyicm.cn/reed/3.html

分享给朋友:
返回列表

没有更早的文章了...

下一篇:利用org.mybatis.generator生成实体类

相关文章

分享SQL,查询用户最近一次购买时间间隔

分享SQL,查询用户最近一次购买时间间隔

(1)先创建一张测试表:1   CREATE TABLE `用户购买订单` (2 3   `购买时间` datetime(6)&n...

.NET Core中过滤器Filter的使用介绍

.NET Core中过滤器Filter的使用介绍

知识点回顾:前面几篇文章分别给大家介绍了(1)Swagger的集成和用法;(2)JWT身份验证的集成和用法;(3)OOM框架AnutoMapper对象映射的用法;今天给大家介绍过滤器Filter的基本...

Jenkins+svn+ftp自动化发布asp.net项目

Jenkins+svn+ftp自动化发布asp.net项目

今天将自己所掌握的(Jenkins+svn+ftp自动化发布asp.net项目)知识分享给大家,希望能帮组到大家:(1)先下载Jenkins并安装;(2)安装.Net所需要的插件;(3)配置插件;(4...

将本地构建好的docker镜像发布到dockerhub

将本地构建好的docker镜像发布到dockerhub

各位读者你们好,上一篇文章介绍了如何将.NET Core项目构建成一个docker镜像,那么今天接下来我们介绍如何将本地docker项目镜像发布到dockerhub上,好了废话不多说,直接进入正题:(...

为什么不再使用D3.js、Echarts做数据可视化

为什么不再使用D3.js、Echarts做数据可视化

D3是什么全称是(Data-Driven Documents),一个被数据驱动的文档简单点,是一个JavaScript函数库,使用它主要用来做数据可视化。D3 是一个开源项目,作者是纽约时报的工程师。...

集成Swagger接口文档分组配置.net core

集成Swagger接口文档分组配置.net core

(一)回顾:上一篇为大家介绍了在.NET Core中如何集成Swagger的介绍,想想集成操作其实非常简单便捷,实质就三个步骤:(1)在项目中执行nuget命令,拉取Swagger包到项目:Insta...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法、交流您的观点。
每一次合作都多一位朋友

体验账号:administrator 密码:administrator

  • 7X12小时
    7X12小时

    专家1V1服务

  • 业务保障
    业务保障

    扎实数据根基

  • 合作伙伴
    合作伙伴

    NBIDataVis

  • 强大交付
    强大交付

    实现客户价值