• 约60条记录,页面显示在80条内,推荐使用搜索获取文章发布时间       点击
  • 2018-01-25     57

    当与zookeeper通信存在异常时,acquire会直接抛出异常,需要使用者自身做重试策略。代码中调用了internalLock(-1, null),参数表明在锁被占用时永久阻塞等待

  • 2018-01-25     47

    旧的消费者依赖于zookeeper管理消费组(译注:ZookeeperConsumerConnector->ZKRebalancerListener), 新的消费者使用了消费组协调协议.

  • 2018-01-25     53

    consumer group是kafka提供的可扩展且具有容错性的消费者机制。既然是一个组,那么组内必然可以有多个消费者或消费者实例(consumer instance),它们共享一个公共的ID

  • 2016-10-08     81

    利用单节点部署多个broker。 不同的broker 设置不同的 id,监听端口及日志目录。

  • 2016-10-08     108

    Kafka中的Message是以topic为基本单位组织的,不同的topic之间是相互独立的。每个topic又可以分成几个不同的partition(每个topic有几个partition是在创建topic时指定的),每个partition存储一部分Message。

  • 2016-10-08     102

    同步生产模型,生产者每次都发送一条消息都会等待,zookeeper集群的确认,如果没有收到确认,则短暂的等待,再次发送,只到达到设置的最大的发送次数

  • 2016-09-20     99

    Kafka Producer 发送消息的两种方式:同步发送、异步发送。

  • 2016-08-23     70

    消息总线需要考虑各个维度:效率、性能、网络、吞吐量、甚至需要自己去设想API可能的使用场景、模式。

  • 2016-07-02     69

    RabbitMQ , 是一个使用 erlang 编写的 AMQP (高级消息队列协议) 的服务实现. 简单来说, 就是一个功能强大的消息队列服务.

  • 2016-07-02     62

    消息Message , RabbitMQ 中的消息有自己的一系列属性, 某些属性对信息流有直接 .... 所以, 默认情况下, 消息, 队列, 交换器都不具有持久化的性质