Send Message To Cloud Kafka Topic
Project description
Kafka Package
This is a simple package which sends log messages to Cloud Kafka Topic.
Version
Python == 3.X
Dependency
confluent-kafka>=0.11.6
Installation
Run the following to install
pip install cloud-kafka-logger
Usage
import logging
from cloudKafkaLogger import 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)
This will be written into Kafka Topic
logger.info(json.dumps({"app_name": "Test_Python_App", "message": "Am logging from application"}))
Project details
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
Hashes for Cloud_Kafka_Logger-0.1.4-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 3003c14875285b15b4f38483a96c3ef4175ea6274ff33ace1bb56fa00cf0c66f |
|
MD5 | afd1193a6a225f873efa422b642f91c9 |
|
BLAKE2b-256 | 7f212695ab3728e79f88f16e002bf1f6460b5b7ab1015cdf8f29b04205da4b89 |