Kafka stratégie de nouvelle tentative de configuration Producteur

Question

Quels paramètres de Kafka configuration du producteur sont nécessaires pour être modifié afin que le producteur doit: 1) Retry n fois 2) Après intervalle de n pour le même message en cas si le courtier est en baisse.

J'ai besoin de gérer une situation liée à ceci: https://github.com/rsyslog/rsyslog/issues/1052

Answer 1

En supposant que vous faites référence à la bibliothèque confluentes-kafka-python, je crois que la config que vous cherchez sont:

1. message.send.max.retries
2. retry.backoff.ms

Voir les détails de configuration here