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 cloud-kafka-logger 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.3-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | fee4bcecbd86ec7c74c89b72f4a3a5a8eb17bbf6ee73b9e5a0032a731b750e73 |
|
MD5 | 399e4a09a8e8b1e597a5a632b17a0c64 |
|
BLAKE2b-256 | e06427d3ba397796b80684b61123cf3718b0f212c16a73a8dd6f4dfcd639f9de |