安装librdkafka和使用C语言操作kafka的范例
一、安装librdkafka。二、开启kafka相关服务:启动zookeeper、启动Kafka、创建topic。三、c语言操作kafka的范例:消费者、生产者、生产者和消费者的交互。
flink与kafka结合示例
flink作为实时流处理平台,可以与kafka很好地结合。 因为flink流处理的特点,需要source和sink作为流处理的源头和终端。与kafka的结合,可以让flink作为生产者,不断的向kafka消息队列中产生消息。这个作为今天的第一个示例。对应下图的场景。 还有一种情况,让flink
FlinkCDC部署
FLINK-CDCFlinkCDC
kafka下载安装
kafka下载与Linux下安装配置一览
kafka的客户端限流(资源配额)
本文说明的是Kafka的客户端(生产者、消费者)与broker之前的限流,不是kafka的broker间topic副本同步的限流。
使用OGG实现Oracle到kafka数据同步(详细版本)
使用OGG实现Oracle到kafka数据同步
Maxwell的简介与使用
一、简介Maxwell 是由美国Zendesk公司开源,用Java编写的MySQL变更数据抓取软件。它会实时监控Mysql数据库的数据变更操作(包括insert、update、delete),并将变更数据以 JSON 格式发送给 Kafka、Kinesi等流数据处理平台。Maxwell的工作原理是实
docker创建带SASL认证的kafka
docker创建带SASL认证的kafka
windows环境下搭建kafka
windows环境下搭建kafka
【kafka】Timed out waiting for a node assignment
在做flink任务的时候,报错 详细错误如下在SourceCoordinator中我们调用了start方法启动.启动方法主要做了2件事创建代码如下source.createEnumerator,这里创建仅仅是赋值没啥重要的2.启动Enumerator启动Enumerator方法中也是主要做了3件事
springboot 集成webSocket
springboot 集成webSocket
kafka集群搭建与prometheus监控配置
prometheus监控kafka集群,kafka集群安装,kafka集群两种方式:zookeeper和KRaft
详解Kafka 3.0 稳定版新特性
Kafka 2.8.0正式发布了KRaft的先行版,并且支持在KRaft模式下的部署和运行。KRaft模式下的Kafka可以完全脱离Zookeeper运行,使用自己的基于Raft算法实现的quorum来保证分布式Metadata的一致
Kafka可视化利器 KafkaTool 发送kafka消息
利用KafkaTool 发送kafka消息
实时数据仓库
实时仓库知识点
kafka消费者组
消费者组是kafka提供的可扩展且具有容错性的消费者机制。既然是一个组,那么组内必然可以有多个消费者或消费者实例,它们共享一个公共的ID,即group ID。
Flink 之 Kafka连接器
Flink 之 Kafka连接器
kafka 常用命令行操作(查看主题,生产数据,消费数据)
一 topic相关操作1.1 查看 主题命令参数[root@localhost kafka_2.12-2.1.0]# bin/kafka-topics.shCreate, delete, describe, or change a topic.Option Desc
kafka操作指南
kafka相关操作
kafka的存储和容错机制
kafka的存储策略和容错机制