zookeeper - Java项目,kafka consume相关

查看:188
本文介绍了zookeeper - Java项目,kafka consume相关的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!

问题描述

问 题

1.Kafka的消费者什么时候开启?

  • 是随着项目的启动就开启消费者吗还是通过监听有新的消息才开启消费者?


回答问题的不要看ID,本人要脸

解决方案

你不开启你从何途径监听有新的消息?如果其他途径也可以,为什么不统一使用 Consumer 呢?结构也简单,程序也可靠,也方便分布到不同服务器。

当然了,还得看你业务了,如果你 8 百年也没来一条消息,来一条处理几天,那是得考虑下。此种情况得到通知后可以 poll(0)

这篇关于zookeeper - Java项目,kafka consume相关的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!

查看全文
登录 关闭
扫码关注1秒登录
发送“验证码”获取 | 15天全站免登陆