Hi ,
We are injecting events to our custom plugin in ceilometer.
The ceilometer pipeline.yaml is configured to publish these events over
kafka and udp, consuming these samples using kafka and udp clients.
KAFKA publisher:
-----------------------
When the events are sent continously ,we can see duplicate msg's are
recevied in kafka client.
From the log it seems ceilometer kafka publisher is failed to send
msg's,but still these msgs
are received by kafka server.So when kafka resends these failed msgs we
can see duplicate msg's
received in kafka client.
Please find the attached log for reference.
Is this know issue ?
Is their any workaround for this issue ?
UDP publisher:
No duplicate msg's issue seen here and it is working as expected.
With Best Regards
Raghunath Dudyala
Tata Consultancy Services Limited
Mailto: [email protected]
Website: http://www.tcs.com
____________________________________________
Experience certainty. IT Services
Business Solutions
Consulting
____________________________________________
=====-----=====-----=====
Notice: The information contained in this e-mail
message and/or attachments to it may contain
confidential or privileged information. If you are
not the intended recipient, any dissemination, use,
review, distribution, printing or copying of the
information contained in this e-mail message
and/or attachments to it are strictly prohibited. If
you have received this communication in error,
please notify us by reply e-mail or telephone and
immediately and permanently delete the message
and any attachments. Thank you
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
__________________________________________________________________________
OpenStack Development Mailing List (not for usage questions)
Unsubscribe: [email protected]?subject:unsubscribe
http://lists.openstack.org/cgi-bin/mailman/listinfo/openstack-dev
