We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent e102c1d commit cc0c139Copy full SHA for cc0c139
1 file changed
apps/commerce-streamer/src/main/java/com/loopers/interfaces/consumer/KafkaOutboxConsumer.java
@@ -44,7 +44,6 @@ public void productViewedListener(
44
Acknowledgment acknowledgment
45
) throws JsonProcessingException {
46
47
- // 1) 배치 내 productId별 점수 누적
48
Map<Long, Double> scoreDelta = new HashMap<>();
49
50
for (var record : messages) {
@@ -73,8 +72,7 @@ public void productViewedListener(
73
72
zset.incrementScore(key, String.valueOf(e.getKey()), e.getValue()); // ZINCRBY
74
}
75
76
- // 3) 일간 키는 TTL 걸어두는 게 운영에 유리 (예: 8일 보관)
77
- redisTemplate.expire(key, Duration.ofDays(8));
+ redisTemplate.expire(key, Duration.ofDays(2));
78
79
acknowledgment.acknowledge();
80
0 commit comments