写文章
- @Analyze_ing
简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
DolphinScheduler启动flink任务， 用Flink消费Kafka数据（linux）
1、修改kafka配置：找到kafka安装包下的config文件夹，修改config下的server.properties文件，修改listeners是为了外面的主机能够访问到虚拟机的kafka，还有把advertised.listeners改成虚拟机地址，写样例的时候能连上虚拟机的kafka地址，不然默认连localhost。flink的启动日志，我这里写了消费两条消息后取消flink任务，因为
微服务间的远程调用报错
微服务间的远程调用报错
项目报错com.ecwid.consul.transport.TnansportException Create breakpoint : java.net,SocketTimeoutExceptio
项目报错com.ecwid.consul.transport.TnansportException Create breakpoint : java.net,SocketTimeoutException
到底了