EmailJobsListener注释KafkaListener注解

This commit is contained in:
万佳 2021-09-15 16:16:43 +08:00
parent c14c7750eb
commit 2903ac29c7
1 changed files with 1 additions and 1 deletions

View File

@ -14,7 +14,7 @@ import org.springframework.stereotype.Component;
@Component
@Configuration
//todo 邮件的topics和groupId待处理
@KafkaListener(topics = "${spring.kafka.consumer.topic}", groupId = "${spring.kafka.consumer.group_id}")
//@KafkaListener(topics = "${spring.kafka.consumer.topic}", groupId = "${spring.kafka.consumer.group_id}")
public class EmailJobsListener {
private Logger logger = LogManager.getLogger(EmailJobsListener.class);