Shikong/springcloud-study
1
0
Fork 0
mirror of https://gitee.com/shikong-sk/springcloud-study synced 2025-04-18 17:28:03 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/master'

Browse Source
This commit is contained in:
Shikong 2024-11-08 22:20:14 +08:00
commit f505e9b49e
Signed by: Shikong
GPG Key ID: BD85FF18B373C341
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
kafka-01/kafka-01-consumer/src/main/java/cn/skcks/study/springcloud/kafka/consumer/services/MQListener.java
View File

@ -11,7 +11,7 @@ import org.springframework.stereotype.Component;
@Component
public class MQListener {
@KafkaListener(topics = {"test"},groupId = "test-group")
@KafkaListener(topics = {"test"},groupId = "test-group", concurrency = "3")
public void onMessage(ConsumerRecord<String, String> record, Acknowledgment ack) {
log.info("消费消息: 主题 {} 分片 {} ",record.topic(),record.partition());
log.info("key {}, value {}",record.key(),record.value());