by Anonymous » 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.
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);
Während dies die Wiederholung konfigurieren würde, unterscheidet es keine erneute Meldung.>
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.[code]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);
[/code]
Während dies die Wiederholung konfigurieren würde, unterscheidet es keine erneute Meldung.>
Mobile version