Skip to content

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

修改消费者偏移量

parent 6a5e4f63
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 1 deletion
moment/views/consum.py
View file @ 07208257
......@@ -21,7 +21,7 @@ from follow.views.follow_fun import follow
def kafka_consum(topic_name=None):
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,auto_offset_reset='latest',bootstrap_servers=[settings.KAFKA_BROKER_LIST], enable_auto_commit=True,
auto_commit_interval_ms=1, group_id="vest")
consumser_obj.subscribe([topic_name, ])
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