Identifizieren Sie die neueste Nachricht mit dem Spring Kafka Produzent
Posted: 02 Mar 2025, 15:00
Was ich erreichen möchte:
Ich möchte die wiedergegebene Nachricht mit Spring Kafka identifizieren, wenn ich die wiedergegebene Nachricht erzeugt. /> Leider ist der Kafka -Cluster schuppig, aber nicht zu einem Punkt, an dem er vollständig heruntergekommen ist. Normalerweise senden einige Wiederholungen die Nachricht erfolgreich an Kafka. Tags tag diese.
Während dies die Wiederholung konfigurieren würde, unterscheidet es keine erneute Meldung.>
Ich möchte die wiedergegebene Nachricht mit Spring Kafka identifizieren, wenn ich die wiedergegebene Nachricht erzeugt. /> Leider ist der Kafka -Cluster schuppig, aber nicht zu einem Punkt, an dem er vollständig heruntergekommen ist. Normalerweise senden einige Wiederholungen die Nachricht erfolgreich an Kafka. Tags tag diese.
Code: Select all
retries (defaults to Integer.MAX_VALUE): the maximum number of attempts to publish the message
delivery.timeout.ms (defaults to 120,000): the maximum time to wait for a message to be acknowledged before considering it failed
retry.backoff.ms (defaults to 100): the time to wait before retrying
retry.backoff.max.ms (defaults to 1,000): the maximum delay between consecutive retries
< /code>
Mit dieser aus dem offiziellen Dokument habe ich dieses Konstrukt verwendet: < /p>
Properties props = new Properties();
// other properties
props.put(RETRIES_CONFIG, 20);
props.put(RETRY_BACKOFF_MS_CONFIG, "500");
props.put(DELIVERY_TIMEOUT_MS_CONFIG, "5000");
[...]
props.put(BOOTSTRAP_SERVERS_CONFIG, KAFKA_CONTAINER.getBootstrapServers());
props.put(KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
props.put(VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
KafkaProducer producer = new KafkaProducer(props);