kafka
-
Kafka 分级存储在腾讯云的实践与演进
导语 腾讯云消息队列 Kafka 内核负责人鲁仕林为大家带来了《Kafka 分级存储在腾讯云的实践与演进》的精彩分享,从 Kafka 架构遇到的问题与挑战、Kafka 弹性架构方案…
-
Zookeeper+Kafka集群
1 Zookeeper 1.1 Zookeeper概述 Zookeeper是一个开源的分布式的,为分布式框架提供协调服务的Apache项目。 分布式系统管理框架,主要用来解决分布式…
-
kafka的原理及集群部署详解
消息队列分类 点对点 组成:消息队列(Queue)、发送者(Sender)、接收者(Receiver) 特点:一个生产者生产的消息只能被一个接受者接收,消息一旦被消费,消息就不在消…
-
kafka+Kraft模式集群+安全认证
Kraft模式安全认证 前章内容聊到了Kafka的Kraft集群的配置及使用。本篇再来说说kafka的安全认证方面的配置,。 Kafka提供了多种方式来进行安全认证,包括身份认证、…
-
Kafka收发消息核心参数
Kafka收发消息核心参数 1.基础的客户端 利用maven简单尝试一下Kafka的代码 1.引入Maven依赖 org.apache.kafka kafka_2.13 3.4.0…
-
【flink番外篇】9、Flink Table API 支持的操作示例(14)- 时态表的join(java版本)
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点,并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
Apache Kafka JNDI注入注入漏洞(CVE-2023-25194)
基于Vulhub搭建的环境 一、漏洞概述 Apache Kafka是一个开源分布式消息队列,Kafka clients是相对应的Java客户端。 在版本3.3.2及以前,Apach…
-
实现 Kafka 分区内消费者多线程顺序消费
在1个topic中,有3个partition,那么如何保证数据的顺序消费? 生产者在写的时候,可以指定一个 key,被分发到同一个 partition 中去,而且这个 partit…
-
39、Flink 的CDC 格式:maxwell部署以及示例
Flink 系列文章 一、Flink 专栏 Flink 专栏系统介绍某一知识点,并辅以具体的示例进行说明。 1、Flink 部署系列 本部分介绍Flink的部署、配置相关基础内容。…
-
Kafka调试
Kafka安装配置 安装 kafka官网https://kafka.apache.org/downloads wget https://archive.apache.org/dis…
-
Kafka、RocketMQ、RabbitMQ消息丢失可能存在的地方,以及解决方案
这里主要对比:Kafka、RocketMQ、RabbitMQ 介绍一下消息生产、存储、消费三者的架构形式。 消息丢失可能存在的场景: 情况 1: 生产者发送给MQ的过程消息丢失 在…
-
JAVA面试题分享一百六十三:Kafka如何实现延时推送?
目录 一、延时队列定义 二、技术实现方案 1. Redis 2. Kafka 3. RabbitMQ 4. RocketMQ 三、Kafka延时队列背景 四、Kafka延时队列实现…
-
【分布式技术】消息队列Kafka
目录 一、Kafka概述 二、消息队列Kafka的好处 三、消息队列Kafka的两种模式 四、Kafka 1、Kafka 定义 2、Kafka 简介 3、Kafka 的特性 五、K…
-
TDengine Kafka Connector将 Kafka 中指定 topic 的数据(批量或实时)同步到 TDengine
教程放在这里:TDengine Java Connector,官方文档已经写的很清晰了,不再赘述。 这里记录一下踩坑: 1.报错 java.lang.UnsatisfiedLink…
-
restful web服务实现mysql+debezium+kafka对mysql数据库的业务实时变更数据监控
要求任务 请写java程序,创建restful web服务,示范利用RestController、Debezium和KafkaListener通过binlog日志监控并获得mysq…
