Когда я сканирую kafka's document, я вижу статью о idempotent producer, которая является очень крутым будущим. Тем не менее, я не уверен, было ли это реализовано в версии 0.9 или просто предложение для будущей версии. Кто-нибудь знает об этом?Имеет ли kafka будущее идемпотентного продюсера
В первом разделе +4,6 доставки сообщений Семантики
документа Это не самая сильная возможная Семантика для издателей. Хотя мы не можем быть уверены в том, что произошло в случае ошибки сети , можно разрешить производителю генерировать своего рода «первичный ключ», который заставляет повторять запрос идемпотент. Эта функция не является тривиальной для реплицируемой системы, так как она должна работать даже (или особенно) в случае сбоя сервера. С этой функцией было бы достаточно, чтобы продюсер повторил до тех пор, пока он не получил подтверждение успешно зафиксированного сообщения, в котором баллов мы гарантировали бы, что сообщение было опубликовано ровно один раз. Мы надеемся, что добавить это в будущую версию Kafka.
Это выглядит очень неопределенно, разве это еще не реализовано?
продюсера
Я также пытаюсь выяснить, если это является особенностью. Знаете ли вы, или у вас есть обход? – user1658296
Функция еще не реализована. См. Билет [JIRA] (https://issues.apache.org/jira/browse/KAFKA-1436) для получения дополнительной информации. Кажется, что теперь основное внимание уделяется [точно-семантической] (https://github.com/edenhill/librdkafka/issues/114), поэтому это, скорее всего, будет реализовано в рамках этой инициативы. –
@TianxiangXiong, семантика одноразового семестра - один из способов реализации идемпотенции. Мы можем понять идемпотентный оператор как вызов этого метода снова и снова, он фактически тот же, что и при вызове. – ivenxu