-
Notifications
You must be signed in to change notification settings - Fork 18
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
remove serde.retention, use retention.max-hr * hour_seconds #56
Conversation
chenqin
commented
Dec 14, 2020
- group max-mb max-hr under retention configuration
- remove ser.retention use max-hr double value multiple with 3600 as kafka ingestion retention config
eviction configuration, put max-mb, max-hr under same yaml config
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think the change in for Kafka serde is inappropriate, otherwise looks good!
src/meta/ClusterInfo.cpp
Outdated
auto retention = node["retention"]; | ||
if (retention) { | ||
serde.retention = retention.as<uint64_t>(); | ||
} | ||
serde.retention = (uint64_t) retention; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This retention is KAFKA topic retention in Kafka store, not the max-hr (retention in Nebula), the usage of this value is used to estimate offset and range for each Kafka split when early version of Kafka doesn't have watermark/offset feature, we should leave this as it is.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
got it, how about rename to topic-retention to avoid confusion.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
sounds good to me, thanks for the update.
Notice to upgrade table compatible with this change |