kafka
-
【Kafka】开发实战和Springboot集成kafka
目录 消息的发送与接收 生产者 消费者 SpringBoot 集成kafka 服务端参数配置 消息的发送与接收 生产者 生产者主要的对象有： KafkaProducer ， Pro…
-
【万字长文】带你搞懂Kafka中的所有知识点
目录 概述 主题和分区 日志 消息压缩 日志分段条件 日志清理 多副本 写入流程 生产者 必要参数配置 消息的发送 流程 元数据更新 重要的生产者参数 消费者 消费者组 分区分配策…
-
【Kafka集群】Kafka针对用户做ACL权限控制
在 Kafka 3.3.1 中，可以使用 ACL（Access Control List）控制用户对 topic 的访问权限。以下是一些基本示例： 创建一个名为 my-topic …
-
Kafka3.0源码学习
文章目录 一、生产者源码 1、初始化 2、发送数据到缓冲区 2.1 发送总体流程 2.2 分区选择 2.3 发送消息大小校验 2.4 内存池 3、sender 线程发送数据 二、消…
-
kafka @KafkaListener 动态接收topic
@KafkaListener 里边的 topics 必须是常量，不可以是变量 但是某些业务场景 kafka定义的topic会不同这时候就需要传入变量才可以实现 具体实现方式如下： …
-
kafka详细解释
什么是kafka Kafka是一个开源的分布式流处理平台，最早由LinkedIn开发，并于2011年成为Apache软件基金会的顶级项目。Kafka使用高效、可扩展和持久化…
-
CVE-2023-34040 Kafka 反序列化RCE
漏洞描述 Spring Kafka 是 Spring Framework 生态系统中的一个模块，用于简化在 Spring 应用程序中集成 Apache Kafka 的过程，记录 (…
-
32个Java面试必考点-09(上)消息队列Kafka架构与原理
本课时主要讲解消息队列与数据库相关的知识，重点讲解三部分知识点： 1.Kafka 的架构与消息交互流程； 2.数据库事务的 4 大特性和分类； 3.MySQL 相关的内容，比如索引…
-
消息中间件（MQ）对比：RabbitMQ、Kafka、ActiveMQ 和 RocketMQ
前言 在构建分布式系统时，选择适合的消息中间件是至关重要的决策。RabbitMQ、Kafka、ActiveMQ 和 RocketMQ 是当前流行的消息中间件之一，它们各自具有独特的…
-
kafka入门(五)：kafka生产者发送消息
构建消息 构建消息，即创建 ProduceRecord 对象。 (1) kafka发送消息，最常见的构造方法是： public ProducerRecord(String topi…
-
kerberos+kafka（2.13）认证（单节点ubuntu）
一：搭建kerberos。 1. 运行安装命令 apt-get install krb5-admin-server krb5-kdc krb5-user krb5-config 2…
-
【kafka实战】03 SpringBoot使用kafka生产者和消费者示例
本节主要介绍用SpringBoot进行开发时，使用kafka进行生产和消费 一、引入依赖 org.springframework.kafka spring-kafka org.sp…
-
分布式 – 消息队列Kafka：Kafka生产者发送消息的方式
文章目录 1. Kafka 生产者 2. kafaka 命令行操作 3. kafka 生产者发送消息流程 4. Kafka 生产者的创建 5. Kafka 生产者发送消息 1. 发…
-
FlinkSQL对接MySQL CDC写入数据到Hive
环境搭配 想要针对公司集群环境学习一下Flink对接MySQL CDC写入Hive的方法，并对过程进行记录。公司环境为CDH 6.3.2搭建的集群，MySQL使用的是AWS RDS…
-
kafka可视化工具-kafkamap
kafka可视化工具-kafkamap 安装openjdk11 kafka-map 依赖openjdk11 下载链接 https://learn.microsoft.com/zh-…
