1单独运行两个流报错数据到es 没问题
2为了确保数据没收到
2.1kafka生产者我循环每30毫秒发一条
2.2 另外开一个消费者 看到了数据
3代码如下
3.1 sink的sql
3.2 创建es sink表
3.3 kafka流表
a表
b表
3.4 代码运行无错误
3.5 es sink结果
请问:我哪写的有问题?
1单独运行两个流报错数据到es 没问题
2为了确保数据没收到
2.1kafka生产者我循环每30毫秒发一条
2.2 另外开一个消费者 看到了数据
3代码如下
3.1 sink的sql
3.2 创建es sink表
3.3 kafka流表
a表
b表
3.4 代码运行无错误
3.5 es sink结果
请问:我哪写的有问题?