Skip to content

V
vest
Commit e0fd699b authored by lixiaofang's avatar lixiaofang
Browse files
Options

auto_vest

parent d23683fd
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
moment/views/consum.py
View file @ e0fd699b
...@@ -26,7 +26,7 @@ def kafka_consum(topic_name=None): ...@@ -26,7 +26,7 @@ def kafka_consum(topic_name=None):
consumser_obj.subscribe([topic_name, ]) consumser_obj.subscribe([topic_name, ])
try: try:
while True: while True:
msg_dict = consumser_obj.poll(timeout_ms=100, max_records=50) msg_dict = consumser_obj.poll(timeout_ms=100, max_records=30)
consumser_obj.commit_async() consumser_obj.commit_async()
for msg_key in msg_dict: for msg_key in msg_dict:
consume_msg = msg_dict[msg_key] consume_msg = msg_dict[msg_key]
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment