- @popping_w
简介
该用户还未填写简介
擅长的技术栈
可提供的服务
暂无可提供的服务
启动kafka失败思路：1、先去查看kafka日志cd /opt/module/kafka/logs（每个人的路径不同，自己找到自己的kafka路径）查看最后500行日志信息输入指令：tail -500 server.log看到：ERROR Fatal error during KafkaServer startup.Configured zookeeper.connect may be wron
Flink—kafkaSink1.开发流程特别说明：Flink内置了一些Sink, 除此之外的Sink需要用户自定义!2.环境介绍hadoop+zookeeper+kafka添加Kafka Connector依赖<dependency><groupId>org.apache.flink</groupId><artifactId>flink-conne
启动kafka失败思路：1、先去查看kafka日志cd /opt/module/kafka/logs（每个人的路径不同，自己找到自己的kafka路径）查看最后500行日志信息输入指令：tail -500 server.log看到：ERROR Fatal error during KafkaServer startup.Configured zookeeper.connect may be wron
Flink从Kafka读取数据1、环境搭建，hadoop集群、zookeeper、kafka2、IDEA程序编写+配置依赖在IDEA中添加kafka配置依赖：Apache Flink 附带了一个通用的 Kafka 连接器，它试图跟踪最新版本的 Kafka 客户端。它使用的客户端版本可能会在 Flink 版本之间发生变化。现代 Kafka 客户端向后兼容代理版本 0.10.0 或更高版本。关于Kaf