kafka通过命令行删除指定topic下所有records

由于在windows环境下,在kafka官网下载下来。

kafka3.4.0版本升级--helm部署

使用helm将kafka升级至3.4.0版本,修复漏洞。

k8s 部署zookeeper-kafka,nfs作为存储

k8s上安装配置zk与kafka

SpringBoot项目集成kafka及常规配置

使用 spring-kafka 的api,在springboot项目中集成kafka能力,封装配置。

kafka topic和topic权限操作

topic创建及权限配置

Kafka的ack机制

Kafka的ACK机制,指的是producer的消息发送确认机制,这直接影响到Kafka集群的吞吐量和消息可靠性。而吞吐量和可靠性就像硬币的两面,两者不可兼得,只能平衡。Kafka的ACK机制是针对producer的。保证消息的吞吐量就是producer只负责发数据,不需要得知消息是否被集群接收,这

Kafka安装与配置

1.下载Kafka2.13-3.1.0最新版为kafka_2.13-3.1.0.tgz下载Zookeper最新版为zookeeper-3.8.02.单机安装zookeperKafka依赖于zookeeper,官方承诺将来会移除.解压文件:tar zxvf apache-zookeeper-3.8.0

【项目实战】Kafka 生产者写入分区的策略

生产者写入分区的策略主要有以下几种:1. **轮询分区策略**:生产者可以使用轮询策略将消息依次写入每个分区,实现负载均衡。在每次发送消息时,生产者会按照轮询的方式选择下一个可用的分区,并将消息写入该分区。这样可以确保消息均匀地分布在各个分区中。 2. **随机分区策略**:Kafka生产者随机的将

用好 kafka,你不得不知的那些工具

工欲善其事,必先利其器。本文主要分享一下消息中间件 kafka 安装部署的过程,以及我平时在工作中针对 kafka 用的一些客户端工具和监控工具。本文分享了平时我在工作使用 kafka 以及 zookeeper 常用的一些工具,同时分享了 kafka 集群的部署,值得一提的是 kafka 部署配置

Kafka bootstrap.servers

Kafka bootstrap.servers

kafka 报错 - Cannot assign requested address

因为如果是 kafka 集群,你可以选择只给客户端配置一个 kafka 节点的地址(这样是不推荐的),但是客户端必须要访问集群中的每一个节点,所以必须通过这个节点获得集群中每一个节点的访问地址。而且有的环境可能被配置成这些 kafka 宿主机是没有外网访问权限的,即虽然他可以访问自己的外网ip,但是

filebeat->kafka>elk日志采集

/可以防止日志爆盘,将所有标准输出及标准错误输出到/dev/null空设备,即没有任何输出信息。//启动logstash --path.data 指定数据存储路径。查看消费者consumer的group列表。查看kafka中指定topic的详情。查看指定的group。

kafka使用详解、最佳实践和问题排查

kafka常用概念、与RabbitMQ对比、最佳实践、工具推荐、Spring快速使用和问题排查

Docker 安装 Kafka

docker在3.0以前依赖于zookeeper,在安装kafka之前需要先安装zookeeper集群。关于 zookeeper 集群的安装本文不做介绍,大家可以自行百度。

Kafka消息积压的原因和处理的方法

kafka消息积压

Kafka安装、配置和使用

kafka的学习之路

Kafka详解

kafka是一款分布式、支持分区的、多副本,基于zookeeper协调的分布式消息系统。最大的特性就是可以实时处理大量数据来满足需求。Kafka 支持自定义规则,一个 Producer 可以使用自己的分区指定规则。

kafka 安装 以及 Kraft 模式、安全认证配置

kafka部署、Kafka- Kraft 模式部署、安全认证开启

kafka常用命令汇总(亲测自用)

kafka常用命令

Kafka中产生数据积压的原因以及解决方案

Kafka中产生数据积压的原因以及解决方案。

登录可以使用的更多功能哦! 登录
作者榜
...
资讯小助手

资讯同步

...
内容小助手

文章同步

...
Deephub

公众号:deephub-imba

...
奕凯

公众号:奕凯的技术栈