fix: fix get topic for resend message

Byndyusoft · Dec 18, 2023 · 735cae1 · 735cae1
1 parent 2af1487
commit 735cae1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/consumer/exceptions/kafkaConsumerErrorTopicExceptionFilter.ts b/src/consumer/exceptions/kafkaConsumerErrorTopicExceptionFilter.ts
@@ -113,7 +113,7 @@ export class KafkaConsumerErrorTopicExceptionFilter
   ): string | false {
     const topic =
       kafkaConsumerError.retriable &&
-      typeof this.options.retryTopicPicker === "function"
+      this.options.retryTopicPicker !== undefined
         ? this.options.retryTopicPicker
         : this.errorTopicPicker;