Skip to content

V
vest
Commit 091cdbf2 authored by 李小芳's avatar 李小芳
Browse files
Options

Merge branch 'poll_num' into 'master' 

add

See merge request !39
parents 4ca1a88d 2d951fac
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
moment/views/consum.py
View file @ 091cdbf2
...@@ -32,7 +32,7 @@ def kafka_consum(topic_name=None): ...@@ -32,7 +32,7 @@ def kafka_consum(topic_name=None):
try: try:
while True: while True:
begin = time.time() begin = time.time()
msg_dict = consumser_obj.poll(timeout_ms=10000, max_records=500) msg_dict = consumser_obj.poll(timeout_ms=10000, max_records=100)
for msg_value in msg_dict.values(): for msg_value in msg_dict.values():
for msg in msg_value: for msg in msg_value:
card_info = json.loads(str(msg.value, encoding="utf8")) card_info = json.loads(str(msg.value, encoding="utf8"))
......
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