Re: 一个FlinkJob消费多个kafka topic消息问题

[zhisheng]

那可以一个 kafka 消息一个 sink

史 正超 <shizhengc...@outlook.com> 于2019年8月29日周四 下午4:11写道：

> 1.平常工作中经常会有同一个统计表中会包含多个不同的统计指标,比如：post_count, send_count
> 2.然而这些指标来自不同的kafka 消息体
> 3.有没有在不用uninon all的情况下，向sink 表中写入各自topic的数据，因为union all有很多0值来填充
>
>