auto_vest

moment/views/irrigation.py

@@ -16,7 +16,7 @@ from libs.error import logging_exception
 def vest_irrigation(card_id=0, card_type=None, card_user_id=None, create_time="", content_level=0, tag_names=[]):
     try:
 
-        producer = KafkaProducer(bootstrap_servers=[settings.KAFKA_BROKER_LIST])
+        producer = KafkaProducer(bootstrap_servers=settings.KAFKA_BROKER_LIST)
         logging.info("新数据进来了:%s" % card_id)
 
         topic = settings.KAFKA_TOPIC_NAME