[patch] visibility (#91)

osskit · Dec 14, 2023 · a9237ee · a9237ee
1 parent c1e08b5
commit a9237ee
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/Main.java b/src/main/java/Main.java
@@ -54,10 +54,10 @@ private static Disposable createConsumer(MonitoringServer monitoringServer) {
             .commitBatchSize(0)
             .subscription(Pattern.compile(topicsRoutes.getTopicsPattern()))
             .addAssignListener(partitions -> {
-                Monitor.assignedToPartition(partitions);
                 if (partitions.isEmpty()) {
                     return;
                 }
+                Monitor.assignedToPartition(partitions);
                 monitoringServer.consumerAssigned();
             })
             .addRevokeListener(Monitor::revokedFromPartition);