Должен ли идемпотентный производитель быть транзакционным, чтобы обеспечить идемпотентность при публикации в многораздельной теме?После прочтения документации Kafka я все еще не уверен, что это так.
Моя среда - кластер Kafka 1.0 и клиент Kafka 1.1.
Идемпотентный производитель создает идентификатор, который отправляется с сообщениями.С этим идентификатором ведущий брокер может сказать: «О, я уже обработал это сообщение».
Идемпотентный производитель и транзакционный обмен сообщениями - это два разных подхода к созданиюсемантика обмена сообщениями.
Итак, нет!