|
@@ -30,7 +30,7 @@ public class QAProblemJobListener {
|
|
|
private KafkaTemplate<Object,QAProblemJob> kafkaTemplate;
|
|
|
|
|
|
//正常队列
|
|
|
- @KafkaListener(id = "qa_problem_consumer_group", topics = "qa_problem_job")
|
|
|
+ @KafkaListener(id = "qa_problem_consumer_group_test", topics = "qa_problem_job_test")
|
|
|
public void consumeJob(ConsumerRecord<Object,QAProblemJob> record, Acknowledgment ack) {
|
|
|
ack.acknowledge(); //无论是否成功都直接提交
|
|
|
var job = record.value();
|
|
@@ -56,7 +56,7 @@ public class QAProblemJobListener {
|
|
|
}
|
|
|
|
|
|
//正常队列错误的的死信对列
|
|
|
- @KafkaListener(id = "qa_problem_error_consumer_group", topics = "qa_problem_job_error")
|
|
|
+ @KafkaListener(id = "qa_problem_error_consumer_group_test", topics = "qa_problem_job_error_test")
|
|
|
public void consumeErrorJob(ConsumerRecord<Object,QAProblemJob> record, Acknowledgment ack) {
|
|
|
var job = record.value();
|
|
|
logger.info("[error queue] receive job : {}",job);
|