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 中配置消息冪等性的方法。希望對你有所幫助！
