2016-08-11 06:46:49.251 25048 DEBUG oslo_messaging._drivers.amqpdriver [-] received message msg_id: None reply to None __call__ /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:201
2016-08-11 06:46:49.255 25048 INFO ceilometer.network.ext_services.vcpe.notifications [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] SRIKANTH: Received VCPE notification: vcpe_id=vcpe-222-432
2016-08-11 06:46:49.263 25048 DEBUG oslo_messaging._drivers.amqpdriver [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] CAST unique_id: c0485a71dd7b454abc520ae36d99620c NOTIFY exchange 'ceilometer' topic 'metering.sample' _send /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:438
2016-08-11 06:46:49.272 25048 DEBUG kafka.conn [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Request 21: ProduceRequest_v0(required_acks=1, timeout=1000, topics=[(topic='ceilometer', partitions=[(partition=0, messages=['(offset=0, message=\'d\\x86\\x1a\\x80\\x00\\x00\\xff\\xff\\xff\\xff\\x00\\x00\\x02o{"counter_name": "vsg", "resource_id": "vcpe-222-432", "timestamp": "2016-08-11T06:46:49.248787", "counter_volume": 1, "user_id": "1e3ce043029547f1a61c1996d1a531a2", "message_signature": "c12644c101b3926dd743b64ed530417eac3788af52912f654a3ee12c564633b3", "resource_metadata": {"tenant_id": "3a397e70f64e4e40b69b6266c634d9d0", "host": "vcpe_publisher", "vcpe_id": "vcpe-222-432", "user_id": "1e3ce043029547f1a61c1996d1a531a2", "event_type": "vcpe"}, "source": "openstack", "counter_unit": "vsg", "project_id": "3a397e70f64e4e40b69b6266c634d9d0", "message_id": "60ef0722-5f8f-11e6-8c47-fa163e7e4feb", "counter_type": "gauge"}\')'])])]) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:49.278 25048 DEBUG oslo_messaging._drivers.amqpdriver [-] received message msg_id: None reply to None __call__ /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:201
2016-08-11 06:46:49.280 25048 INFO ceilometer.network.ext_services.vcpe.notifications [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] SRIKANTH: Received VCPE cache.size notification
2016-08-11 06:46:49.285 25048 DEBUG oslo_messaging._drivers.amqpdriver [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] CAST unique_id: 7dfe4cf5eabe431c811fe20b700a87d7 NOTIFY exchange 'ceilometer' topic 'metering.sample' _send /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:438
2016-08-11 06:46:49.293 25048 ERROR kafka.conn [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] Error sending ProduceRequest_v0(required_acks=1, timeout=1000, topics=[(topic='ceilometer', partitions=[(partition=0, messages=['(offset=0, message=\'\\\'}\\xc1\\x9a\\x00\\x00\\xff\\xff\\xff\\xff\\x00\\x00\\x02\\xa8{"counter_name": "vsg.dns.cache.size", "resource_id": "vcpe-222-432", "timestamp": "2016-08-11T06:46:49.255965", "counter_volume": 150.0, "user_id": "1e3ce043029547f1a61c1996d1a531a2", "message_signature": "ba9345526de6c2387c1ae9a09e2835ef649d176047d46d55422b0f0d09c2b637", "resource_metadata": {"user_id": "1e3ce043029547f1a61c1996d1a531a2", "event_type": "vcpe.dns.cache.size", "tenant_id": "3a397e70f64e4e40b69b6266c634d9d0", "host": "vcpe_publisher", "cache_size": 150, "vcpe_id": "vcpe-222-432"}, "source": "openstack", "counter_unit": "entries", "project_id": "3a397e70f64e4e40b69b6266c634d9d0", "message_id": "60f290e0-5f8f-11e6-ac9a-fa163e7e4feb", "counter_type": "gauge"}\')'])])]) to <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092>
2016-08-11 06:46:49.293 25048 ERROR kafka.conn Traceback (most recent call last):
2016-08-11 06:46:49.293 25048 ERROR kafka.conn   File "/usr/local/lib/python2.7/dist-packages/kafka/conn.py", line 530, in _send
2016-08-11 06:46:49.293 25048 ERROR kafka.conn     sent_bytes = self._sock.send(data[total_sent:])
2016-08-11 06:46:49.293 25048 ERROR kafka.conn error: [Errno 32] Broken pipe
2016-08-11 06:46:49.293 25048 ERROR kafka.conn
2016-08-11 06:46:49.297 25048 ERROR kafka.conn [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092>: socket disconnected
2016-08-11 06:46:49.305 25048 ERROR kafka.producer [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] Unable to send messages
2016-08-11 06:46:49.305 25048 ERROR kafka.producer Traceback (most recent call last):
2016-08-11 06:46:49.305 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/producer/base.py", line 422, in _send_messages
2016-08-11 06:46:49.305 25048 ERROR kafka.producer     fail_on_error=self.sync_fail_on_error
2016-08-11 06:46:49.305 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 648, in send_produce_request
2016-08-11 06:46:49.305 25048 ERROR kafka.producer     (not fail_on_error or not self._raise_on_response_error(resp))]
2016-08-11 06:46:49.305 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 404, in _raise_on_response_error
2016-08-11 06:46:49.305 25048 ERROR kafka.producer     raise resp
2016-08-11 06:46:49.305 25048 ERROR kafka.producer FailedPayloadsError: FailedPayloadsError
2016-08-11 06:46:49.305 25048 ERROR kafka.producer
2016-08-11 06:46:49.307 25048 ERROR kafka.producer [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] Unable to send messages
2016-08-11 06:46:49.307 25048 ERROR kafka.producer Traceback (most recent call last):
2016-08-11 06:46:49.307 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/producer/base.py", line 422, in _send_messages
2016-08-11 06:46:49.307 25048 ERROR kafka.producer     fail_on_error=self.sync_fail_on_error
2016-08-11 06:46:49.307 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 648, in send_produce_request
2016-08-11 06:46:49.307 25048 ERROR kafka.producer     (not fail_on_error or not self._raise_on_response_error(resp))]
2016-08-11 06:46:49.307 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 404, in _raise_on_response_error
2016-08-11 06:46:49.307 25048 ERROR kafka.producer     raise resp
2016-08-11 06:46:49.307 25048 ERROR kafka.producer FailedPayloadsError: FailedPayloadsError
2016-08-11 06:46:49.307 25048 ERROR kafka.producer
2016-08-11 06:46:49.308 25048 DEBUG kafka.conn [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] <BrokerConnection host=localhost/127.0.0.1 port=9092> Request 4: MetadataRequest_v0(topics=['ceilometer']) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:49.310 25048 DEBUG kafka.conn [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092>: creating new socket connect /usr/local/lib/python2.7/dist-packages/kafka/conn.py:208
2016-08-11 06:46:49.310 25048 ERROR kafka.conn [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] <BrokerConnection host=localhost/127.0.0.1 port=9092>: socket disconnected
2016-08-11 06:46:49.312 25048 ERROR kafka.client [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] Request failed: ConnectionError: socket disconnected
2016-08-11 06:46:49.313 25048 DEBUG kafka.conn [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092>: established TCP connection connect /usr/local/lib/python2.7/dist-packages/kafka/conn.py:277
2016-08-11 06:46:49.313 25048 DEBUG kafka.conn [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092>: established TCP connection connect /usr/local/lib/python2.7/dist-packages/kafka/conn.py:277
2016-08-11 06:46:49.315 25048 DEBUG kafka.conn [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Request 23: MetadataRequest_v0(topics=['ceilometer']) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:49.316 25048 DEBUG kafka.conn [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Request 24: MetadataRequest_v0(topics=['ceilometer']) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:49.316 25048 DEBUG kafka.conn [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Response 23: MetadataResponse_v0(brokers=[(node_id=0, host=u'127.0.0.1', port=9092)], topics=[(error_code=0, topic=u'ceilometer', partitions=[(error_code=0, partition=0, leader=0, replicas=[0], isr=[0])])]) _process_response /usr/local/lib/python2.7/dist-packages/kafka/conn.py:717
2016-08-11 06:46:49.317 25048 ERROR kafka.producer [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] Unable to send messages
2016-08-11 06:46:49.317 25048 ERROR kafka.producer Traceback (most recent call last):
2016-08-11 06:46:49.317 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/producer/base.py", line 422, in _send_messages
2016-08-11 06:46:49.317 25048 ERROR kafka.producer     fail_on_error=self.sync_fail_on_error
2016-08-11 06:46:49.317 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 644, in send_produce_request
2016-08-11 06:46:49.317 25048 ERROR kafka.producer     resps = self._send_broker_aware_request(payloads, encoder, decoder)
2016-08-11 06:46:49.317 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 234, in _send_broker_aware_request
2016-08-11 06:46:49.317 25048 ERROR kafka.producer     payloads_by_broker = self._payloads_by_broker(payloads)
2016-08-11 06:46:49.317 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 191, in _payloads_by_broker
2016-08-11 06:46:49.317 25048 ERROR kafka.producer     leader = self._get_leader_for_partition(payload.topic, payload.partition)
2016-08-11 06:46:49.317 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 111, in _get_leader_for_partition
2016-08-11 06:46:49.317 25048 ERROR kafka.producer     self.load_metadata_for_topics(topic)
2016-08-11 06:46:49.317 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 526, in load_metadata_for_topics
2016-08-11 06:46:49.317 25048 ERROR kafka.producer     resp = self.send_metadata_request(topics)
2016-08-11 06:46:49.317 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 591, in send_metadata_request
2016-08-11 06:46:49.317 25048 ERROR kafka.producer     return self._send_broker_unaware_request(payloads, encoder, decoder)
2016-08-11 06:46:49.317 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 177, in _send_broker_unaware_request
2016-08-11 06:46:49.317 25048 ERROR kafka.producer     conn.recv()
2016-08-11 06:46:49.317 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/conn.py", line 565, in recv
2016-08-11 06:46:49.317 25048 ERROR kafka.producer     assert not self._processing, 'Recursion not supported'
2016-08-11 06:46:49.317 25048 ERROR kafka.producer AssertionError: Recursion not supported
2016-08-11 06:46:49.317 25048 ERROR kafka.producer
2016-08-11 06:46:49.318 25048 DEBUG kafka.client [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] Updating broker metadata: [(0, u'127.0.0.1', 9092)] load_metadata_for_topics /usr/local/lib/python2.7/dist-packages/kafka/client.py:528
2016-08-11 06:46:49.320 25048 DEBUG kafka.conn [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] <BrokerConnection host=localhost/127.0.0.1 port=9092>: creating new socket connect /usr/local/lib/python2.7/dist-packages/kafka/conn.py:208
2016-08-11 06:46:49.320 25048 DEBUG kafka.client [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] Updating topic metadata: [u'ceilometer'] load_metadata_for_topics /usr/local/lib/python2.7/dist-packages/kafka/client.py:529
2016-08-11 06:46:49.325 25048 DEBUG kafka.conn [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Request 25: ProduceRequest_v0(required_acks=1, timeout=1000, topics=[(topic='ceilometer', partitions=[(partition=0, messages=['(offset=0, message=\'\\\'}\\xc1\\x9a\\x00\\x00\\xff\\xff\\xff\\xff\\x00\\x00\\x02\\xa8{"counter_name": "vsg.dns.cache.size", "resource_id": "vcpe-222-432", "timestamp": "2016-08-11T06:46:49.255965", "counter_volume": 150.0, "user_id": "1e3ce043029547f1a61c1996d1a531a2", "message_signature": "ba9345526de6c2387c1ae9a09e2835ef649d176047d46d55422b0f0d09c2b637", "resource_metadata": {"user_id": "1e3ce043029547f1a61c1996d1a531a2", "event_type": "vcpe.dns.cache.size", "tenant_id": "3a397e70f64e4e40b69b6266c634d9d0", "host": "vcpe_publisher", "cache_size": 150, "vcpe_id": "vcpe-222-432"}, "source": "openstack", "counter_unit": "entries", "project_id": "3a397e70f64e4e40b69b6266c634d9d0", "message_id": "60f290e0-5f8f-11e6-ac9a-fa163e7e4feb", "counter_type": "gauge"}\')'])])]) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:49.326 25048 DEBUG kafka.conn [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] <BrokerConnection host=localhost/127.0.0.1 port=9092>: established TCP connection connect /usr/local/lib/python2.7/dist-packages/kafka/conn.py:277
2016-08-11 06:46:49.327 25048 DEBUG kafka.conn [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Response 24: MetadataResponse_v0(brokers=[(node_id=0, host=u'127.0.0.1', port=9092)], topics=[(error_code=0, topic=u'ceilometer', partitions=[(error_code=0, partition=0, leader=0, replicas=[0], isr=[0])])]) _process_response /usr/local/lib/python2.7/dist-packages/kafka/conn.py:717
2016-08-11 06:46:49.327 25048 DEBUG kafka.conn [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] <BrokerConnection host=localhost/127.0.0.1 port=9092> Request 5: MetadataRequest_v0(topics=['ceilometer']) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:49.328 25048 DEBUG kafka.conn [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Response 25: ProduceResponse_v0(topics=[(topic=u'ceilometer', partitions=[(partition=0, error_code=0, offset=510)])]) _process_response /usr/local/lib/python2.7/dist-packages/kafka/conn.py:717
2016-08-11 06:46:49.329 25048 DEBUG kafka.conn [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] <BrokerConnection host=localhost/127.0.0.1 port=9092> Response 5: MetadataResponse_v0(brokers=[(node_id=0, host=u'127.0.0.1', port=9092)], topics=[(error_code=0, topic=u'ceilometer', partitions=[(error_code=0, partition=0, leader=0, replicas=[0], isr=[0])])]) _process_response /usr/local/lib/python2.7/dist-packages/kafka/conn.py:717
2016-08-11 06:46:49.330 25048 DEBUG ceilometer.publisher.udp [req-775522ad-360a-4d16-b0d5-c1749ca0caa3 - - - - -] Publishing sample {'counter_name': 'vsg.dns.cache.size', 'resource_id': u'vcpe-222-432', 'timestamp': u'2016-08-11T06:46:49.255965', 'counter_volume': 150.0, 'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'message_signature': 'ba9345526de6c2387c1ae9a09e2835ef649d176047d46d55422b0f0d09c2b637', 'resource_metadata': {u'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'event_type': u'vcpe.dns.cache.size', u'tenant_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'host': u'vcpe_publisher', u'cache_size': 150, u'vcpe_id': u'vcpe-222-432'}, 'source': 'openstack', 'counter_unit': 'entries', 'project_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'message_id': '60f290e0-5f8f-11e6-ac9a-fa163e7e4feb', 'counter_type': 'gauge'} over UDP to localhost:5004 publish_samples /usr/lib/python2.7/dist-packages/ceilometer/publisher/udp.py:62
2016-08-11 06:46:49.330 25048 DEBUG kafka.client [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] Updating broker metadata: [(0, u'127.0.0.1', 9092)] load_metadata_for_topics /usr/local/lib/python2.7/dist-packages/kafka/client.py:528
2016-08-11 06:46:49.331 25048 DEBUG kafka.client [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] Updating topic metadata: [u'ceilometer'] load_metadata_for_topics /usr/local/lib/python2.7/dist-packages/kafka/client.py:529
2016-08-11 06:46:49.335 25048 DEBUG kafka.conn [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Request 26: ProduceRequest_v0(required_acks=1, timeout=1000, topics=[(topic='ceilometer', partitions=[(partition=0, messages=['(offset=0, message=\'d\\x86\\x1a\\x80\\x00\\x00\\xff\\xff\\xff\\xff\\x00\\x00\\x02o{"counter_name": "vsg", "resource_id": "vcpe-222-432", "timestamp": "2016-08-11T06:46:49.248787", "counter_volume": 1, "user_id": "1e3ce043029547f1a61c1996d1a531a2", "message_signature": "c12644c101b3926dd743b64ed530417eac3788af52912f654a3ee12c564633b3", "resource_metadata": {"tenant_id": "3a397e70f64e4e40b69b6266c634d9d0", "host": "vcpe_publisher", "vcpe_id": "vcpe-222-432", "user_id": "1e3ce043029547f1a61c1996d1a531a2", "event_type": "vcpe"}, "source": "openstack", "counter_unit": "vsg", "project_id": "3a397e70f64e4e40b69b6266c634d9d0", "message_id": "60ef0722-5f8f-11e6-8c47-fa163e7e4feb", "counter_type": "gauge"}\')'])])]) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:49.336 25048 DEBUG kafka.conn [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Response 26: ProduceResponse_v0(topics=[(topic=u'ceilometer', partitions=[(partition=0, error_code=0, offset=511)])]) _process_response /usr/local/lib/python2.7/dist-packages/kafka/conn.py:717
2016-08-11 06:46:49.337 25048 DEBUG ceilometer.publisher.udp [req-1dfff14f-52b4-4814-9cf5-5e1a8629d370 - - - - -] Publishing sample {'counter_name': 'vsg', 'resource_id': u'vcpe-222-432', 'timestamp': u'2016-08-11T06:46:49.248787', 'counter_volume': 1, 'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'message_signature': 'c12644c101b3926dd743b64ed530417eac3788af52912f654a3ee12c564633b3', 'resource_metadata': {u'tenant_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'host': u'vcpe_publisher', u'vcpe_id': u'vcpe-222-432', u'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'event_type': u'vcpe'}, 'source': 'openstack', 'counter_unit': 'vsg', 'project_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'message_id': '60ef0722-5f8f-11e6-8c47-fa163e7e4feb', 'counter_type': 'gauge'} over UDP to localhost:5004 publish_samples /usr/lib/python2.7/dist-packages/ceilometer/publisher/udp.py:62
2016-08-11 06:46:50.784 25048 DEBUG oslo_messaging._drivers.amqpdriver [-] received message msg_id: None reply to None __call__ /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:201
2016-08-11 06:46:50.785 25048 INFO ceilometer.network.ext_services.vcpe.notifications [req-c8b58583-e8cc-49d2-b78c-252d80d20e4a - - - - -] SRIKANTH: Received VCPE notification: vcpe_id=vcpe-222-432
2016-08-11 06:46:50.787 25048 DEBUG oslo_messaging._drivers.amqpdriver [req-c8b58583-e8cc-49d2-b78c-252d80d20e4a - - - - -] CAST unique_id: 6c5cbc4ad5c14c56890527a3f6a21357 NOTIFY exchange 'ceilometer' topic 'metering.sample' _send /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:438
2016-08-11 06:46:50.800 25048 DEBUG kafka.conn [req-c8b58583-e8cc-49d2-b78c-252d80d20e4a - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Request 27: ProduceRequest_v0(required_acks=1, timeout=1000, topics=[(topic='ceilometer', partitions=[(partition=0, messages=['(offset=0, message=\'x\\xd6:\\xab\\x00\\x00\\xff\\xff\\xff\\xff\\x00\\x00\\x02o{"counter_name": "vsg", "resource_id": "vcpe-222-432", "timestamp": "2016-08-11T06:46:50.782971", "counter_volume": 1, "user_id": "1e3ce043029547f1a61c1996d1a531a2", "message_signature": "6a7b5063edbbd409459d1fa9e69ecc9ed270e489546d259461eb7397caa04bad", "resource_metadata": {"tenant_id": "3a397e70f64e4e40b69b6266c634d9d0", "host": "vcpe_publisher", "vcpe_id": "vcpe-222-432", "user_id": "1e3ce043029547f1a61c1996d1a531a2", "event_type": "vcpe"}, "source": "openstack", "counter_unit": "vsg", "project_id": "3a397e70f64e4e40b69b6266c634d9d0", "message_id": "61d7a8d8-5f8f-11e6-98ac-fa163e7e4feb", "counter_type": "gauge"}\')'])])]) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:50.803 25048 DEBUG oslo_messaging._drivers.amqpdriver [-] received message msg_id: None reply to None __call__ /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:201
2016-08-11 06:46:50.806 25048 INFO ceilometer.network.ext_services.vcpe.notifications [req-e0f95a5f-98f3-4f32-87e3-bd66a6b1eae3 - - - - -] SRIKANTH: Received VCPE cache.size notification
2016-08-11 06:46:50.807 25048 DEBUG oslo_messaging._drivers.amqpdriver [req-e0f95a5f-98f3-4f32-87e3-bd66a6b1eae3 - - - - -] CAST unique_id: 3aa4695833ec4e73b4634f6851bb69e2 NOTIFY exchange 'ceilometer' topic 'metering.sample' _send /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:438
2016-08-11 06:46:50.824 25048 DEBUG kafka.conn [req-c8b58583-e8cc-49d2-b78c-252d80d20e4a - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Response 27: ProduceResponse_v0(topics=[(topic=u'ceilometer', partitions=[(partition=0, error_code=0, offset=512)])]) _process_response /usr/local/lib/python2.7/dist-packages/kafka/conn.py:717
2016-08-11 06:46:50.827 25048 DEBUG ceilometer.publisher.udp [req-c8b58583-e8cc-49d2-b78c-252d80d20e4a - - - - -] Publishing sample {'counter_name': 'vsg', 'resource_id': u'vcpe-222-432', 'timestamp': u'2016-08-11T06:46:50.782971', 'counter_volume': 1, 'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'message_signature': '6a7b5063edbbd409459d1fa9e69ecc9ed270e489546d259461eb7397caa04bad', 'resource_metadata': {u'tenant_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'host': u'vcpe_publisher', u'vcpe_id': u'vcpe-222-432', u'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'event_type': u'vcpe'}, 'source': 'openstack', 'counter_unit': 'vsg', 'project_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'message_id': '61d7a8d8-5f8f-11e6-98ac-fa163e7e4feb', 'counter_type': 'gauge'} over UDP to localhost:5004 publish_samples /usr/lib/python2.7/dist-packages/ceilometer/publisher/udp.py:62
2016-08-11 06:46:50.839 25048 DEBUG kafka.conn [req-e0f95a5f-98f3-4f32-87e3-bd66a6b1eae3 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Request 28: ProduceRequest_v0(required_acks=1, timeout=1000, topics=[(topic='ceilometer', partitions=[(partition=0, messages=['(offset=0, message=\'\\x02\\xebv\\xa2\\x00\\x00\\xff\\xff\\xff\\xff\\x00\\x00\\x02\\xa8{"counter_name": "vsg.dns.cache.size", "resource_id": "vcpe-222-432", "timestamp": "2016-08-11T06:46:50.787451", "counter_volume": 150.0, "user_id": "1e3ce043029547f1a61c1996d1a531a2", "message_signature": "5ac995c257265c375d317f433bdc8df5329a22f2508b14edbabb7fa9d7ceaf4a", "resource_metadata": {"user_id": "1e3ce043029547f1a61c1996d1a531a2", "event_type": "vcpe.dns.cache.size", "tenant_id": "3a397e70f64e4e40b69b6266c634d9d0", "host": "vcpe_publisher", "cache_size": 150, "vcpe_id": "vcpe-222-432"}, "source": "openstack", "counter_unit": "entries", "project_id": "3a397e70f64e4e40b69b6266c634d9d0", "message_id": "61dacc7a-5f8f-11e6-8072-fa163e7e4feb", "counter_type": "gauge"}\')'])])]) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:50.840 25048 DEBUG kafka.conn [req-e0f95a5f-98f3-4f32-87e3-bd66a6b1eae3 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Response 28: ProduceResponse_v0(topics=[(topic=u'ceilometer', partitions=[(partition=0, error_code=0, offset=513)])]) _process_response /usr/local/lib/python2.7/dist-packages/kafka/conn.py:717
2016-08-11 06:46:50.841 25048 DEBUG ceilometer.publisher.udp [req-e0f95a5f-98f3-4f32-87e3-bd66a6b1eae3 - - - - -] Publishing sample {'counter_name': 'vsg.dns.cache.size', 'resource_id': u'vcpe-222-432', 'timestamp': u'2016-08-11T06:46:50.787451', 'counter_volume': 150.0, 'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'message_signature': '5ac995c257265c375d317f433bdc8df5329a22f2508b14edbabb7fa9d7ceaf4a', 'resource_metadata': {u'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'event_type': u'vcpe.dns.cache.size', u'tenant_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'host': u'vcpe_publisher', u'cache_size': 150, u'vcpe_id': u'vcpe-222-432'}, 'source': 'openstack', 'counter_unit': 'entries', 'project_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'message_id': '61dacc7a-5f8f-11e6-8072-fa163e7e4feb', 'counter_type': 'gauge'} over UDP to localhost:5004 publish_samples /usr/lib/python2.7/dist-packages/ceilometer/publisher/udp.py:62
2016-08-11 06:46:54.510 25048 DEBUG oslo_messaging._drivers.amqpdriver [-] received message msg_id: None reply to None __call__ /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:201
2016-08-11 06:46:54.511 25048 INFO ceilometer.network.ext_services.vcpe.notifications [req-65392498-91aa-4eee-a579-658cbbc03ca2 - - - - -] SRIKANTH: Received VCPE notification: vcpe_id=vcpe-222-432
2016-08-11 06:46:54.512 25048 DEBUG oslo_messaging._drivers.amqpdriver [req-65392498-91aa-4eee-a579-658cbbc03ca2 - - - - -] CAST unique_id: f3d796000ac8491380cd20150ef18607 NOTIFY exchange 'ceilometer' topic 'metering.sample' _send /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:438
2016-08-11 06:46:54.526 25048 DEBUG kafka.conn [req-65392498-91aa-4eee-a579-658cbbc03ca2 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Request 29: ProduceRequest_v0(required_acks=1, timeout=1000, topics=[(topic='ceilometer', partitions=[(partition=0, messages=['(offset=0, message=\'\\x80\\x1dqu\\x00\\x00\\xff\\xff\\xff\\xff\\x00\\x00\\x02o{"counter_name": "vsg", "resource_id": "vcpe-222-432", "timestamp": "2016-08-11T06:46:54.508658", "counter_volume": 1, "user_id": "1e3ce043029547f1a61c1996d1a531a2", "message_signature": "dfb1ccddb2e31c6b9bf4e29c19da96a1960450de8e6e93bb3e78bfff3d35c37c", "resource_metadata": {"tenant_id": "3a397e70f64e4e40b69b6266c634d9d0", "host": "vcpe_publisher", "vcpe_id": "vcpe-222-432", "user_id": "1e3ce043029547f1a61c1996d1a531a2", "event_type": "vcpe"}, "source": "openstack", "counter_unit": "vsg", "project_id": "3a397e70f64e4e40b69b6266c634d9d0", "message_id": "641023e6-5f8f-11e6-b9bf-fa163e7e4feb", "counter_type": "gauge"}\')'])])]) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:54.528 25048 DEBUG oslo_messaging._drivers.amqpdriver [-] received message msg_id: None reply to None __call__ /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:201
2016-08-11 06:46:54.531 25048 DEBUG kafka.conn [req-65392498-91aa-4eee-a579-658cbbc03ca2 - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Response 29: ProduceResponse_v0(topics=[(topic=u'ceilometer', partitions=[(partition=0, error_code=0, offset=514)])]) _process_response /usr/local/lib/python2.7/dist-packages/kafka/conn.py:717
2016-08-11 06:46:54.532 25048 INFO ceilometer.network.ext_services.vcpe.notifications [req-2e0a9c58-4fc7-41c1-b65a-a37d12c902ac - - - - -] SRIKANTH: Received VCPE cache.size notification
2016-08-11 06:46:54.536 25048 DEBUG oslo_messaging._drivers.amqpdriver [req-2e0a9c58-4fc7-41c1-b65a-a37d12c902ac - - - - -] CAST unique_id: ef2712a7d5054893a7d6831a4f5661c1 NOTIFY exchange 'ceilometer' topic 'metering.sample' _send /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:438
2016-08-11 06:46:54.549 25048 DEBUG kafka.conn [req-2e0a9c58-4fc7-41c1-b65a-a37d12c902ac - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Request 30: ProduceRequest_v0(required_acks=1, timeout=1000, topics=[(topic='ceilometer', partitions=[(partition=0, messages=['(offset=0, message=\'E\\xe6\\xdf\\xf5\\x00\\x00\\xff\\xff\\xff\\xff\\x00\\x00\\x02\\xa8{"counter_name": "vsg.dns.cache.size", "resource_id": "vcpe-222-432", "timestamp": "2016-08-11T06:46:54.513370", "counter_volume": 150.0, "user_id": "1e3ce043029547f1a61c1996d1a531a2", "message_signature": "8d4cf12afc746462e5c4305d94345e04d15a6ed19145989b5102b6a90e2e5470", "resource_metadata": {"user_id": "1e3ce043029547f1a61c1996d1a531a2", "event_type": "vcpe.dns.cache.size", "tenant_id": "3a397e70f64e4e40b69b6266c634d9d0", "host": "vcpe_publisher", "cache_size": 150, "vcpe_id": "vcpe-222-432"}, "source": "openstack", "counter_unit": "entries", "project_id": "3a397e70f64e4e40b69b6266c634d9d0", "message_id": "6413d162-5f8f-11e6-acec-fa163e7e4feb", "counter_type": "gauge"}\')'])])]) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:54.550 25048 DEBUG ceilometer.publisher.udp [req-65392498-91aa-4eee-a579-658cbbc03ca2 - - - - -] Publishing sample {'counter_name': 'vsg', 'resource_id': u'vcpe-222-432', 'timestamp': u'2016-08-11T06:46:54.508658', 'counter_volume': 1, 'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'message_signature': 'dfb1ccddb2e31c6b9bf4e29c19da96a1960450de8e6e93bb3e78bfff3d35c37c', 'resource_metadata': {u'tenant_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'host': u'vcpe_publisher', u'vcpe_id': u'vcpe-222-432', u'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'event_type': u'vcpe'}, 'source': 'openstack', 'counter_unit': 'vsg', 'project_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'message_id': '641023e6-5f8f-11e6-b9bf-fa163e7e4feb', 'counter_type': 'gauge'} over UDP to localhost:5004 publish_samples /usr/lib/python2.7/dist-packages/ceilometer/publisher/udp.py:62
2016-08-11 06:46:54.551 25048 DEBUG kafka.conn [req-2e0a9c58-4fc7-41c1-b65a-a37d12c902ac - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Response 30: ProduceResponse_v0(topics=[(topic=u'ceilometer', partitions=[(partition=0, error_code=0, offset=515)])]) _process_response /usr/local/lib/python2.7/dist-packages/kafka/conn.py:717
2016-08-11 06:46:54.555 25048 DEBUG ceilometer.publisher.udp [req-2e0a9c58-4fc7-41c1-b65a-a37d12c902ac - - - - -] Publishing sample {'counter_name': 'vsg.dns.cache.size', 'resource_id': u'vcpe-222-432', 'timestamp': u'2016-08-11T06:46:54.513370', 'counter_volume': 150.0, 'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'message_signature': '8d4cf12afc746462e5c4305d94345e04d15a6ed19145989b5102b6a90e2e5470', 'resource_metadata': {u'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'event_type': u'vcpe.dns.cache.size', u'tenant_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'host': u'vcpe_publisher', u'cache_size': 150, u'vcpe_id': u'vcpe-222-432'}, 'source': 'openstack', 'counter_unit': 'entries', 'project_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'message_id': '6413d162-5f8f-11e6-acec-fa163e7e4feb', 'counter_type': 'gauge'} over UDP to localhost:5004 publish_samples /usr/lib/python2.7/dist-packages/ceilometer/publisher/udp.py:62
2016-08-11 06:46:56.150 25048 DEBUG oslo_messaging._drivers.amqpdriver [-] received message msg_id: None reply to None __call__ /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:201
2016-08-11 06:46:56.151 25048 INFO ceilometer.network.ext_services.vcpe.notifications [req-55fece3e-98e9-49c1-bc2b-89218eb23d1e - - - - -] SRIKANTH: Received VCPE notification: vcpe_id=vcpe-222-432
2016-08-11 06:46:56.152 25048 DEBUG oslo_messaging._drivers.amqpdriver [req-55fece3e-98e9-49c1-bc2b-89218eb23d1e - - - - -] CAST unique_id: cab05a52d4e44ca8b83781fba9459857 NOTIFY exchange 'ceilometer' topic 'metering.sample' _send /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:438
2016-08-11 06:46:56.163 25048 DEBUG kafka.conn [req-55fece3e-98e9-49c1-bc2b-89218eb23d1e - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Request 31: ProduceRequest_v0(required_acks=1, timeout=1000, topics=[(topic='ceilometer', partitions=[(partition=0, messages=['(offset=0, message=\'\\xa0\\xd4R\\xfa\\x00\\x00\\xff\\xff\\xff\\xff\\x00\\x00\\x02o{"counter_name": "vsg", "resource_id": "vcpe-222-432", "timestamp": "2016-08-11T06:46:56.148930", "counter_volume": 1, "user_id": "1e3ce043029547f1a61c1996d1a531a2", "message_signature": "0d4c094af85ae6d217eba0f9797e5be9752e54a4ecafade2177cc2fa7cb08b8c", "resource_metadata": {"tenant_id": "3a397e70f64e4e40b69b6266c634d9d0", "host": "vcpe_publisher", "vcpe_id": "vcpe-222-432", "user_id": "1e3ce043029547f1a61c1996d1a531a2", "event_type": "vcpe"}, "source": "openstack", "counter_unit": "vsg", "project_id": "3a397e70f64e4e40b69b6266c634d9d0", "message_id": "650a5d7a-5f8f-11e6-9768-fa163e7e4feb", "counter_type": "gauge"}\')'])])]) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:56.165 25048 DEBUG oslo_messaging._drivers.amqpdriver [-] received message msg_id: None reply to None __call__ /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:201
2016-08-11 06:46:56.169 25048 INFO ceilometer.network.ext_services.vcpe.notifications [req-e97efc5d-d651-4cea-a635-fc06d3eef83b - - - - -] SRIKANTH: Received VCPE cache.size notification
2016-08-11 06:46:56.171 25048 DEBUG oslo_messaging._drivers.amqpdriver [req-e97efc5d-d651-4cea-a635-fc06d3eef83b - - - - -] CAST unique_id: 6781ffe147824dffb6e14200ff77616c NOTIFY exchange 'ceilometer' topic 'metering.sample' _send /usr/lib/python2.7/dist-packages/oslo_messaging/_drivers/amqpdriver.py:438
2016-08-11 06:46:56.181 25048 DEBUG kafka.conn [req-e97efc5d-d651-4cea-a635-fc06d3eef83b - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Request 32: ProduceRequest_v0(required_acks=1, timeout=1000, topics=[(topic='ceilometer', partitions=[(partition=0, messages=['(offset=0, message=\'\\x87\\x9fh\\x90\\x00\\x00\\xff\\xff\\xff\\xff\\x00\\x00\\x02\\xa8{"counter_name": "vsg.dns.cache.size", "resource_id": "vcpe-222-432", "timestamp": "2016-08-11T06:46:56.153385", "counter_volume": 150.0, "user_id": "1e3ce043029547f1a61c1996d1a531a2", "message_signature": "3c13c6c02cd9acfe7cc486720dd215837868a5f2def224919811f83454d8d103", "resource_metadata": {"user_id": "1e3ce043029547f1a61c1996d1a531a2", "event_type": "vcpe.dns.cache.size", "tenant_id": "3a397e70f64e4e40b69b6266c634d9d0", "host": "vcpe_publisher", "cache_size": 150, "vcpe_id": "vcpe-222-432"}, "source": "openstack", "counter_unit": "entries", "project_id": "3a397e70f64e4e40b69b6266c634d9d0", "message_id": "650d361c-5f8f-11e6-8d16-fa163e7e4feb", "counter_type": "gauge"}\')'])])]) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:56.182 25048 DEBUG kafka.conn [req-55fece3e-98e9-49c1-bc2b-89218eb23d1e - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Response 31: ProduceResponse_v0(topics=[(topic=u'ceilometer', partitions=[(partition=0, error_code=0, offset=516)])]) _process_response /usr/local/lib/python2.7/dist-packages/kafka/conn.py:717
2016-08-11 06:46:56.186 25048 ERROR kafka.producer [req-e97efc5d-d651-4cea-a635-fc06d3eef83b - - - - -] Unable to send messages
2016-08-11 06:46:56.186 25048 ERROR kafka.producer Traceback (most recent call last):
2016-08-11 06:46:56.186 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/producer/base.py", line 422, in _send_messages
2016-08-11 06:46:56.186 25048 ERROR kafka.producer     fail_on_error=self.sync_fail_on_error
2016-08-11 06:46:56.186 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 644, in send_produce_request
2016-08-11 06:46:56.186 25048 ERROR kafka.producer     resps = self._send_broker_aware_request(payloads, encoder, decoder)
2016-08-11 06:46:56.186 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/client.py", line 286, in _send_broker_aware_request
2016-08-11 06:46:56.186 25048 ERROR kafka.producer     conn.recv()
2016-08-11 06:46:56.186 25048 ERROR kafka.producer   File "/usr/local/lib/python2.7/dist-packages/kafka/conn.py", line 565, in recv
2016-08-11 06:46:56.186 25048 ERROR kafka.producer     assert not self._processing, 'Recursion not supported'
2016-08-11 06:46:56.186 25048 ERROR kafka.producer AssertionError: Recursion not supported
2016-08-11 06:46:56.186 25048 ERROR kafka.producer
2016-08-11 06:46:56.187 25048 DEBUG ceilometer.publisher.udp [req-55fece3e-98e9-49c1-bc2b-89218eb23d1e - - - - -] Publishing sample {'counter_name': 'vsg', 'resource_id': u'vcpe-222-432', 'timestamp': u'2016-08-11T06:46:56.148930', 'counter_volume': 1, 'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'message_signature': '0d4c094af85ae6d217eba0f9797e5be9752e54a4ecafade2177cc2fa7cb08b8c', 'resource_metadata': {u'tenant_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'host': u'vcpe_publisher', u'vcpe_id': u'vcpe-222-432', u'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'event_type': u'vcpe'}, 'source': 'openstack', 'counter_unit': 'vsg', 'project_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'message_id': '650a5d7a-5f8f-11e6-9768-fa163e7e4feb', 'counter_type': 'gauge'} over UDP to localhost:5004 publish_samples /usr/lib/python2.7/dist-packages/ceilometer/publisher/udp.py:62
2016-08-11 06:46:56.195 25048 DEBUG kafka.conn [req-e97efc5d-d651-4cea-a635-fc06d3eef83b - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Request 33: ProduceRequest_v0(required_acks=1, timeout=1000, topics=[(topic='ceilometer', partitions=[(partition=0, messages=['(offset=0, message=\'\\x87\\x9fh\\x90\\x00\\x00\\xff\\xff\\xff\\xff\\x00\\x00\\x02\\xa8{"counter_name": "vsg.dns.cache.size", "resource_id": "vcpe-222-432", "timestamp": "2016-08-11T06:46:56.153385", "counter_volume": 150.0, "user_id": "1e3ce043029547f1a61c1996d1a531a2", "message_signature": "3c13c6c02cd9acfe7cc486720dd215837868a5f2def224919811f83454d8d103", "resource_metadata": {"user_id": "1e3ce043029547f1a61c1996d1a531a2", "event_type": "vcpe.dns.cache.size", "tenant_id": "3a397e70f64e4e40b69b6266c634d9d0", "host": "vcpe_publisher", "cache_size": 150, "vcpe_id": "vcpe-222-432"}, "source": "openstack", "counter_unit": "entries", "project_id": "3a397e70f64e4e40b69b6266c634d9d0", "message_id": "650d361c-5f8f-11e6-8d16-fa163e7e4feb", "counter_type": "gauge"}\')'])])]) _send /usr/local/lib/python2.7/dist-packages/kafka/conn.py:541
2016-08-11 06:46:56.196 25048 DEBUG kafka.conn [req-e97efc5d-d651-4cea-a635-fc06d3eef83b - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Response 32: ProduceResponse_v0(topics=[(topic=u'ceilometer', partitions=[(partition=0, error_code=0, offset=517)])]) _process_response /usr/local/lib/python2.7/dist-packages/kafka/conn.py:717
2016-08-11 06:46:56.198 25048 DEBUG kafka.conn [req-e97efc5d-d651-4cea-a635-fc06d3eef83b - - - - -] <BrokerConnection host=127.0.0.1/127.0.0.1 port=9092> Response 33: ProduceResponse_v0(topics=[(topic=u'ceilometer', partitions=[(partition=0, error_code=0, offset=518)])]) _process_response /usr/local/lib/python2.7/dist-packages/kafka/conn.py:717
2016-08-11 06:46:56.198 25048 DEBUG ceilometer.publisher.udp [req-e97efc5d-d651-4cea-a635-fc06d3eef83b - - - - -] Publishing sample {'counter_name': 'vsg.dns.cache.size', 'resource_id': u'vcpe-222-432', 'timestamp': u'2016-08-11T06:46:56.153385', 'counter_volume': 150.0, 'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'message_signature': '3c13c6c02cd9acfe7cc486720dd215837868a5f2def224919811f83454d8d103', 'resource_metadata': {u'user_id': u'1e3ce043029547f1a61c1996d1a531a2', 'event_type': u'vcpe.dns.cache.size', u'tenant_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'host': u'vcpe_publisher', u'cache_size': 150, u'vcpe_id': u'vcpe-222-432'}, 'source': 'openstack', 'counter_unit': 'entries', 'project_id': u'3a397e70f64e4e40b69b6266c634d9d0', 'message_id': '650d361c-5f8f-11e6-8d16-fa163e7e4feb', 'counter_type': 'gauge'} over UDP to localhost:5004 publish_samples /usr/lib/python2.7/dist-packages/ceilometer/publisher/udp.py:62