python中的一个简单的kafka记录器。
kafka-logger的Python项目详细描述
##用于python的kafka logger
< P >为什么存在这种现象？有一个现有的Python包，可以通过卡夫卡将日志发送到LogSTASH， 但它有两个问题：
一。它建立在一个特定的python-kafka包之上，已经过时了， 这使得用户无法选择他们可以使用哪种卡夫卡。 2.它只使用python日志包中的默认日志格式， 这并不能提供很多有用的信息。
###安装
pip install kafka-logger
###用法
import logging import KafkaLoggingHandler logger = logging.getLogger(‘python-logstash-logger’) logger.setLevel(logging.INFO) log_producer = KafkaProducer(bootstrap_servers=KAFKA_BROKER) logger.addHandler(KafkaLoggingHandler(log_producer, ‘app-log’))
欢迎加入QQ群-->： 979659372
