diff --git a/src/main/java/uk/gov/companieshouse/disqualifiedofficers/delta/consumer/DisqualifiedOfficersDeltaConsumer.java b/src/main/java/uk/gov/companieshouse/disqualifiedofficers/delta/consumer/DisqualifiedOfficersDeltaConsumer.java index 889b1dc..4ce6e14 100644 --- a/src/main/java/uk/gov/companieshouse/disqualifiedofficers/delta/consumer/DisqualifiedOfficersDeltaConsumer.java +++ b/src/main/java/uk/gov/companieshouse/disqualifiedofficers/delta/consumer/DisqualifiedOfficersDeltaConsumer.java @@ -35,8 +35,7 @@ public DisqualifiedOfficersDeltaConsumer(DisqualifiedOfficersDeltaProcessor delt @RetryableTopic(attempts = "${disqualified-officers.delta.retry-attempts}", backoff = @Backoff(delayExpression = "${disqualified-officers.delta.backoff-delay}"), fixedDelayTopicStrategy = FixedDelayStrategy.SINGLE_TOPIC, - retryTopicSuffix = "-${disqualified-officers.delta.group-id}-retry", - dltTopicSuffix = "-${disqualified-officers.delta.group-id}-error", + dltTopicSuffix = "-error", dltStrategy = DltStrategy.FAIL_ON_ERROR, autoCreateTopics = "false", exclude = NonRetryableErrorException.class)