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
Close
Hashes for Cloud_Kafka_Logger-0.1.5-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | e1e82e89dc441cb03e2e69042179b847ab4b53ac2b72e3c0879113acd25500d5 |
|
MD5 | 7007b26aecc5c83649fab5e8cf39f629 |
|
BLAKE2b-256 | c186abcc2fe55eb8c1dccec85828f12cd5dfe4bfd8b2a595aa9bf1da00155b52 |