没有做过这样的逻辑, 但应该是可行的, 很好奇flink达到性能瓶颈的原因是啥?
其实kakfa的stream,底层也是基于消费者->生产者
的...
理论上不会有太大改善,你只能通过分区数来提供并发处理的能力,提升效率。
原先java程序使用的简单的消费者->生产者模式
可能是我没表达清楚,因为之前使用的方案flink性能达到瓶颈就采用了filebeat->kafka->java程序过滤->kafka(新topic)->flink的模式,我考虑的是中间java程序这里换成kafka-stream会不会提高点效率,您看这可行吗?