1.poll()方法里传的是时间(ms)，而不是Kafka返回的记录条数。
2.Kafka轮询一次就相当于拉取(poll)一定时间段broker中可消费的数据， 在这个指定时间段里拉取，时间到了就立刻返回数据。
3.例如poll(5000)： 如果拉到数据的话 会立即放回；如果拉不到数据的话，这个是最长的等待时间；
比如5s，如果一直没有数据的话，每5s拉一次返回一次，有数据就立即返回再拉
原文：https://blog.csdn.net/weixin_41227335/article/details/86521894
版权声明：本文为qq_55548053原创文章，遵循CC 4.0 BY-SA版权协议，转载请附上原文出处链接和本声明。