腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
首页
学习
活动
专区
工具
TVP
最新优惠活动
返回腾讯云官网
别先生
爱生活,爱工作。
专栏成员
举报
588
文章
1182794
阅读量
64
订阅数
订阅专栏
申请加入专栏
全部文章(588)
java(104)
数据库(87)
spring(58)
云数据库 SQL Server(54)
编程算法(53)
sql(50)
其他(37)
xml(36)
maven(33)
http(33)
hadoop(32)
网络安全(29)
html(28)
eclipse(26)
网站(26)
https(24)
linux(21)
容器(21)
存储(19)
Elasticsearch Service(19)
javascript(18)
ide(18)
apache(18)
kubernetes(17)
struts(16)
nginx(16)
servlet(15)
jsp(15)
jquery(15)
分布式(15)
spring boot(14)
微服务(14)
node.js(13)
tomcat(12)
rabbitmq(12)
大数据(12)
数据处理(12)
json(11)
容器镜像服务(11)
tcp/ip(11)
kafka(11)
jar(10)
.net(9)
云数据库 Redis(9)
api(9)
postgresql(8)
打包(8)
spark(8)
zookeeper(8)
数据结构(8)
ajax(7)
jdk(7)
机器学习(6)
css(6)
oracle(6)
git(6)
腾讯云测试服务(6)
windows(6)
负载均衡(5)
c++(5)
vue.js(5)
lucene/solr(5)
负载均衡缓存(5)
文件存储(5)
shell(5)
hive(5)
mybatis(5)
spring cloud(5)
安全(5)
hbase(5)
php(4)
bootstrap(4)
中文分词(4)
ubuntu(4)
centos(4)
访问管理(4)
开源(4)
缓存(4)
数据迁移(4)
ssh(4)
jdbc(4)
二叉树(4)
aop(4)
dubbo(4)
数据分析(4)
云数据库 postgresql(4)
bash(3)
scala(3)
mvc(3)
github(3)
mapreduce(3)
消息队列 CMQ 版(3)
正则表达式(3)
npm(3)
虚拟机(3)
python(2)
erlang(2)
单片机(2)
全文检索(2)
analyzer(2)
unix(2)
bash 指令(2)
渲染(2)
express(2)
serverless(2)
grunt(2)
jvm(2)
yum(2)
面向对象编程(2)
hashmap(2)
grep(2)
jenkins(2)
utf8(2)
博客(2)
分页(2)
弹性伸缩(1)
自动驾驶(1)
c 语言(1)
ruby(1)
go(1)
access(1)
搜索引擎(1)
批量计算(1)
消息队列 CKafka 版(1)
SSL 证书(1)
短信(1)
云推荐引擎(1)
mongodb(1)
人工智能(1)
图像处理(1)
企业(1)
eslint(1)
xslt & xpath(1)
自动化(1)
压力测试(1)
dns(1)
推荐系统(1)
ftp(1)
udp(1)
gcc(1)
gradle(1)
socket编程(1)
kvm(1)
微信(1)
小程序(1)
nat(1)
nest(1)
任务调度(1)
虚拟化(1)
ipv6(1)
etcd(1)
es(1)
数据库管理(1)
app(1)
bug(1)
button(1)
centos7(1)
data(1)
debug(1)
frame(1)
gif(1)
jackson(1)
kettle(1)
math(1)
microsoft(1)
mysql(1)
nodes(1)
parent(1)
repository(1)
runtime(1)
service(1)
time(1)
title(1)
vmware(1)
war(1)
worker(1)
百度(1)
服务(1)
工具类(1)
函数(1)
集合(1)
加密(1)
开发(1)
框架(1)
内存(1)
配置(1)
前端(1)
数组(1)
搜索(1)
线程(1)
线程池(1)
搜索文章
搜索
搜索
关闭
RabbitMQ的安装与使用(Centos7,linux版本)
erlang
消息队列 CMQ 版
kafka
rabbitmq
1)、ActiveMQ是Apache出品,最流行的,能力强劲的开源消息总线,并且它一个完全支持jms(java message service)规范的消息中间件。其丰富的api,多种集群构建模式使得他成为业界老牌消息中间件,在中小企业中应用广泛。 如果不是高并发的系统,对于ActiveMQ,是一个不错的选择的,丰富的api,让你开发的很愉快哟。 注意:MQ衡量指标:服务性能,数据存储,集群架构。
别先生
2022-05-11
1.4K
0
Elastic Stack之 Logstash 6.7.1版本安装
kafka
nginx
云数据库 Redis
1、截至目前Elasticsearch 版本已经更新到了7.10.1版本了,这里先使用Logstash 6.7.1版本,给一个下载地址,如下所示:
别先生
2021-01-13
488
0
Kafka的消费者提交方式手动同步提交、和异步提交
kafka
网络安全
1)、自动提交,这种方式让消费者来管理位移,应用本身不需要显式操作。当我们将enable.auto.commit设置为true,那么消费者会在poll方法调用后每隔五秒(由auto.commit.interval.ms指定)提交一次位移。和很多其他操作一样,自动提交也是由poll方法来驱动的,在调用poll方法的时候,消费者判断是否到达提交时间,如果是则提交上一次poll返回的最大位移。需要注意的是,这种方式可能会导致消息重复消费,假如,某个消费者poll消息后,应用正在处理消息,在3秒后kafka进行了重平衡,那么由于没有更新位移导致重平衡后这部分消息重复消费。
别先生
2021-01-13
6.9K
0
kafka生产者Producer、消费者Consumer的拦截器interceptor
网络安全
kafka
正则表达式
1、Producer的拦截器interceptor,和consumer端的拦截器interceptor是在kafka0.10版本被引入的,主要用于实现clients端的定制化控制逻辑,生产者拦截器可以用在消息发送前做一些准备工作,使用场景,如下所示:
别先生
2021-01-13
1.6K
0
SpringBoot整合Kafka消息组件
kafka
maven
xml
1、Kafka是新一代的消息系统,也是目前性能最好的消息组件,在数据采集业务中被广泛应用。这里Kafka将基于Kerberos认证实现消息组件处理。
别先生
2020-11-26
867
0
RabbitMQ消息队列基础概念、原理学习
kafka
消息队列 CMQ 版
rabbitmq
答:队列就像存放了商品的仓库或者商店,是生产商品的工厂和购买商品的用户之间的中转站。
别先生
2019-11-04
557
0
单独KafkaConsumer实例and多worker线程。
kafka
worker
集合
线程
线程池
1、单独KafkaConsumer实例and多worker线程。 将获取的消息和消息的处理解耦,将消息的处理放入单独的工作者线程中,即工作线程中,同时维护一个或者若各干consumer实例执行消息获取任务。 本例使用全局的KafkaConsumer实例执行消息获取,然后把获取到的消息集合交给线程池中的worker线程执行工作,之后worker线程完成处理后上报位移状态,由全局consumer提交位移。
别先生
2019-06-03
564
0
kafka中消费者消费消息之每个线程维护一个KafkaConsumer实例
kafka
3、kafka中消费者消费消息之每个线程维护一个KafkaConsumer实例:
别先生
2019-06-03
507
0
基于kafka_2.11-2.1.0实现的生产者和消费者代码样例
kafka
网络安全
unix
遇到的坑,一开始报的错误莫名其妙,一开始以为使用的jar包版本问题,又是报slf4j的错误,又是报log4j的错误,又是报空指针的异常。最后百度意外遇到了可能是本地没有将ip地址放到hosts文件里面,果然是这个问题。
别先生
2019-06-03
1.9K
0
ERROR Fatal error during KafkaServer startup. Prepare to shutdown
kafka
1、之前搭建的kafka,过了好久,去启动kafka,发现报如下下面的错误,有错误就要解决了。
别先生
2019-06-03
4.6K
0
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.9K
0
没有更多了
社区活动
【纪录片】中国数据库前世今生
穿越半个世纪,探寻中国数据库50年的发展历程
立即查看
Python精品学习库
代码在线跑,知识轻松学
立即查看
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
立即体验
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
立即查看
领券
问题归档
专栏文章
快讯文章归档
关键词归档
开发者手册归档
开发者手册 Section 归档