add

moment/views/process_time.py

@@ -340,7 +340,7 @@ def judge_offset_partition_have_consum(offset=0, partition=0):
         redis_list_data = 0
         key = "irrigation_partition_offset_have_consum:" + str(partition)
         redis_data = redis_client.get(key)
-        if offset > int(redis_data):
+        if offset < int(redis_data):
             return False
         redis_client.set(key, offset)
         return True