| rdudyala | b086cf3 | 2016-08-11 00:07:45 -0400 | [diff] [blame] | 1 | import kafka |
| 2 | import kafka_broker |
| 3 | from oslo_utils import netutils |
| 4 | import logging |
| 5 | |
| 6 | def read_notification_from_ceilometer_over_kafka(parse_target): |
| 7 | logging.info("Kafka target:%s",parse_target) |
| 8 | try : |
| 9 | kafka_publisher=kafka_broker.KafkaBrokerPublisher(parse_target) |
| 10 | for message in kafka_publisher.kafka_consumer: |
| 11 | #print message.value |
| 12 | logging.info("%s",message.value) |
| 13 | #print status |
| 14 | except Exception as e: |
| 15 | logging.error("Error in Kafka setup:%s ",e.__str__()) |
| 16 | |
| 17 | ceilometer_client="kafka://10.11.10.1:9092?topic=test" |
| 18 | logging.basicConfig(format='%(asctime)s %(filename)s %(levelname)s %(message)s',filename='kafka_client.log',level=logging.INFO) |
| 19 | parse_target=netutils.urlsplit(ceilometer_client) |
| 20 | read_notification_from_ceilometer_over_kafka(parse_target) |