关于Kafka,你需要知道的一切( 三 )

  • 访问控制列表——跟踪每个组中消费者的数量及其访问权限
  • 配额——跟踪每个客户端可以读取和写入的数据量
  • 长轮询Kafka 如何向消费者推送消息?
    RabbitMQ 采用推送模型 。代理与消费者保持持久的 TCP 连接,并在有可用数据时将数据推送给他们 。
    然而,推送模型可能会淹没消费者 。如果代理推送数据的速度快于消费者处理数据的速度,消费者可能会落后 。RabbitMQ 确实有一个解决方案,这边就不展开讨论了 。
    长轮询等待方式方法
    Kafka 使用拉模型,也就是长轮询 。消费者定期从代理拉取数据 。因此,消费者只有在准备好时才能拉取数据 。但是,如果分区上没有数据,来自消费者的定期轮询可能会导致资源浪费 。
    Kafka通过使用“long polling”等待模式的方式解决了这个问题 。简而言之,如果分区上没有数据,Kafka 不会返回空响应 。相反,broker保持连接并等待数据进入,然后再将其返回给消费者 。
    这减轻了当分区上没有数据时消费者频繁轮询并防止资源浪费 。
    总结本文总结了Kafka这个组件的基础知识,希望让大家对Kafka有一个宏观的认识,感兴趣的再深入分析底层的实现机制 。




    推荐阅读