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.7-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 0838793451cde0932147c7d0603488bfd01b6149016b1a20dc6ea4e682233fab |
|
MD5 | a64ca4fc25b3798f21e2825beab94395 |
|
BLAKE2b-256 | 9c348817488cd1010847a6aaa305faa2a0ccbbb4a92c2d81fc08ccf47dc0c8b1 |