我在Kafka遇到了一个经常出现的问题:我按客户ID对邮件进行分区,有时会发生客户收到大量邮件的情况.结果,该客户和同一分区中的所有其他客户的消息被延迟.
有没有众所周知的方法来处理这个问题?可能与其他消息传递平台?
理想情况下,只会延迟一个客户的消息.其他客户的消息将获得消费者带宽的相等份额.
注意:我必须按客户ID进行分区,因为我想按顺序使用任何给定自定义的消息.但是,我可以按任何顺序使用两个客户的消息.