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

发哥说消息队列

专栏成员
29
文章
36294
阅读量
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
6880
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
4730
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
2440
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
4600
线上Kafka集群部署规划建议
现在我们就来看看在生产环境中的 Kafka 集群规划该怎么做。既然是集群,那必然就要有多个 Kafka 节点机器,因为只有单台机器构成的 Kafka 伪集群只能用于日常测试之用,根本无法满足实际的线上生产需求。而真正的线上环境需要仔细地考量各种因素,结合自身的业务需求而制定。
沐榕樰
2024-02-19
1250
CKafka系列学习文章 - 搭建单机模式zookeeper+kafka(十四)
导语:搭建单机模式的zookeeper+kafka,用来做开发测试环境,管理主题、分区、生产消费及主题数据的导入导出。
发哥说消息队列
2019-09-17
8420
CKafka系列学习文章 - 调用API接口管理主题(十三)
接口请求域名:ckafka.api.qcloud.com 本接口(CreateTopic)用于在消息队列 CKafka 实例下创建主题。
发哥说消息队列
2019-09-11
5860
CKafka系列学习文章 - 用java调用Ckafka实例相关接口(十二)
接口请求域名:ckafka.api.qcloud.com 本接口(ListInstance)用于在用户账户下获取消息队列 CKafka 实例列表。
发哥说消息队列
2019-09-11
1.2K0
CKafka系列学习文章 - 手动拼接和自动拼接请求URL(十)
导语:我们来搭建开发环境调用消息队列 CKafka--手动拼接和自动拼接请求URL,来调用获取消费分组offset的接口
发哥说消息队列
2019-09-05
9820
CKafka系列学习文章 - Flume接入Ckafka(九)
导语:当你的业务系统既要对实时数据进行处理也要对离线数据进行分析时,这时候可以来了解一下Flume。
发哥说消息队列
2019-09-05
7210
CKafka系列学习文章 - Logstash接入CKafka (八)
导语:前面一章讲了Filebeat对接Ckafka,通常的场景是各种beats将数据存到CKafka,然后Logstash将从Ckafka中消息消息进行过滤,再经过Ckafka存入到Elasticsearch 。
发哥说消息队列
2019-09-02
7410
CKafka系列学习文章 - Filebeat对接CKafka(七)
导语:用CKafka作一个消息缓冲,用Filebeat收集日志,然后将日志传到Ckafka中。
发哥说消息队列
2019-08-30
1.3K0
CKafka系列学习文章 - CKafka场景案例(五)
导语:当我们的公司在不断发展时,业务也是遍布全国或者已经国际化了,公司内部的各种系统也是越来越多,还要对接其它公司的系统,来实现公司业务的正常运转。这时我们通常希望各个系统是独立的,在升级版本时不会影响其它系统;或收集公司业务服务器集群的日志做日志分析。
发哥说消息队列
2019-08-27
6490
CKafka系列学习文章 - 创建一个CKafka实例(三)
导语:前面我们介绍了消息队列也比较了各种消息队列,接下来创建一个CKafka来测试一下。
发哥说消息队列
2019-08-23
1.2K0
CKafka系列学习文章 - 对比RabbitMQ、RocketMQ、TDMQ-CMQ、kafka和Ckafka(二)
导语:上一章我们聊到了:什么是消息队列,为什么要用消息队列,有那些消息队列?下来我们聊聊什么样的消息队列适合我们公司。
发哥说消息队列
2019-08-22
4.7K0
没有更多了
社区活动
【纪录片】中国数据库前世今生
穿越半个世纪,探寻中国数据库50年的发展历程
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档