Skip to content

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

auto_vest

parent 9bd778ea
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
moment/views/consum.py
View file @ 63f98156
...@@ -23,7 +23,7 @@ from kafka.structs import TopicPartition ...@@ -23,7 +23,7 @@ from kafka.structs import TopicPartition
def kafka_consum(topic_name=None): def kafka_consum(topic_name=None):
topic_name = settings.KAFKA_TOPIC_NAME if not topic_name else topic_name topic_name = settings.KAFKA_TOPIC_NAME if not topic_name else 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_commit_interval_ms=1, group_id="vest")
consumser_obj.subscribe([topic_name, ]) consumser_obj.subscribe([topic_name, ])
try: try:
......
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