R
Size: a a a
R
AE
R
AE
R
AE
R
AE
AE
R
AE
R
PK
VS
@StreamListener(KafkaBindings.CONFIGURATION)
public void processConfiguration(SomeMessage message) {
log.debug("TEST RETRY");
throw new ConstraintViolationException("", Set.of());
}
configuration:
destination: ${configuration.topic:configuration}
group: some_group
consumer:
max-attempts: 1
retryable-exceptions:
javax.validation.ConstraintViolationException: false
PK
AK
PK
PK