Kafka 消息幂等的配置主要涉及到两个方面：消费者端和生产者端。下面分别介绍如何进行配置。
在消费者端，我们可以通过设置 enable.auto.commit 为 false 来确保消息的幂等性。这样，消费者在处理每条消息时都会先检查该消息是否已经被处理过，如果没有，则处理并标记为已处理；如果已经处理过，则忽略该消息。
此外，为了进一步确保幂等性，我们还可以使用事务来确保一组消息的原子性提交。这需要在消费者端开启事务支持，并在处理消息时使用事务API。
具体配置如下：
# 开启事务支持
enable.auto.commit=false
transactional.id=my-transactional-id
# 设置事务超时时间
transaction.timeout.ms=10000
# 设置最大并发事务数
max.in.flight.requests.per.connection=1
在生产者端，我们可以通过设置 enable.idempotence 为 true 来开启幂等性。这样，Kafka 会为每个生产者分配一个唯一的 ID（PID），并为每个 PID 生成一个序列号。生产者发送的消息会包含这个序列号，Kafka 会根据这个序列号来确保消息的幂等性。
具体配置如下：
# 开启幂等性
enable.idempotence=true
# 设置唯一生产者 ID
transactional.id=my-transactional-id
# 设置最大并发事务数
max.in.flight.requests.per.connection=1
需要注意的是，为了确保幂等性，生产者和消费者必须使用相同的事务 ID（transactional.id），并且必须配置相同的 max.in.flight.requests.per.connection 值。此外，消费者在处理消息时还需要使用事务API来确保消息的原子性提交。
以上就是在 Kafka 中配置消息幂等性的方法。希望对你有所帮助！