码迷,mamicode.com
首页 >  
搜索关键字:producer    ( 888个结果
RocketMq灰皮书(三)------MQ使用
RocketMq灰皮书(三) MQ使用 在使用MQ之前,我们回顾一下前两篇博文的内容. 我们大致了解了RocketMQ的四个概念,分别是:Producer,Consumer,Message和Broker 我们在本地的Windows10系统上,部署了RocketMQ和其后台系统 在本篇博文中,我们会使 ...
分类:其他好文   时间:2021-02-19 13:45:46    阅读次数:0
test_log-0 in dir D:\tmp\kafka-logs Caused by: java.nio.file.FileSystemExcept 错误问题
启动完kafka后,go run producer.go 程序之后出现 D:\tmp\kafka-logs\__consumer_offsets-48\00000000000000000000.test_log.log: 另一个程序正在使用此文件,进程无法访问。 解决办法,网上说,直接把tmp的这个 ...
分类:编程语言   时间:2021-02-03 10:47:28    阅读次数:0
kafka
#kafka ##1.kafka基础架构 Kafka是一个分布式的基于发布/订阅模式的消息队列,主要应用于大数据实时处理领域。 消息生产者(发布)将消息发布到topic中,同时有多个消息消费者(订阅)消费该消息。和点对点方式不同,发布到topic的消息会被所有订阅者消费。 (1)Producer : ...
分类:其他好文   时间:2021-01-30 12:13:24    阅读次数:0
Spring Boot整合RabbitMQ
转自:https://www.cnblogs.com/lusaisai/p/13019822.html 在Spring项目中,可以使用Spring-Rabbit去操作RabbitMQ https://github.com/spring-projects/spring-amqp 尤其是在spring ...
分类:编程语言   时间:2021-01-26 12:25:45    阅读次数:0
kafka 如何保证数据不丢失
一般我们在用到这种消息中件的时候,肯定会考虑要怎样才能保证数据不丢失,在面试中也会问到相关的问题。但凡遇到这种问题,是指3个方面的数据不丢失,即:producer consumer 端数据不丢失 broker端数据不丢失下面我们分别从这三个方面来学习,kafka是如何保证数据不丢失的 一.produ ...
分类:其他好文   时间:2021-01-18 10:53:52    阅读次数:0
kafka
Kafka概述 定义 Kafka是一个分布式的基于发布/订阅模式的消息队列(Message Queue),主要应用于大数据实时处理领域。 传统消息队列的应用场景 使用消息队列的好处 1:解耦 允许你独立的扩展或修改两边的处理过程,只要确保它们遵守同样的接口约束。 2:可恢复性 系统的一部分组件失效时 ...
分类:其他好文   时间:2021-01-02 10:52:13    阅读次数:0
ssm+RabbitMQ 整合
1. 配置说明 1.配置rabbitmq.properties rmq.ip=192.168.5.109 rmq.port=5672 rmq.producer.num=20 rmq.manager.user=test rmq.manager.password=123456 2.使用注解配置Rabbi ...
分类:其他好文   时间:2020-12-15 12:54:42    阅读次数:8
Kafka 消息丢失与消费精确一次性
消息丢失的场景如果KafkaProducer使用“发后即忘”的方式发送消息,即调用producer.send(msg)方法来发送消息,方法会立即返回,但此时并不能说明消息已经发送成功。消息发送方式详见初次邂逅Kafka生产者。如果在消息过程中发生了网络抖动,那么消息就会丢失;或发送的消息本身不符合要求,如大小超过Broker端的承受能力等(消息太大的情况在生产中实际遇到过,最后通过在发送前将消息分
分类:其他好文   时间:2020-12-08 12:53:00    阅读次数:5
初识 Kafka Producer 生产者
温馨提示:整个KafkaClient专栏基于kafka-2.3.0版本。1、KafkaProducer概述根据KafkaProducer类上的注释上来看KafkaProducer具有如下特征:KafkaProducer是线程安全的,可以被多个线程交叉使用。KafkaProducer内部包含一个缓存池,存放待发送消息,即ProducerRecord队列,与此同时会开启一个IO线程将ProducerR
分类:其他好文   时间:2020-12-07 12:49:28    阅读次数:11
consumer 是推还是拉?
Kafka 最初考虑的问题是,customer 应该从 brokes 拉取消息还是 brokers 将消 息推送到 consumer,也就是 pull 还 push。在这方面,Kafka 遵循了一种大部分 消息系统共同的传统的设计:producer 将消息推送到 broker,consumer 从 ...
分类:其他好文   时间:2020-12-03 11:32:29    阅读次数:3
888条   上一页 1 2 3 4 5 ... 89 下一页
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!