flink kafka consumer部分消息未消费

classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

flink kafka consumer部分消息未消费

zenglong chen
一个test topic,手动往里面添加消息,flink消费后print输出,发现会漏掉部分添加的消息,问题可能出在哪里?前辈有人遇到过类似问题吗?
Reply | Threaded
Open this post in threaded view
|

Re: flink kafka consumer部分消息未消费

Dian Fu
web界面上可以看到每个节点收到了多少条数据,发送了多少条数据,看看在哪里少了。

> 在 2019年9月27日,下午7:44,zenglong chen <[hidden email]> 写道:
>
> 一个test topic,手动往里面添加消息,flink消费后print输出,发现会漏掉部分添加的消息,问题可能出在哪里?前辈有人遇到过类似问题吗?