rabbitmq更换数据文件和日志文件的存放位置
原来的默认位置是/var下
需要将这些文件更换位置
1、先创建数据文件和日志文件存放位置的目录并给权限
mkdir -p /usr/local/rabbitmq/mnesia
mkdir -p /usr/local/rabbitmq/log
chmod -R 777 /usr/loca...
Spring Cloud Stream Binder 实现
Spring Cloud Stream Binder 实现
JMS 实现 ActiveMQ
1.增加Maven依赖
<!-- 整合 Sprig Boot Starter ActiveMQ -->
<!-- 间接依赖：
spring jms
...
Flink-Table-SQL系列之source
source作为Table&SQL API的数据源，同时也是程序的入口。当前Flink的Table&SQL API整体而言支持三种source：Table source、DataSet以及DataStream，它们都通过特定的API注册到Table环境对象。
