kafka
-
图解KafkaConsumer SyncGroupRequest请求流程
作者:石臻臻, CSDN博客之星Top5、Kafka Contributor 、nacos Contributor、华为云 MVP ,腾讯云TVP, 滴滴Kafka技术专家 、 K…
-
kafka 消费者相关参数
1.enable.auto.commit ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG = “enable.auto.commit”; 是否自动…
-
阿里 P7 三面凉凉,kafka Borker 日志持久化没答上来
👏作者简介:大家好,我是爱敲代码的小黄,阿里巴巴淘天Java开发工程师,CSDN博客专家 📕系列专栏:Spring源码、Netty源码、Kafka源…
-
Prometheus监控Kafka(三种方法JMX/Kafka
背景 一句话说明需求: 公司需要监控kafka消息队列的消费情况,强调需查看当前Topic中的message的数量。 一句话说明解决: 像Kafka这样的Java进程可以先通过JM…
-
14-部署Kafkasource和KafkaChannel
部署KafkaSource KafkaSource负责将Kafka中的消息记录转为CloudEvents 仅在需要从Kafka中加载消息并提供给Knative Eventing上的…
-
KAFKA (2.12-2.2.1)常用命令和kafka tool 工具使用
KAFKA (2.12-2.2.1)常用命令 查看topic 查看所有topic列表 #集群地址以逗号分隔如 ip1:9092, ip2:9092, ip3:9092 ./kafk…
-
Kafka消费者异常问题解析与解决方案
Kafka是一个分布式流处理平台,它提供了高吞吐量、容错性和可扩展性的特性。然而,有时候在使用Kafka消费者时,可能会遇到一些异常情况。本文将详细讨论几种常见的Kafka消费异常…
-
14、Kafka 请求是怎么被处理的
Kafka 请求是怎么被处理的 1、处理请求的 2 种常见方案 1.1、顺序处理请求 1.2、每个请求使用单独线程处理 2、Kafka 是如何处理请求的? 3、控制类请求和数据类请…
-
Kafka-配置Kerberos安全认证(JDK8、JDK11)
一、相关配置 1、JAAS 配置文件 KafkaClient { com.sun.security.auth.module.Krb5LoginModule required use…
-
Apache Kafka 漏洞 【CVE-2023-25194】说明及解决建议
目录 漏洞发布时间: 影响版本: 漏洞说明: 漏洞建议: 官方描述: 升级 Apache Kafka 各版本重大更新参考 漏洞发布时间: 2023-02-07 影响版本: Apac…
-
【Kafka】Windows下安装Kafka(图文记录详细步骤)
【Kafka】Windows下安装Kafka Kafka简介 一、Kafka安装前提 安装Kafka之前,需要安装JDK、Zookeeper、Scala。 1.1、JDK安装(ve…
-
Kafka系列:查看Topic列表、消息消费情况、模拟生产者消费者
1、查看kafka队列中topic信息 1.1、查看所有topic ./kafka-topics.sh –zookeeper 10.128.106.52:2181 –list …
-
Kafka(一)使用Docker Compose安装单机Kafka以及Kafka UI
文章目录 Kafka中涉及到的术语 Kafka镜像选择 Kafka UI镜像选择 Docker Compose文件 Kafka配置项说明 KRaft vs Zookeeper 和K…
-
Kafka存取原理与实现分析,打破面试难关
系列文章目录 上手第一关,手把手教你安装kafka与可视化工具kafka-eagle Kafka是什么,以及如何使用SpringBoot对接Kafka 架构必备能力——kafka的…
-
kafka的auto.offset.reset详解与测试
取值及定义# auto.offset.reset有以下三个可选值:latest (默认) earliest none 三者均有共同定义: 对于同一个消费者组,若已有提交的offse…
