Last updated: 2021-12-28 17:08:15

    How do I calculate the number of unconsumed messages?

    Number of unconsumed messages = maximum offset - submitted offset, as shown below:

    img

    Can the message retention period be automatically adjusted?

    CKafka allows you to add dynamic message retention policies. After such a policy is set, if the disk utilization reaches the specified percentage, a certain proportion of existing data will automatically expire in case of message surges, helping avoid situations where normal production and consumption stop after the disk space is used up. For detailed directions, please see Adding Dynamic Message Retention Policy.