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

chenchenchen

专栏作者
260
文章
824750
阅读量
28
订阅数
Kafka 基本原理
简介 Kafka架构 Kafka存储策略 Kafka删除策略 Kafka broker Kafka Design The Producer The Consumer 复制(Replication) 日志压缩(Log Compaction) Distribution Zookeeper协调控制 开发环境搭建 一些example 参考
chenchenchen
2022-05-07
1900
查看kafka消息消费情况
消息堆积是消费滞后(Lag)的一种表现形式,消息中间件服务端中所留存的消息与消费掉的消息之间的差值即为消息堆积量,也称之为消费滞后(Lag)量。 对于Kafka而言,消息被发送至Topic中,而Topic又分成了多个分区(Partition),每一个Partition都有一个预写式的日志文件,虽然Partition可以继续细分为若干个段文件(Segment),但是对于上层应用来说可以将Partition看成最小的存储单元(一个由多个Segment文件拼接的“巨型文件”)。 每个Partition都由一系列有序的、不可变的消息组成,这些消息被连续的追加到Partition中。我们来看下图,其就是Partition的一个真实写照:
chenchenchen
2022-05-07
2.1K0
Kafka分区与消费者的关系kafka分区和消费者线程的关系
kafka中的topic可以细分为不同的partition,一个topic可以将消息存放在不同的partition中。
chenchenchen
2022-03-09
3.9K0
中华石杉Java面试突击第一季笔记一(消息队列)
数据结构和算法,软素质,工程素养,履历背景,学历,带团队管理,技术广度、技术深度、项目经验、系统设计
chenchenchen
2022-03-09
6840
Kafka消费者接收数据异常,contentType标头始终附加到消息正文
使用Spring Cloud Stream 1.3.2.RELEASE向Kafka发布String消息。 当使用命令行Kafka使用者或Spring Kafka @KafkaListener使用消息时,contentType标头始终附加到消息正文
chenchenchen
2021-09-06
1K0
KafkaTemplate和SpringCloudStream混用导致stream发送消息出现序列化失败问题
服务启动时,会给cloud-stream 装载绑定中间件的配置,而spring cloud stream默认使用的序列化方式为ByteArraySerializer,这就导致stream 在发送数据时使用l了服务装载StringSerializer序列化方式,从而导致了java.lang.ClassCastException: [B > cannot be cast to java.lang.String的问题出现。
chenchenchen
2021-09-06
2.1K0
综合对比 Kafka、RabbitMQ、RocketMQ、ActiveMQ 四个分布式消息队列
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
chenchenchen
2019-11-12
5880
消息队列MQ
版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
chenchenchen
2019-10-22
1.7K0
RabbitMQ和Kafka对比
开源社区有好多优秀的队列中间件,比如RabbitMQ和Kafka,每个队列都貌似有其特性,在进行工程选择时,往往眼花缭乱,不知所措。对于RabbitMQ和Kafka,到底应该选哪个?
chenchenchen
2019-10-22
1K0
Kafka的安装与使用
点对点消息系统:生产者发送一条消息到queue,一个queue可以有很多消费者,但是一个消息只能被一个消费者接受,当没有消费者可用时,这个消息会被保存直到有 一个可用的消费者,所以Queue实现了一个可靠的负载均衡。
chenchenchen
2019-09-03
5780
Kafka的生成者、消费者、broker的基本概念
kafka是一款基于发布与订阅的消息系统。它一般被称为“分布式提交日志”或者“分布式流平台”。文件系统或者数据库提交日志用来提供所有事物的持久化记录,通过重建这些日志可以重建系统的状态。同样地,kafka的数据是按照一定顺序持久化保存的,可以按需读取。
chenchenchen
2019-09-03
4.8K0
在Windows安装运行Kafka
http://www.oracle.com/technetwork/java/javase/downloads/jdk8-downloads-2133151.html
chenchenchen
2019-09-02
5.1K0
没有更多了
社区活动
腾讯技术创作狂欢月
“码”上创作 21 天,分 10000 元奖品池!
Python精品学习库
代码在线跑,知识轻松学
博客搬家 | 分享价值百万资源包
自行/邀约他人一键搬运博客,速成社区影响力并领取好礼
技术创作特训营·精选知识专栏
往期视频·千货材料·成员作品 最新动态
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档