包含标签:kafka 的文章
-
如何查看kafka的topic的消费者组有没有积压
Kafka 自带的命令行工具 kafka-consumer-groups.sh 来查看消费者组的消费情况,包括是否有积压。 具体步骤如下: 打开命令行终端,进入 Kafka 安装目录下的 b…… -
Apache Kafka – 高性能原因探究
文章目录 概述 图解 概述 Kafka 的高性能主要依赖于以下几个关键因素: 分布式架构:Kafka 采用分布式集群架构,可以水平扩展到上万个节点,支持每秒…… -
Apache Kafka – 重识消费者
文章目录 概述 Kafka消费者的工作原理 Kafka消费者的配置 Kafka消费者的实现 高级API 低级API 导图 总结 概述 Kafka是一个分布式的消…… -
Kafka增加安全验证安全认证,SASL认证,并通过spring boot-Java客户端连接配置
出发点 公司Kafka一直没做安全验证,由于是诱捕程序故需要面向外网连接,需要增加Kafka连接验证,保证Kafka不被非法连接,故开始研究Kafka安全验证 使用Kafk…… -
Redis消息队列
消息队列(Message Queue),字面意思就是存放消息的队列。最简单的消息队列模型包括3个角色: 消息队列:存储和管理消息,也被称为消息代理(Message Broker…… -
兼容 信创鲲鹏/M1 arm64架构的kafka镜像
当前热度比较高的kafka镜像是wurstmeister/kafka,在dockerhub上有很多的使用次数。我起初很开心最新版支持arm64架构,然后拉到本地用Mac M1跑也很完美 但…… -
Monitor 监控架构
Monitor 监控架构 采集器 Telegraf Exporters Grafana-Agent Categraf 时序库 OpenTSDB InfluxDB TDEngine M3DB VictoriaMetrics TimescaleDB 告警…… -
【Kafka】MM2同步Kafka集群时如何自定义复制策略(ReplicationPolicy)
文章目录 需求 准备工作 自定义复制策略 编译代码 需求 使用MM2同步集群数据,topic名称不能变,默认的复制策略为:DefaultReplicationPolicy,这个策略…… -
Kafka 动态配置
Kafka 动态配置 配置保存 配置 动态配置 : 修改参数后,无需重启 Broker 就能生效 Kafka 1.1 后的 Dynamic Update Mode 列 : read-only : 只有重启 Brok…… -
zookeeper和kafka安全机制:java.lang.ClassNotFoundException: kafka.security.auth.SimpleAclAuthorizer
1、找不到验证类文件 在给项目支撑时反馈到项目一直存在kafka的报错问题,看能不能解决一下,排查项目发现配置中开启了kafka的安全机制(这个我也看不太懂,……