Skip to content

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

ad

parent cf891ce9
Show whitespace changes
Inline Side-by-side
Showing with 0 additions and 3 deletions
moment/views/consum.py
View file @ 6434219e
...@@ -23,9 +23,6 @@ from moment.views.process_time import judge_offset_partition_have_consum, judge_ ...@@ -23,9 +23,6 @@ from moment.views.process_time import judge_offset_partition_have_consum, judge_
import msgpack import msgpack
from kafka import TopicPartition from kafka import TopicPartition
clientid = "6"
def kafka_consum(topic_name=None): def kafka_consum(topic_name=None):
topic_name = settings.KAFKA_TOPIC_NAME topic_name = settings.KAFKA_TOPIC_NAME
consumser_obj = KafkaConsumer(topic_name, bootstrap_servers=settings.KAFKA_BROKER_LIST, enable_auto_commit=True, consumser_obj = KafkaConsumer(topic_name, bootstrap_servers=settings.KAFKA_BROKER_LIST, enable_auto_commit=True,
......
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