Previously, each partition topic will periodically call the CronFlow function. This is to ensure that the message is lost in some cases, so that the next flow will never be triggered, resulting in message accumulation. But it seems that pulsar-client-go has fixed this problem, so we can cancel the periodically call.
Previously, each partition topic will periodically call the CronFlow function. This is to ensure that the message is lost in some cases, so that the next flow will never be triggered, resulting in message accumulation. But it seems that pulsar-client-go has fixed this problem, so we can cancel the periodically call.