首页
学习
活动
专区
工具
TVP
发布

发哥说消息队列

专栏作者
27
文章
32860
阅读量
72
订阅数
kafka常见报错集合-四
1、生产者连接kafka有reset的报错: write curve kafka failed , write: connection reset by peer
沐榕樰
2024-03-17
1740
kafka常见报错集合-三
完整日志信息: [2021-12-10 14:10:49.244][INFO][promotionEventConsumer-0-C-1][org.apache.kafka.clients.consumer.internals.AbstractCoordinator][[,,,]][TID: N/A] - [Consumer clientId=consumer-4, groupId=promotionEventGroup] Group coordinator xxx.xxx.xxx.xxx:9093 (id: 2147383250 rack: null) is unavailable or invalid, will attempt rediscovery
沐榕樰
2024-03-10
290
kafka常见报错集合-二
Failed to send SASL handshake xxx.xxx.xxx.xxx:port: tls: failed to verify certificate: x509: certificate relies on legacy Common Name field, use SANs instead
沐榕樰
2024-03-03
790
kafka常见报错集合-一
用java客户端消费topic的数据的时候,会报错The fetch session encountered inconsistent topic ID usage Caused by: org.apache.kafka.common.KafkaException: Unexpected error in join group response: The fetch session encountered inconsistent topic ID usage
沐榕樰
2024-02-25
1500
线上Kafka集群部署规划建议
现在我们就来看看在生产环境中的 Kafka 集群规划该怎么做。既然是集群,那必然就要有多个 Kafka 节点机器,因为只有单台机器构成的 Kafka 伪集群只能用于日常测试之用,根本无法满足实际的线上生产需求。而真正的线上环境需要仔细地考量各种因素,结合自身的业务需求而制定。
沐榕樰
2024-02-19
940
TDMQ-pulsar消息的顺序性
Pulsar中消息的顺序性和几个因素有关:用户自己的业务线程数、Producer 的路由模式(SinglePartition、RoundRobinPariion等、Topie是否分区、发送方式(同步、异步),是否开启批量发送、消息是否有Key。 每个Producer实例都有一个属于自已的发送队列,不管是同步发送还是异步发送,所有的消息都会先进入这个队列。同步发送是基于异步发送实现的----异步发送会返回一个CompletablePuture对象,同步发送只是在此基础上同步等特而已(通过CompletableFuture,get()实现)。因此,同步发送的消息也会先进入发送队列,不过每次入队后都会触发发送操作。
沐榕樰
2022-05-06
1.9K0
ckafka、Pulsar、TDMQ RocketMQ 版、TDMQ RabbitMQ 版和TDMQ CMQ 版功能上有啥区别
ckafka、TDMQ Pulsar版、TDMQ RocketMQ 版、TDMQ RabbitMQ 版和TDMQ CMQ 版功能上有啥区别
沐榕樰
2022-04-25
1.7K0
手把手教学--从Pulsar到TDMQ
导语:介于TDMQ还没有公网的访问功能,不可能买台CVM安装windows吧,VPN又只能支持协议类型: IKE/IPsec,意思是企业用户才能用,对于个人就只能再想办法了,但办法总比问题多。本地开发测试环境使用pulsar的单机版,生产使用TDMQ,这样怎么样,一起来看看怎么配置。
沐榕樰
2020-12-03
1.8K0
TDMQ系列学习 - 消息队列里的“新物种”(一)
导语:TDMQ是什么?常见的消息队列有:kafka、ActiveMQ、RabbitMQ、RocketMQ、ZeroMQ、MetaMQ、CMQ等,今天介绍的是TDMQ。
沐榕樰
2020-11-21
2.9K0
CKafka系列学习文章 - 云上消息队列它香不香?(十七)
一、先买买买,一个 1、供上购买链接:https://buy.cloud.tencent.com/ckafka?rid=1 2、先创建一个Ckafka实例 image.png image.png im
发哥说消息队列
2020-06-15
1.5K0
CKafka系列学习文章 - 你是否踩过Ckafka的这些坑(十六)
导读:目前国内公有云上的kafka产品都是基于开源kafka产品二次封装改造的,基本上开源kafka的配置参数都能应用在云上kafka产品里。本文以腾讯云的ckafka产品为例,分别介绍了几个应用场景,每个点都有详细的配置干货。通过这些设置和正确的使用姿势,我们来很好的保证关联业务的稳定性和可靠性。
发哥说消息队列
2020-05-11
1.2K0
CMQ系列学习文章 - topic消息过滤类型使用说明( 一 )
导语:首先这里的标签跟资源标签无关,资源标签是对queue进行分类,便于识别、查询和管理。
发哥说消息队列
2019-11-26
8170
CKafka系列学习文章 - CKafka入门型配置压测报告(十五)
CKafka实例: 规格:入门型、峰值带宽: 40 MB/s、磁盘容量: 300GB,
发哥说消息队列
2019-09-30
1K0
CKafka系列学习文章 - 搭建单机模式zookeeper+kafka(十四)
导语:搭建单机模式的zookeeper+kafka,用来做开发测试环境,管理主题、分区、生产消费及主题数据的导入导出。
发哥说消息队列
2019-09-17
8270
CKafka系列学习文章 - 调用API接口管理主题(十三)
接口请求域名:ckafka.api.qcloud.com 本接口(CreateTopic)用于在消息队列 CKafka 实例下创建主题。
发哥说消息队列
2019-09-11
5610
CKafka系列学习文章 - 用java调用Ckafka实例相关接口(十二)
接口请求域名:ckafka.api.qcloud.com 本接口(ListInstance)用于在用户账户下获取消息队列 CKafka 实例列表。
发哥说消息队列
2019-09-11
1.1K0
CKafka系列学习文章 - 用java实现API调用(十一)
导语:上一章节我们了解了怎么手动拼接请求URL和用API2.0签名自动生成请求URL,来调用CKafka的接口,这一章将进入开发阶段,用java实现拼接请求URL,进行API调用。
发哥说消息队列
2019-09-06
6260
CKafka系列学习文章 - 手动拼接和自动拼接请求URL(十)
导语:我们来搭建开发环境调用消息队列 CKafka--手动拼接和自动拼接请求URL,来调用获取消费分组offset的接口
发哥说消息队列
2019-09-05
9430
CKafka系列学习文章 - Flume接入Ckafka(九)
导语:当你的业务系统既要对实时数据进行处理也要对离线数据进行分析时,这时候可以来了解一下Flume。
发哥说消息队列
2019-09-05
6960
CKafka系列学习文章 - Logstash接入CKafka (八)
导语:前面一章讲了Filebeat对接Ckafka,通常的场景是各种beats将数据存到CKafka,然后Logstash将从Ckafka中消息消息进行过滤,再经过Ckafka存入到Elasticsearch 。
发哥说消息队列
2019-09-02
7150
点击加载更多
社区活动
腾讯技术创作狂欢月
“码”上创作 21 天,分 10000 元奖品池!
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档