kafka消费者的问题

我们用的卡夫卡消费者其实就是起定时任务,比如每秒起一个任务,然后在任务中拉取一条消息消费。那么除了这种方式外还有其他的创建消费者的方式吗?

阅读 2.3k
2 个回答

你没说什么编程语言。

如果是 PHP 这种脚本语言,由于没有进程常驻,所以只能用定时任务(现在有了 swoole 这种扩展,可以做到进程常驻了)。

如果是 Java / C# / Go 这类的,其实就写个死循环不断 poll 就好了(poll 的等待时间可以设长一点,以免频繁建立链接的开销问题)。

while循环,然后每次sleep一秒,最后设置为守护进程,放在服务器上运行。

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进