向云端发送消息Kafka主题
Cloud-Kafka-Logger的Python项目详细描述
卡夫卡套餐
这是一个简单的包，它向cloud kafka主题发送日志消息。
版本
python==3.x
依赖性
合流kafka>；=0.11.6
安装
运行以下命令安装
pip安装云kafka记录器
用法
导入日志记录
从cloudkafkalogger导入kafkahandler
logger=logging.getlogger（name）
logger.setlevel（logging.debug）
conf={
'bootstrap.servers': 'cloud-kafka-servers',
'session.timeout.ms': 6000,
'default.topic.config': {'auto.offset.reset': 'smallest'},
'security.protocol': 'your-protocol',
'sasl.mechanisms': 'your-mechanisms',
'sasl.username': 'your-username',
'sasl.password': 'your-password'
}
kh=kafkahandler（conf=conf，topic='your-topic'）
logger.addhandler（kh）
这将写入卡夫卡主题
logger.info（json.dumps（{“app_name”：“test_python_app”，“message”：“am logging from application”}））
欢迎加入QQ群-->： 979659372
