1.poll()方法里传的是时间(ms)，而不是Kafka返回的记录条数。

2.Kafka轮询一次就相当于拉取(poll)一定时间段broker中可消费的数据， 在这个指定时间段里拉取，时间到了就立刻返回数据。

3.例如poll(5000)： 如果拉到数据的话 会立即放回；如果拉不到数据的话，这个是最长的等待时间；
比如5s，如果一直没有数据的话，每5s拉一次返回一次，有数据就立即返回再拉

原文：https://blog.csdn.net/weixin_41227335/article/details/86521894