Metadata-Version: 2.1
Name: Cloud_Kafka_Logger
Version: 0.1.5
Summary: Send Message To Cloud Kafka Topic
Home-page: UNKNOWN
Author: Ganesh
Author-email: ganeshmoorthy.va@gmail.com
License: UNKNOWN
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"}))
Platform: UNKNOWN
Classifier: Programming Language :: Python :: 3
Classifier: License :: OSI Approved :: MIT License
Classifier: Operating System :: OS Independent
Description-Content-Type: text/markdown
