From 01db10fc9cd9d678c564b14626d25b3aea316aee Mon Sep 17 00:00:00 2001 From: moonyoungCHAE Date: Thu, 20 Nov 2025 11:11:56 +0900 Subject: [PATCH] add topic validation of kafka listener Signed-off-by: moonyoungCHAE --- .../annotation/KafkaListenerAnnotationBeanPostProcessor.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java b/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java index 5e016c2366..1a2c89a789 100644 --- a/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java +++ b/spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java @@ -665,6 +665,8 @@ private void processKafkaListenerAnnotation(MethodKafkaListenerEndpoint en endpoint.setBean(bean); endpoint.setMessageHandlerMethodFactory(this.messageHandlerMethodFactory); endpoint.setGroupId(getEndpointGroupId(kafkaListener, endpoint.getId())); + + Assert.state((topics.length > 0) ^ (tps.length > 0), "Only one of @Topic or @TopicPartition is allowed"); endpoint.setTopicPartitions(tps); endpoint.setTopics(topics); endpoint.setTopicPattern(resolvePattern(kafkaListener));