FIX calcule Partition

abes-esr · Sep 4, 2024 · ad44374 · ad44374
1 parent ee5b3a6
commit ad44374
Showing 1 changed file with 2 additions and 8 deletions.
diff --git a/src/main/java/fr/abes/bestppn/kafka/TopicProducer.java b/src/main/java/fr/abes/bestppn/kafka/TopicProducer.java
@@ -215,16 +215,10 @@ private void logEnvoi(SendResult<String, ?> result, ProducerRecord<String, ?> re
                 record.key(), record.value(), metadata.topic(), metadata.partition(), metadata.offset(), Stream.of(result.getProducerRecord().headers().toArray()).map(h -> h.key() + ":" + Arrays.toString(h.value())).collect(Collectors.joining(";"))));
     }
 
-    public Integer calculatePartition(Integer nbPartitions) throws ArithmeticException {
+    public Integer calculatePartition(int nbPartitions) throws ArithmeticException {
         if (nbPartitions == 0) {
             throw new ArithmeticException("Nombre de threads = 0");
         }
-        synchronized (nbPartitions) {
-            if (lastThreadUsed.incrementAndGet() >= nbPartitions) {
-                lastThreadUsed.set(0);
-            }
-        }
-
-        return lastThreadUsed.get();
+        return lastThreadUsed.getAndIncrement() % nbPartitions;
     }
 }