kafka通过zk选举leader以及在消费组变化时进行负载均衡生产者使用push（推）模式将消息发布到broker消费者用pill（拉）模式从broker订阅发布消息

原因：jar冲突core用的是1.7<!--flink-core依赖--><dependency><groupId>org.apache.flink</groupId><artifactId>flink-scala_2.12</artifactId><version>1.7.0</

ck介绍

目录说明背景步骤首先选择自定义直接下一步选择centos64位选择一个存放路径和虚拟机的名称，默认的也是可以的设置cpu设置内存设置网络类型，建议是桥接网络哟一路默认到创建磁盘我的是1T，比较较大，分的比较多完成添加iso启动虚拟机，一路enter选择语言是english就可以，中文也行，看个人，时区选择上海手动分区，选择I will configure partioning 选项，然后点击don

KafkaManager 雅虎出品，可管理多个Kafka集群，是目前功能最全的管理工具。但是注意，当你的Topic太多，监控数据会占用你大量的带宽，造成你的机器负载增高。其监控功能偏弱，不满足需求。KafkaOffsetMonitor 程序一个jar包的形式运行，部署较为方便。只有监控功能，使用起来也较为安全。Kafka Web Console 监控功能较为全面，可以预览消息，监控Offset、L

从指定offset消费kafka数据java从指定offset消费kafka数据代码import com.google.common.collect.Maps;import lombok.extern.slf4j.Slf4j;import org.apache.kafka.clients.consumer.ConsumerRecord;import org.apache.kafka.clients

Kafka Monitor是kafka的监控工具，安装简单，页面简单，主要是用来监控消费者和offset，对kafka集群的支持较少上传jar包mkdir kafka-offset-monitorcp KafkaOffsetMonitor-assembly-0.4.6-SNAPSHOT.jar /usr/local/bigdata/kafka-offset-monitor/cd kafka-off

在这里插入代码片

doris简介到特性到一些简单的进阶用法

flink-table-planner：planner 计划器，是 table API 最主要的部分，提供了运行时环境和生成程序执行计划的 planner；flink-table-api-scala-bridge：bridge 桥接器，主要负责 table API 和 DataStream/DataSet API的连接支持，按照语言分 java 和 scala。这里的两个依赖，是 IDE 环境下运