You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@pulsar.apache.org by GitBox <gi...@apache.org> on 2022/11/15 04:47:25 UTC
[GitHub] [pulsar] startjava created a discussion: what is "滚动策略循环"?
GitHub user startjava created a discussion: what is "滚动策略循环"?
https://www.jianshu.com/p/168db3b69fac
一个 stream 由多个 ledger 组成;每个 ledger 根据基于时间或空间的滚动策略循环。
@sijie
how do loop??
GitHub link: https://github.com/apache/pulsar/discussions/18471
----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@pulsar.apache.org
[GitHub] [pulsar] startjava added a comment to the discussion: what is "滚动策略循环"?
Posted by GitBox <gi...@apache.org>.
GitHub user startjava added a comment to the discussion: what is "滚动策略循环"?
https://pulsar.apache.org/docs/next/concepts-architecture-overview/#managed-ledgers
A ledger can be deleted when all cursors have consumed the messages it contains. This allows for periodic rollover of ledgers.
“periodic rollover of ledgers”
what is rollover of ledgers ? how rollover??
ledgers not delete, from begin write data ??
GitHub link: https://github.com/apache/pulsar/discussions/18471#discussioncomment-4143453
----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@pulsar.apache.org
[GitHub] [pulsar] MarvinCai added a comment to the discussion: what is "滚动策略循环"?
Posted by GitBox <gi...@apache.org>.
GitHub user MarvinCai added a comment to the discussion: what is "滚动策略循环"?
Rollover means delete old(consumed) ledgers and make room for new ledgers.
Ledger is append only and will not be writable once closed/fenced.
Ledger can only be deleted as a whole, so all entries on a ledger has to be consumed and acked by consumers(or auto acked by ttl).
Broker will scan ledger at background and if a ledger is fullly consumer(all entries are consumed) & (ledger exists more than configured retention period || total storage size for a topic cross max retion size), then it's marked for delete(rollover).
GitHub link: https://github.com/apache/pulsar/discussions/18471#discussioncomment-4254595
----
This is an automatically sent email for dev@pulsar.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@pulsar.apache.org