Flink大数据实时计算系列-Flink读取kafka实现并行RichParallelSource
目录
- Flink实现并行的SourceFunction
-
- RichParallelSourceFunction
- Flink案例实战
- Flink 自定义schema示例代码
- kafka 本地安装
-
- scala 安装
- kafka 安装
-
- 配置Kafka自带的zookeeper
- 配置server.properties
- 启动kafka自带的zk
- 启动kafka
- kafka操作
-
- 新建主题
- 展示topic列表
- 描述 topic
- 生产与消费
