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

开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

发哥说消息队列

专栏成员

29

文章

36341

阅读量

72

订阅数

解密kafka为啥总是在重平衡

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

2024-08-01

1560

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

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

2024-07-04

860

kafka常见报错集合-四

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

2024-03-17

6970

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

4790

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

2460

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

4650

线上Kafka集群部署规划建议

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

2024-02-19

1260

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

kafka zookeeper bash bash 指令 tcp/ip

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

发哥说消息队列

2019-09-17

8420

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

tcp/ip java 消息队列 CKafka 版 kafka

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

发哥说消息队列

2019-09-11

5890

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

kafka 消息队列 CKafka 版 java

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

发哥说消息队列

2019-09-11

1.2K0

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

kafka 消息队列 CKafka 版 https 云 API

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

发哥说消息队列

2019-09-05

9820

CKafka系列学习文章 - Flume接入Ckafka（九）

kafka apache 消息队列 CKafka 版 tcp/ip 日志数据

导语：当你的业务系统既要对实时数据进行处理也要对离线数据进行分析时，这时候可以来了解一下Flume。

发哥说消息队列

2019-09-05

7240

CKafka系列学习文章 - Logstash接入CKafka (八)

kafka Elasticsearch Service 消息队列 CKafka 版

导语：前面一章讲了Filebeat对接Ckafka，通常的场景是各种beats将数据存到CKafka，然后Logstash将从Ckafka中消息消息进行过滤，再经过Ckafka存入到Elasticsearch 。

发哥说消息队列

2019-09-02

7410

CKafka系列学习文章 - Filebeat对接CKafka（七）

kafka 消息队列 CKafka 版

导语：用CKafka作一个消息缓冲，用Filebeat收集日志，然后将日志传到Ckafka中。

发哥说消息队列

2019-08-30

1.3K0

CKafka系列学习文章 - CKafka场景案例（五）

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

导语：当我们的公司在不断发展时，业务也是遍布全国或者已经国际化了，公司内部的各种系统也是越来越多，还要对接其它公司的系统，来实现公司业务的正常运转。这时我们通常希望各个系统是独立的，在升级版本时不会影响其它系统；或收集公司业务服务器集群的日志做日志分析。

发哥说消息队列

2019-08-27

6490

CKafka系列学习文章 - 创建一个CKafka实例（三）

jdk kafka sas 消息队列 CKafka 版消息队列 CMQ 版

导语：前面我们介绍了消息队列也比较了各种消息队列，接下来创建一个CKafka来测试一下。

发哥说消息队列

2019-08-23

1.2K0

CKafka系列学习文章 - 对比RabbitMQ、RocketMQ、TDMQ-CMQ、kafka和Ckafka（二）

消息队列 CMQ 版 kafka 消息队列 CKafka 版运维

导语：上一章我们聊到了：什么是消息队列，为什么要用消息队列，有那些消息队列？下来我们聊聊什么样的消息队列适合我们公司。

发哥说消息队列

2019-08-22

4.7K0

没有更多了

社区活动

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

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

Python精品学习库

代码在线跑，知识轻松学

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

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

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

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