maxwell数据抓取工具
maxwell是一款开源MySQL数据抓取工具，可以读取MySQL的binlog，然后转换成json并输出到kafka、redis等消息队列中。 bin/maxwell，用于增量抓取 bin/maxwell-boostrap， ......KafkaProducer的整体逻辑
KafkaProducer是用户向kafka servers发送消息的客户端。官网上对producer的记载如下： Kafka所有的节点都可以应答metadata的请求，这些metadata中包含了分区所对应 ......![]()
Storm整合Kafka Java API源码
1.Maven项目的pom.xml源码如下: <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schem ......我的 Kafka 旅程 - 基于账号密码的 SASL+PLAIN 认证授权 · 配置 · 创建账号 · 用户授权 · .NET接入
本文基于 Kafka 3.0+ 的 KRaft 模式来阐述 默认的 Kafka 不受认证约束，可不用账号就可以连接到服务，也就是默认的 PLAIN 方式，不需要认证；配置了 SASL 认证之后， ......CDC一键入湖：当 Apache Hudi DeltaStreamer 遇见 Serverless Spark
Apache Hudi的DeltaStreamer是一种以近实时方式摄取数据并写入Hudi表的工具类，它简化了流式数据入湖并存储为Hudi表的操作，自 0.10.0 版开始，Hudi又在DeltaStream ......![]()
Flink-读Kafka写Hive表
使用Flink读取Kafka数据并实时写入Hive表。 EMR环境：Hadoop 3.3.3, Hive 3.1.3, Flink 1.16.0 根据官网描述： https://nightlies.apache.org/flink/flink-docs- ......![]()
Kafka入门学习
什么是 Kafka Kafka 是由 Linkedin 公司开发的，它是一个分布式的，支持多分区、多副本，基于 Zookeeper 的分布式消息流平台，它同时也是一款开源的基于发布订阅模 ......![]()
docker-compose多服务器部署kafka集群
Kafka 是一个开源的分布式事件流平台，依赖Zookeeper或者KRaft，本文基于Zookeeper。 本文使用三个服务器来做集群搭建，IP如下： nodeName IP node1 10.10.21 ......谁在以太坊区块链上循环交易？TuGraph+Kafka的0元流图解决方案
都在说数据已经成为新时代的生产资料。 但随着大数据和人工智能等技术的发展，即便人们都知道数据的价值日益凸显，却无法凭借一己之力获取和分析如此大规模的数据。 ......![]()
↓ 按住下拉
V2AS = Way To Ask
V2AS 一个技术分享与创造的静土
手机扫一扫
移动阅读更方便
近15日热搜文章