发哥说消息队列-腾讯云开发者社区

开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

发哥说消息队列

专栏成员

29

文章

37271

阅读量

72

订阅数

解密kafka为啥总是在重平衡

使用的是java SDK ：kafka-clients：2.1.0， kafka版本：2.4.1

2024-08-01

1690

ckafka这个消费者参数配置后，为什么Kafka rebalance时间好长，超过一个小时还没有完成

ckafka这个消费者参数配置后，为什么Kafka rebalance时间好长，超过一个小时还没有完成

2024-07-04

980

kafka常见报错集合-四

1、生产者连接kafka有reset的报错： write curve kafka failed ， write: connection reset by peer

2024-03-17

7950

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

6330

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

2980

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

5600

线上Kafka集群部署规划建议

现在我们就来看看在生产环境中的 Kafka 集群规划该怎么做。既然是集群，那必然就要有多个 Kafka 节点机器，因为只有单台机器构成的 Kafka 伪集群只能用于日常测试之用，根本无法满足实际的线上生产需求。而真正的线上环境需要仔细地考量各种因素，结合自身的业务需求而制定。

2024-02-19

1300

TDMQ-pulsar消息的顺序性

消息队列 TDMQ 消息队列 CMQ 版

Pulsar中消息的顺序性和几个因素有关：用户自己的业务线程数、Producer 的路由模式(SinglePartition、RoundRobinPariion等、Topie是否分区、发送方式（同步、异步），是否开启批量发送、消息是否有Key。每个Producer实例都有一个属于自已的发送队列，不管是同步发送还是异步发送，所有的消息都会先进入这个队列。同步发送是基于异步发送实现的----异步发送会返回一个CompletablePuture对象，同步发送只是在此基础上同步等特而已（通过CompletableFuture,get（）实现)。因此，同步发送的消息也会先进入发送队列，不过每次入队后都会触发发送操作。

2022-05-06

2.2K0

ckafka、Pulsar、TDMQ RocketMQ 版、TDMQ RabbitMQ 版和TDMQ CMQ 版功能上有啥区别

消息队列 CKafka 版消息队列 TDMQ 消息队列 CMQ 版

ckafka、TDMQ Pulsar版、TDMQ RocketMQ 版、TDMQ RabbitMQ 版和TDMQ CMQ 版功能上有啥区别

2022-04-25

1.8K0

手把手教学--从Pulsar到TDMQ

消息队列 CMQ 版消息队列 CKafka 版

导语：介于TDMQ还没有公网的访问功能，不可能买台CVM安装windows吧，VPN又只能支持协议类型： IKE/IPsec，意思是企业用户才能用，对于个人就只能再想办法了，但办法总比问题多。本地开发测试环境使用pulsar的单机版，生产使用TDMQ，这样怎么样，一起来看看怎么配置。

2020-12-03

1.8K0

TDMQ系列学习 - 消息队列里的“新物种”（一）

消息队列 CMQ 版消息队列 CKafka 版

导语：TDMQ是什么？常见的消息队列有：kafka、ActiveMQ、RabbitMQ、RocketMQ、ZeroMQ、MetaMQ、CMQ等，今天介绍的是TDMQ。

2020-11-21

3.5K0

CKafka系列学习文章 - 云上消息队列它香不香？（十七）

消息队列 CKafka 版

一、先买买买，一个 1、供上购买链接：https://buy.cloud.tencent.com/ckafka?rid=1 2、先创建一个Ckafka实例 image.png image.png im

发哥说消息队列

2020-06-15

1.5K0

CKafka系列学习文章 - 你是否踩过Ckafka的这些坑（十六）

消息队列 CKafka 版

导读：目前国内公有云上的kafka产品都是基于开源kafka产品二次封装改造的，基本上开源kafka的配置参数都能应用在云上kafka产品里。本文以腾讯云的ckafka产品为例，分别介绍了几个应用场景，每个点都有详细的配置干货。通过这些设置和正确的使用姿势，我们来很好的保证关联业务的稳定性和可靠性。

发哥说消息队列

2020-05-11

1.2K0

CMQ系列学习文章 - topic消息过滤类型使用说明（一）

导语：首先这里的标签跟资源标签无关，资源标签是对queue进行分类，便于识别、查询和管理。

发哥说消息队列

2019-11-26

8670

CKafka系列学习文章 - CKafka入门型配置压测报告（十五）

消息队列 CKafka 版

CKafka实例：规格：入门型、峰值带宽: 40 MB/s、磁盘容量: 300GB，

发哥说消息队列

2019-09-30

1.1K0

CKafka系列学习文章 - 搭建单机模式zookeeper+kafka（十四）

kafka zookeeper bash bash 指令 tcp/ip

导语：搭建单机模式的zookeeper+kafka，用来做开发测试环境，管理主题、分区、生产消费及主题数据的导入导出。

发哥说消息队列

2019-09-17

8480

CKafka系列学习文章 - 调用API接口管理主题（十三）

tcp/ip java 消息队列 CKafka 版 kafka

接口请求域名：ckafka.api.qcloud.com 本接口（CreateTopic）用于在消息队列 CKafka 实例下创建主题。

发哥说消息队列

2019-09-11

5970

CKafka系列学习文章 - 用java调用Ckafka实例相关接口（十二）

kafka 消息队列 CKafka 版 java

接口请求域名：ckafka.api.qcloud.com 本接口（ListInstance）用于在用户账户下获取消息队列 CKafka 实例列表。

发哥说消息队列

2019-09-11

1.2K0

CKafka系列学习文章 - 用java实现API调用（十一）

消息队列 CKafka 版

导语：上一章节我们了解了怎么手动拼接请求URL和用API2.0签名自动生成请求URL，来调用CKafka的接口，这一章将进入开发阶段，用java实现拼接请求URL，进行API调用。

发哥说消息队列

2019-09-06

6540

CKafka系列学习文章 - 手动拼接和自动拼接请求URL（十）

kafka 消息队列 CKafka 版 https 云 API

导语：我们来搭建开发环境调用消息队列 CKafka--手动拼接和自动拼接请求URL，来调用获取消费分组offset的接口

发哥说消息队列

2019-09-05

9900

点击加载更多

社区活动

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

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

Python精品学习库

代码在线跑，知识轻松学

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

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

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

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