Skip to content

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

del log

parent c42b6b24
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
moment/views/consum.py
View file @ 62c3ad1e
...@@ -27,7 +27,7 @@ from kafka import TopicPartition ...@@ -27,7 +27,7 @@ from kafka import TopicPartition
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,
auto_commit_interval_ms=1, group_id="vest", auto_offset_reset='earliest') group_id="vest", auto_offset_reset='earliest')
consumser_obj.subscribe([topic_name, ]) consumser_obj.subscribe([topic_name, ])
# partition = TopicPartition(topic_name, int(clientid)) # partition = TopicPartition(topic_name, int(clientid))
......
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