From a0f386f06f896657105e419ad33e66a2cc660a3d Mon Sep 17 00:00:00 2001 From: Marius Bogoevici Date: Sun, 18 Jun 2017 11:02:19 -0400 Subject: [PATCH] Log faulty topic name during validation Fix #157 --- .../cloud/stream/binder/kafka/utils/KafkaTopicUtils.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/KafkaTopicUtils.java b/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/KafkaTopicUtils.java index 8b937bfbe..9c0aee8f2 100644 --- a/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/KafkaTopicUtils.java +++ b/spring-cloud-stream-binder-kafka-core/src/main/java/org/springframework/cloud/stream/binder/kafka/utils/KafkaTopicUtils.java @@ -37,7 +37,8 @@ public final class KafkaTopicUtils { if (!((b >= 'a') && (b <= 'z') || (b >= 'A') && (b <= 'Z') || (b >= '0') && (b <= '9') || (b == '.') || (b == '-') || (b == '_'))) { throw new IllegalArgumentException( - "Topic name can only have ASCII alphanumerics, '.', '_' and '-'"); + "Topic name can only have ASCII alphanumerics, '.', '_' and '-', but was: '" + topicName + + "'"); } } }