Re: Ack mode of individual pulsar

2018-07-12 Thread Sijie Guo
I can't find source code in package org.apache.bookkeeper.mledger.proto > > -- > li.peng...@zhaopin.com.cn > > > *From:* Sijie Guo > *Date:* 2018-07-12 00:40 > *To:* user ; us...@pulsar.incubator.apache.org > *Subject:* Re: Ack mode of individual pulsar >

Re: Ack mode of individual pulsar

2018-07-11 Thread li.peng...@zhaopin.com.cn
org.apache.bookkeeper.mledger.proto li.peng...@zhaopin.com.cn From: Sijie Guo Date: 2018-07-12 00:40 To: user; us...@pulsar.incubator.apache.org Subject: Re: Ack mode of individual pulsar +users@pulsar In the context of pulsar, when a consumer acks a message, it doesn’t remove entries from bookkeeper

Re: Ack mode of individual pulsar

2018-07-11 Thread Sijie Guo
+users@pulsar In the context of pulsar, when a consumer acks a message, it doesn’t remove entries from bookkeeper. Instead, for each subscription at pulsar, pulsar brokers use a separate ledger for storing the acknowledgments for each subscription. When a broker receives individual acks, it

Ack mode of individual pulsar

2018-07-11 Thread li.peng...@zhaopin.com.cn
In introduce of pulsar, i interest in ack mode of individual. I know that pulsar use bookkeeper to store messages, and entries in bookkeeper write only once. so i want to know how pulsar server do message ack in individual mode. if ack failed, how long will i receive the message again.