diff --git a/impl/src/main/java/io/quarkiverse/kafkastreamsprocessor/impl/errors/ErrorHandlingStrategy.java b/impl/src/main/java/io/quarkiverse/kafkastreamsprocessor/impl/errors/ErrorHandlingStrategy.java index 68b2978..2a58aad 100644 --- a/impl/src/main/java/io/quarkiverse/kafkastreamsprocessor/impl/errors/ErrorHandlingStrategy.java +++ b/impl/src/main/java/io/quarkiverse/kafkastreamsprocessor/impl/errors/ErrorHandlingStrategy.java @@ -60,7 +60,8 @@ public static boolean shouldSendToDlq(String errorStrategy, Optional dlq if (dlqTopic.isPresent()) { return true; } else { - throw new IllegalStateException("DLQ strategy enabled but dlq.topic configuration property is missing"); + throw new IllegalStateException( + "DLQ strategy enabled but kafkastreamsprocessor.dlq.topic configuration property is missing"); } } return false;