240 发简信
IP属地:北京
  • kafka生产者配置参数

    1.ack ack=0, 生产者在成功写入消息之前不会等待任何来自服务器的相应。如果出现问题生产者是感知不到的,消息就丢失了。不过因为生产者不需要等待服务器响应,所以它可以以...

  • kafka消费者一次性语义方法

    目前根据自己的理解和kafka权威指南提供的方式一共有两种可以实现消费者的一次性语义的方式,在kafka1.10之后kafka内部可以保证生产者端到broker的一次性语义。...