Skip to content

Commit

Permalink
fix(impl): Fix missing DLQ topic error message
Browse files Browse the repository at this point in the history
The message mentions to define a `dlq.topic` configuration entry.
Whilst the proper key to define is rather `kafkastreamsprocessor.dlq.topic`.
  • Loading branch information
edeweerd1A committed Oct 23, 2024
1 parent 3e4ed5b commit db0221a
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,8 @@ public static boolean shouldSendToDlq(String errorStrategy, Optional<String> 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;
Expand Down

0 comments on commit db0221a

Please sign in to comment.