别先生-腾讯云开发者社区

开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

别先生

爱生活，爱工作。

专栏成员

588

文章

1182371

阅读量

64

订阅数

RabbitMQ的安装与使用（Centos7，linux版本）

erlang 消息队列 CMQ 版 kafka rabbitmq

　　1）、ActiveMQ是Apache出品，最流行的，能力强劲的开源消息总线，并且它一个完全支持jms（java message service）规范的消息中间件。其丰富的api，多种集群构建模式使得他成为业界老牌消息中间件，在中小企业中应用广泛。如果不是高并发的系统，对于ActiveMQ，是一个不错的选择的，丰富的api，让你开发的很愉快哟。注意：MQ衡量指标：服务性能，数据存储，集群架构。

2022-05-11

1.4K0

Elastic Stack之 Logstash 6.7.1版本安装

kafka nginx 云数据库 Redis

1、截至目前Elasticsearch 版本已经更新到了7.10.1版本了，这里先使用Logstash 6.7.1版本，给一个下载地址，如下所示：

2021-01-13

4880

Kafka的消费者提交方式手动同步提交、和异步提交

kafka 网络安全

　　1）、自动提交，这种方式让消费者来管理位移，应用本身不需要显式操作。当我们将enable.auto.commit设置为true，那么消费者会在poll方法调用后每隔五秒（由auto.commit.interval.ms指定）提交一次位移。和很多其他操作一样，自动提交也是由poll方法来驱动的，在调用poll方法的时候，消费者判断是否到达提交时间，如果是则提交上一次poll返回的最大位移。需要注意的是，这种方式可能会导致消息重复消费，假如，某个消费者poll消息后，应用正在处理消息，在3秒后kafka进行了重平衡，那么由于没有更新位移导致重平衡后这部分消息重复消费。

2021-01-13

6.9K0

kafka生产者Producer、消费者Consumer的拦截器interceptor

网络安全 kafka 正则表达式

1、Producer的拦截器interceptor，和consumer端的拦截器interceptor是在kafka0.10版本被引入的，主要用于实现clients端的定制化控制逻辑，生产者拦截器可以用在消息发送前做一些准备工作，使用场景，如下所示：

2021-01-13

1.6K0

SpringBoot整合Kafka消息组件

kafka maven xml

1、Kafka是新一代的消息系统，也是目前性能最好的消息组件，在数据采集业务中被广泛应用。这里Kafka将基于Kerberos认证实现消息组件处理。

2020-11-26

8670

RabbitMQ消息队列基础概念、原理学习

kafka 消息队列 CMQ 版 rabbitmq

　　答：队列就像存放了商品的仓库或者商店，是生产商品的工厂和购买商品的用户之间的中转站。

2019-11-04

5570

单独KafkaConsumer实例and多worker线程。

kafka worker 集合线程线程池

1、单独KafkaConsumer实例and多worker线程。将获取的消息和消息的处理解耦，将消息的处理放入单独的工作者线程中，即工作线程中，同时维护一个或者若各干consumer实例执行消息获取任务。本例使用全局的KafkaConsumer实例执行消息获取，然后把获取到的消息集合交给线程池中的worker线程执行工作，之后worker线程完成处理后上报位移状态，由全局consumer提交位移。

2019-06-03

5630

kafka中消费者消费消息之每个线程维护一个KafkaConsumer实例

3、kafka中消费者消费消息之每个线程维护一个KafkaConsumer实例：

2019-06-03

5070

基于kafka_2.11-2.1.0实现的生产者和消费者代码样例

kafka 网络安全 unix

遇到的坑，一开始报的错误莫名其妙，一开始以为使用的jar包版本问题，又是报slf4j的错误，又是报log4j的错误，又是报空指针的异常。最后百度意外遇到了可能是本地没有将ip地址放到hosts文件里面，果然是这个问题。

2019-06-03

1.9K0

ERROR Fatal error during KafkaServer startup. Prepare to shutdown

1、之前搭建的kafka，过了好久，去启动kafka，发现报如下下面的错误，有错误就要解决了。

2019-06-03

4.6K0

Kafka的生产者和消费者代码解析

kafka 文件存储 ide

1:Kafka名词解释和工作方式 1.1:Producer ：消息生产者，就是向kafka broker发消息的客户端。 1.2:Consumer ：消息消费者，向kafka broker取消息的客户端 1.3:Topic ：可以理解为一个队列。 1.4:Consumer Group （CG）：这是kafka用来实现一个topic消息的广播（发给所有的consumer）和单播（发给任意一个consumer）的手段。一个topic可以有多个CG。topic的消息会复制（不是真的

2018-04-02

1.9K0

没有更多了

社区活动

【纪录片】中国数据库前世今生

穿越半个世纪，探寻中国数据库50年的发展历程

Python精品学习库

代码在线跑，知识轻松学

博客搬家 | 分享价值百万资源包

自行/邀约他人一键搬运博客，速成社区影响力并领取好礼

技术创作特训营·精选知识专栏

往期视频·千货材料·成员作品最新动态