diff --git a/back/src/main/java/com/back/global/kafka/KafkaConsumer.java b/back/src/main/java/com/back/global/kafka/KafkaConsumer.java index ee4d9790..a5cc99a8 100644 --- a/back/src/main/java/com/back/global/kafka/KafkaConsumer.java +++ b/back/src/main/java/com/back/global/kafka/KafkaConsumer.java @@ -19,7 +19,9 @@ public void consume(String transcodingStatusMessage) { try { JsonNode rootNode = mapper.readTree(transcodingStatusMessage); - String uuid = rootNode.get("key").asText(); + String key = rootNode.get("key").asText(); + String uuid = key.replaceFirst("^videos/", ""); + String status = rootNode.get("qualities").toString(); //현재 duration이 0인 문제가 있음 영상 길이가 필요한게 아니라면 제거할 예정 fileManager.updateVideoStatus(uuid, status);