这篇文章主要介绍“Kafka多线程Consumer的实例代码”，在日常操作中，相信很多人在Kafka多线程Consumer的实例代码问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Kafka多线程Consumer的实例代码”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！（旧版本：多分区多线程 新版本：一个线程管理多个socket连接）但新版本KafkaConsumer是双线程的，主线程负责：消息获取，rebalance，coordinator，位移提交等等，另一个是后台心跳线程。根据上边的各种配置，poll方法会找到offset，当获取了足够多的可用数据，或者等待时间超过了指定的超时时间，就会返回。java consumer不是线程安全的，同一个KafkaConsumer用在了多个线程中，将会报Kafka Consumer is not safe for multi-threaded assess异常。可以加一个同步锁进行保护。poll的超时参数，已经说过1000的话是超时设定，如果没有很多数据，也就等一秒，就返回了，比如定时5秒的将消息写入，就可以将超时参数设置为5000，达到效率最大化。如果没有定时任务呢，那就设置为 Lo开发云主机域名ng.MAX_VALUE 未获取足够多的数据就无限等待。这里要捕获一下WakeupException。到此，关于“Kafka多线程Consumer的实例代码”的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注开发云网站，小编会继续努力为大家带来更多实用的文章！
这篇文章主要介绍“Spark程序怎么实现”，在日常操作中，相信很多人在Spark程序怎么实现问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答”Spark程序怎么实现”的疑惑有所帮助！接下来，请跟着小编一起来学习吧！import or…
免责声明：本站发布的图片视频文字，以转载和分享为主，文章观点不代表本站立场，本站不承担相关法律责任；如果涉及侵权请联系邮箱：360163164@qq.com举报，并提供相关证据，经查实将立刻删除涉嫌侵权内容。
微信扫一扫 
