修改mock数据量
This commit is contained in:
@@ -53,7 +53,7 @@ public class TestController {
|
||||
try {
|
||||
AicorpusTelephoneDTO aicorpusTelephone = objectMapper.readValue(message, AicorpusTelephoneDTO.class);
|
||||
log.info("mockKafka:{}",message);
|
||||
for (int i = 0; i < 2; i++){
|
||||
for (int i = 0; i < 10; i++){
|
||||
aicorpusTelephone.setSourceId(aicorpusTelephone.getSourceId().concat("_"+i));
|
||||
kafkaTemplate.send("topic_voc_covert_text_log", JSONObject.toJSONString(aicorpusTelephone)); // 发送 Kafka 消息
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user