add

moment/views/consum.py

@@ -40,7 +40,8 @@ def kafka_consum(topic_name=None):
         #     consumser_obj.seek(partition=TopicPartition(topic_name,int(partition_id.decode())),offset=int(topic_partition_info[partition_id]))
         while True:
             begin = time.time()
-            msg_dict = consumser_obj.poll(timeout_ms=10000, max_records=50)
+            msg_dict = consumser_obj.poll(timeout_ms=10000, max_records=500)
+
             consumser_obj.commit_async()
             for msg_value in msg_dict.values():
                 for msg in msg_value: