官方文档：https://kafka-python.readthedocs.io/en/master/apidoc/KafkaConsumer.html
import threading
import os
import sys
from kafka import KafkaConsumer, TopicPartition, OffsetAndMetadata
from consumers.db_util import *
from consumers.json_dispose import *
from collections import OrderedDict
threads = []
