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

咖啡店网站模板站长之家最新域名查询

咖啡店网站模板,站长之家最新域名查询,下载手机app软件,四川集团网站建设1 Kafka Kafka 是由 Linkedin 公司开发的,它是一个分布式的,支持多分区、多副本,基于 Zookeeper 的分布式消息流平台,它同时也是一款开源的基于发布订阅模式的消息引擎系统。 2 Maven依赖 <dependency><groupId>org.springframework.kafka</groupId><…

1 Kafka

        Kafka 是由 Linkedin 公司开发的,它是一个分布式的,支持多分区、多副本,基于 Zookeeper 的分布式消息流平台,它同时也是一款开源的基于发布订阅模式的消息引擎系统。

2 Maven依赖

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

3 Spring Boot配置

spring:kafka:bootstrap-servers: localhost:9092producer:batch-size: 16384buffer-memory: 67108864acks: 1compression-type: lz4key-serializer: org.apache.kafka.common.serialization.StringSerializervalue-serializer: org.apache.kafka.common.serialization.StringSerializerconsumer:enable-auto-commit: trueauto-offset-reset: latestkey-deserializer: org.apache.kafka.common.serialization.StringSerializervalue-deserializer: org.apache.kafka.common.serialization.StringSerializer

4 生产者配置

4.1 KafkaProducerConfig

        生产者的相关配置,指定kafka的地址,消息序列化器。

        topic的分区数、副本数。

package com.xudongbase.kafka.producer;import com.xudongbase.kafka.constant.KafkaTopicConstant;
import org.apache.kafka.clients.CommonClientConfigs;
import org.apache.kafka.clients.admin.AdminClient;
import org.apache.kafka.clients.admin.AdminClientConfig;
import org.apache.kafka.clients.admin.NewTopic;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.kafka.core.ProducerFactory;import java.util.HashMap;
import java.util.Map;
import java.util.Properties;@Configuration
public class KafkaProducerConfig {@Value(value = "${spring.kafka.bootstrap-servers:}")private String bootstrapAddress;/*** 分区(分区数需要慎重设置,一般分区数为消费者的倍数,要不然在消费高峰时刻会出现消费速度不一样的情况)*/private static final int NUM_PARTITIONS = 5;/*** 副本*/private static final short REPLICATION_FACTOR = (short) 2;
http://www.15wanjia.com/news/52411.html

相关文章:

  • 网站登录账号密码保存百度竞价优化软件
  • 大学 网站开发 专业长沙seo优化价格
  • 个人外贸网站制作百度竞价运营
  • 陕西网站建设公司找哪家搜索引擎关键词优化
  • 做商城网站要哪些流程图外链发布平台有哪些
  • 竞价安徽新站优化
  • 如何做网站泛目录解析游戏代理300元一天
  • 1核2g 做网站cpc广告接单平台
  • 淄博网站制作开发优化dw网页制作教程
  • 做网站不用数据库可以吗外链seo推广
  • 网站开发的理解宁德市地图
  • 航拍类wordpress模板网页关键词排名优化
  • 网站建设培训班百度搜索推广费用
  • 泰安建设信息网站网络推广和运营的区别
  • 自建外贸推广网站有哪些游戏代理平台
  • 淘宝客怎么样做网站武汉seo哪家好
  • 摄影瀑布流网站模板太原seo关键词优化
  • 如何规范网站使用让顾客进店的100条方法
  • 公安网站备案到底需要什么seo搜索优化是什么意思
  • 免费打开网站培训学校资质办理条件
  • 企业宣传网站建设模板网络推广方案的基本思路
  • 购物网站建设的目标线上销售方案
  • 项目协同管理软件seo排名外包
  • 十堰市网络运营中心福州短视频seo网红
  • 中国建筑官网一测二测成绩多少算及格seo搜索引擎优化关键词
  • 赣县城乡规划建设局网站百度官网平台
  • 二维码生成器网站源码百度爱采购推广平台
  • 做中东服装有什么网站免费开源网站
  • 建站公司走量渠道网络营销课程论文
  • 哈尔滨百度网站排名惠州seo关键词