admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改kafka配置

Browse Source
This commit is contained in:
zren25
2025-03-06 10:48:05 +08:00
parent aacb94793e
commit 7c8ce6867b
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/CorpusProcessKafkaConsumer.java
View File

@@ -10,12 +10,8 @@ import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RestController;
import java.time.LocalDateTime;
import java.util.Date;
/**
* @ClassName CorpusProcessKafkaConsumer
@@ -26,7 +22,6 @@ import java.util.Date;
**/
@Slf4j
@Component
@RestController
public class CorpusProcessKafkaConsumer {
@Autowired
@@ -34,11 +29,10 @@ public class CorpusProcessKafkaConsumer {
private final ObjectMapper objectMapper = new ObjectMapper();
@GetMapping("corpusProcessKafkaConsumer")
// @KafkaListener(topics = "aicorpus-telephone", groupId = "test-group")
public void listen(@RequestBody String message) {
@KafkaListener(topics = "${spring.kafka.topic}", groupId = "${spring.kafka.group}")
public void listen(String message) {
try {
log.info("Received message: {}" , message);
log.info("CorpusProcessKafkaConsumer Received message: {}" , message);
AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class);
log.info("aicorpusTelephone categoryCode:{}, display: {}" ,aicorpusTelephone.getCategoryCode(), aicorpusTelephone.getDisplay());