高并发投票

src/main/java/com/smcic/api/operate/job/Kafka2Db.java

@@ -48,7 +48,7 @@ public class Kafka2Db {
         while (true) {
             Boolean success = redisTemplate.opsForValue().setIfAbsent(lockKey, String.valueOf(id), Duration.ofSeconds(20));
             if (Boolean.FALSE.equals(success)){
-                break;
+                continue;
             }
             List<VoteInfo> voteInfos = new ArrayList<>();
             consumer.poll(Duration.ofMillis(300)).forEach((record) -> {