Производитель Kafka должен повторить три раза в случае неудачи

Question

Я хочу внедрить логику повторов производителей Kafka c три раза в случае любого сбоя, а также я хочу вручную проверить, повторяет ли производитель попытки или нет. Можете ли вы предложить мне, как вручную проверить эту функциональность. В приведенной ниже конфигурации добавлена ​​конфигурация производителя, чтобы повторить попытку в случае любого сбоя. Спасибо.

props.put("retries", 3);

Answer 1

Вы должны доверять этой основной функциональности Kafka, но вы можете отследить ее с помощью захвата пакетов Производителя.

вы можете использовать tcpdump для того, чтобы прослушивать пакеты на сервере-производителе и проверять, сколько раз они отправляли:
tcpdump -i any port 9092
Я также рекомендую просмотреть этот ответ об использовании tshark для захвата Кафки.

Если вы хотите изучить протокол еще глубже, вы можете использовать WireShark.
Ознакомьтесь с этим руководством о как установить WireShark на Linux .