We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b58096f commit fceb7ebCopy full SHA for fceb7eb
backend/src/main/java/io/f1/backend/domain/stat/app/StatKafkaConsumer.java
@@ -26,17 +26,14 @@ public class StatKafkaConsumer {
26
@Transactional
27
@KafkaListener(topics = "stat-changes")
28
public void handleStatChanges(List<String> messages) {
29
- log.info("Received {} messages from Kafka", messages.size());
30
31
try {
32
- // JSON 문자열을 StatChangeEvent 객체로 변환
33
List<StatChangeEvent> events = new ArrayList<>();
34
for (String message : messages) {
35
StatChangeEvent event = objectMapper.readValue(message, StatChangeEvent.class);
36
events.add(event);
37
}
38
39
- log.info("Processing {} stat change events", events.size());
40
statBatchRepository.batchUpdateStats(events);
41
42
} catch (Exception e) {
0 commit comments