是的,只需遵循@KafkaListener
JavaDocs:
/** * The topics for this listener. * The entries can be 'topic name', 'property-placeholder keys' or 'expressions'. * Expression must be resolved to the topic name. * Mutually exclusive with {@link #topicPattern()} and {@link #topicPartitions()}. * @return the topic names or expressions (SpEL) to listen to. */ String[] topics() default {}; /** * The topic pattern for this listener. * The entries can be 'topic name', 'property-placeholder keys' or 'expressions'. * Expression must be resolved to the topic pattern. * Mutually exclusive with {@link #topics()} and {@link #topicPartitions()}. * @return the topic pattern or expression (SpEL). */ String topicPattern() default ""; /** * The topicPartitions for this listener. * Mutually exclusive with {@link #topicPattern()} and {@link #topics()}. * @return the topic names or expressions (SpEL) to listen to. */ TopicPartition[] topicPartitions() default {};
所以,你的用例应该是这样的:
@KafkaListener(topics = {"topic1" , "topic2"})