最近两周我们的DTS数据订阅在周末经常出现消息堆积。
我们的消费程序,拿到消息后,立即异步执行我们的业务逻辑,消费速度可以认为是立即,而且我们只是监听了部分表的数据变化。
从现象上看是,消息突然增加,消费能力不足导致。但是我观察了日志,每次拉取的数据量也很小,如何增加这个数据的拉取量呢。
最近两周我们的DTS数据订阅在周末经常出现消息堆积。
我们的消费程序,拿到消息后,立即异步执行我们的业务逻辑,消费速度可以认为是立即,而且我们只是监听了部分表的数据变化。
从现象上看是,消息突然增加,消费能力不足导致。但是我观察了日志,每次拉取的数据量也很小,如何增加这个数据的拉取量呢。