如何避免消息重复投递或重复消费？

避免消息重复投递或重复消费，可以通过以下几种策略实现：

1. 幂等性设计：确保业务逻辑具有幂等性，即无论相同的消息被处理多少次，其结果都与处理一次相同。例如，在支付场景中，通过订单号作为幂等键，确保多次扣款请求只会执行一次扣款操作。

2. 唯一消息标识（Message ID）：利用消息系统提供的唯一消息标识，消费端可以记录已处理的消息ID，对于已经处理过的消息进行过滤，避免重复处理。

3. 消费去重逻辑：在消费者端实现消息去重机制，比如使用哈希表、Redis等数据结构存储已处理消息的标识，对重复消息进行识别和过滤。

4. 合理配置消费参数：针对大消息或公网消费，适当调整如max.poll.records、fetch.max.bytes、max.partition.fetch.bytes等参数，控制拉取速度和消息大小，减少因网络不稳定导致的重复拉取消息。

5. 控制消费时长与QoS设置：确保每个队列的消费时长不超过服务端限制，并根据消费能力合理设置预取数量(Prefetch Count)，避免消息处理超时引发的重新投递。

6. 监控与日志分析：开启并分析消息日志，及时发现并定位消费重复的问题，结合实例的消费时长统计，优化消费逻辑和参数配置。

通过上述方法综合施策，可以在很大程度上减少消息重复投递和重复消费的情况，保障系统的稳定性和数据的一致性。