Shikong/springcloud-study
1
0
Fork 0
mirror of https://gitee.com/shikong-sk/springcloud-study synced 2024-11-09 01:51:19 +08:00
Code Issues Packages Projects Releases Wiki Activity

多分片并发消费

Browse Source
This commit is contained in:
shikong 2024-07-07 18:47:38 +08:00
parent 346ffe3d23
commit aa7f659b23
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 @Component
public class MQListener { 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) { public void onMessage(ConsumerRecord<String, String> record, Acknowledgment ack) {
log.info("消费消息: 主题 {} 分片 {} ",record.topic(),record.partition()); log.info("消费消息: 主题 {} 分片 {} ",record.topic(),record.partition());
log.info("key {}, value {}",record.key(),record.value()); log.info("key {}, value {}",record.key(),record.value());