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

温州网站制作价格竞价推广专员

温州网站制作价格,竞价推广专员,opencart网站,公司建设电商型网站的作用kafka的基础概念 Producer (消息生产者) 向主题发布消息的客户端应用程序称为生产者(Producer),生产者用于持续不断的向某个主题发送消息。 Consumer (消息消费者) 订阅主题消息的客户端程序称为消费者(Consumer),消费者用于处理生产者产生的消息。 Co…

kafka的基础概念

  • Producer (消息生产者)
    向主题发布消息的客户端应用程序称为生产者(Producer),生产者用于持续不断的向某个主题发送消息。

  • Consumer (消息消费者)
    订阅主题消息的客户端程序称为消费者(Consumer),消费者用于处理生产者产生的消息。

  • Consumer Group (消费者组)

每个消费者属于一个特定的消费者群组(可为每个消费者指定group name,若不指定group name则属于默认的group)。

每个消费者群组都有一个唯一的GroupId。

  • Brokers(kafka服务器)

一个独立的 Kafka 服务器就被称为 broker,broker 接收来自生产者的消息,为消息设置偏移量,并提交消息到磁盘保存。

一个broker可以容纳多个topic。每个broker都有各自的broker.id。

  • Topics(主题)

消息的种类称为 主题(Topic),可以说一个主题代表了一类消息。相当于是对消息进行分类。

  • Partition(分区)

主题(Topic)可以被分为若干个分区(partition),同一个主题中的分区可以不在一个机器上,有可能会部署在多个机器上,

由此来实现 kafka 的伸缩性,单一主题中的分区有序,但是无法保证主题中所有的分区有序。

安装kafka,创建 topic:

Windows安装kafka, 详情见:https://blog.csdn.net/sinat_32502451/article/details/133067851

Linux 安装kafka,详情见:https://blog.csdn.net/sinat_32502451/article/details/133080353

添加依赖包:

        <dependency><groupId>org.springframework.kafka</groupId><artifactId>spring-kafka</artifactId><version>2.1.10.RELEASE</version></dependency><dependency><groupId>org.apache.kafka</groupId><artifactId>kafka-clients</artifactId><version>2.0.0</version></dependency>

kafka生产者示例:

按以下步骤发送消息:

  • 设置 broker服务器的ip和端口
  • 生产者初始化
  • 发送消息
public class KafkaDemoProducer {public static final String BROKER_LIST = "localhost:9092";public static final String TOPIC = "myTopic1";public static void main(String[] args) {//属性配置Properties properties = getProperties(BROKER_LIST);//生产者初始化KafkaProducer<String, String> producer = new KafkaProducer<>(properties);ProducerRecord<String, String> record = new ProducerRecord<>(TOPIC, "hello kafka");//发送消息try {producer.send(record);} catch (Exception e) {System.out.println("send error." + e);}producer.close();}private static Properties getProperties(String brokerList) {Properties properties = new Properties();properties.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");properties.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");properties.put("bootstrap.servers", brokerList);return properties;}}

kafka消费者示例:

主要按照以下步骤:

  • 设置 broker服务器的ip和端口, 设置 消费者群组id

  • 初始化消费者

  • 消费者订阅主题

  • 消费者批量拉取消息

public class KafkaDemoConsumer {public static final String BROKER_LIST = "localhost:9092";public static final String TOPIC = "myTopic1";public static final String GROUP_ID = "group.demo";public static void main(String[] args) {consumerRecord();}public static void consumerRecord() {//属性配置Properties properties = getProperties(BROKER_LIST, GROUP_ID);//消费者初始化KafkaConsumer<String, String> consumer = new KafkaConsumer<>(properties);//消息者订阅主题consumer.subscribe(Collections.singletonList(TOPIC));//循环while (true) {//每次拉取 1千条消息ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(1000));for (ConsumerRecord<String, String> record : records) {System.out.println("=============> 消费kafka消息:"+ record.value());}}}public static Properties getProperties(String brokerList, String groupId) {Properties properties = new Properties();//序列化properties.put("key.deserializer","org.apache.kafka.common.serialization.StringDeserializer");properties.put("value.deserializer","org.apache.kafka.common.serialization.StringDeserializer");//broker服务器的ip和端口,多个用逗号隔开properties.put("bootstrap.servers", brokerList);//消费者群组idproperties.put("group.id", groupId);return properties;}}

观察idea 控制台,可以看到 成功消费了消息:

=============> 消费kafka消息:hello kafka

参考资料:

《深入理解kafka 核心设计与实践原理》
kafka的简单理解

http://www.ritt.cn/news/21741.html

相关文章:

  • 深圳网站建设吗杭州网站推广优化公司
  • 谷歌云做网站网络销售管理条例
  • 平凉市建设局网站强力搜索引擎
  • 软件开发有前途吗杭州seo网络推广
  • 为什么要用国外服务器做网站安阳企业网站优化外包
  • 网站服务公司解释seo网站推广
  • 网站首页的布局方式最新推广赚钱的app
  • 做网站连带责任qq群推广平台
  • java开源代码网站网站推广是什么意思
  • seo网站建设公司哪家好郑州做网络营销渠道
  • 可信赖的广州做网站安徽网站推广优化
  • 摄影网站有哪些?seo网站培训优化怎么做
  • 中国行业网站手机百度网址大全首页
  • 网站的构成北京seo经理
  • 免费发布信息网有哪些网站自己建网站需要多少钱
  • 浙江网站建设费用站长工具seo综合查询收费吗
  • wordpress自带图片seo网址超级外链工具
  • 网页制作软件怎么做合肥seo快排扣费
  • 域名类型南阳seo优化
  • wordpress idcseo入门培训学校
  • 微网站平台微网站建设方案小说排行榜
  • dw设计网页步骤临沂百度seo
  • 我想网上做网站seo网络优化
  • 武昌做网站公司电话推广普通话的意义
  • 摄影网站的需求分析网站关键词怎么设置
  • 100个免费推广网站下载seo搜索引擎优化试题
  • 做网站动态背景的图片策划书模板
  • 哪个网站做演唱会门票如何写软文推广产品
  • 做数学题目在哪个网站好阿里指数官网
  • 松原手机网站开发公司快手seo软件下载