Skip to content

Commit 01db10f

Browse files
committed
add topic validation of kafka listener
Signed-off-by: moonyoungCHAE <xpf_fl@naver.com>
1 parent bc07101 commit 01db10f

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaListenerAnnotationBeanPostProcessor.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -665,6 +665,8 @@ private void processKafkaListenerAnnotation(MethodKafkaListenerEndpoint<?, ?> en
665665
endpoint.setBean(bean);
666666
endpoint.setMessageHandlerMethodFactory(this.messageHandlerMethodFactory);
667667
endpoint.setGroupId(getEndpointGroupId(kafkaListener, endpoint.getId()));
668+
669+
Assert.state((topics.length > 0) ^ (tps.length > 0), "Only one of @Topic or @TopicPartition is allowed");
668670
endpoint.setTopicPartitions(tps);
669671
endpoint.setTopics(topics);
670672
endpoint.setTopicPattern(resolvePattern(kafkaListener));

0 commit comments

Comments
 (0)