Last active
January 19, 2017 10:55
-
-
Save siddharth96/58c9326cd2edd090c47a6641ee76f317 to your computer and use it in GitHub Desktop.
PyKafka logs with use_rdkafka=True
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [2017-01-19 14:47:43,002 DEBUG T:MainThread F:_debug] | Worker: Starting Pool | |
| [2017-01-19 14:47:43,010 DEBUG T:MainThread F:start] ^-- substep ok | |
| [2017-01-19 14:47:43,011 DEBUG T:MainThread F:_debug] | Worker: Starting Consumer | |
| [2017-01-19 14:47:43,011 DEBUG T:MainThread F:_debug] | Consumer: Starting Connection | |
| [2017-01-19 14:47:43,017 INFO T:MainThread F:start] Connected to pykafka://guest:guest@<ip>:2181//,pykafka://guest:guest@<ip>:2181//,pykafka://guest:guest@<ip>:2181// | |
| [2017-01-19 14:47:43,017 DEBUG T:MainThread F:start] ^-- substep ok | |
| [2017-01-19 14:47:43,017 DEBUG T:MainThread F:_debug] | Consumer: Starting Events | |
| [2017-01-19 14:47:43,021 DEBUG T:MainThread F:start] ^-- substep ok | |
| [2017-01-19 14:47:43,021 DEBUG T:MainThread F:_debug] | Consumer: Starting Tasks | |
| [2017-01-19 14:47:43,027 DEBUG T:MainThread F:update] Updating cluster, attempt 1/3 | |
| [2017-01-19 14:47:43,029 INFO T:Thread-8 F:_connect] Connecting to <ip>:2181 | |
| [2017-01-19 14:47:43,031 DEBUG T:Thread-8 F:log] Sending request(xid=None): Connect(protocol_version=0, last_zxid_seen=0, time_out=30000, session_id=0, passwd='\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00', read_only=None) | |
| [2017-01-19 14:47:43,034 INFO T:Thread-8 F:_session_callback] Zookeeper connection established, state: CONNECTED | |
| [2017-01-19 14:47:43,037 DEBUG T:Thread-8 F:log] Sending request(xid=1): GetChildren(path='/brokers/ids', watcher=None) | |
| [2017-01-19 14:47:43,038 DEBUG T:Thread-8 F:_read_response] Received response(xid=1): [u'0', u'1', u'2'] | |
| [2017-01-19 14:47:43,038 DEBUG T:Thread-8 F:log] Sending request(xid=2): GetData(path='/brokers/ids/0', watcher=None) | |
| [2017-01-19 14:47:43,040 DEBUG T:Thread-8 F:_read_response] Received response(xid=2): ('{"jmx_port":9090,"timestamp":"1483357467458","endpoints":["PLAINTEXT://ip-<something>.ap-southeast-1.compute.internal:9092"],"host":"ip-<something>.ap-southeast-1.compute.interna | |
| l","version":3,"port":9092}', ZnodeStat(czxid=8589934746, mzxid=8589934746, ctime=1483357467461, mtime=1483357467461, version=0, cversion=0, aversion=0, ephemeralOwner=169270881677082626, dataLength=211, numChildren=0, pzxid=8589934746)) | |
| [2017-01-19 14:47:43,040 DEBUG T:Thread-8 F:log] Sending request(xid=3): GetData(path='/brokers/ids/1', watcher=None) | |
| [2017-01-19 14:47:43,042 DEBUG T:Thread-8 F:_read_response] Received response(xid=3): ('{"jmx_port":9090,"timestamp":"1483357470027","endpoints":["PLAINTEXT://ip-<something>.ap-southeast-1.compute.internal:9092"],"host":"ip-<something>.ap-southeast-1.compute.internal","vers | |
| ion":3,"port":9092}', ZnodeStat(czxid=8589934750, mzxid=8589934750, ctime=1483357470046, mtime=1483357470046, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776925189, dataLength=203, numChildren=0, pzxid=8589934750)) | |
| [2017-01-19 14:47:43,042 DEBUG T:Thread-8 F:log] Sending request(xid=4): GetData(path='/brokers/ids/2', watcher=None) | |
| [2017-01-19 14:47:43,044 DEBUG T:Thread-8 F:_read_response] Received response(xid=4): ('{"jmx_port":9090,"timestamp":"1483357565976","endpoints":["PLAINTEXT://ip-<something>.ap-southeast-1.compute.internal:9092"],"host":"ip-<something>.ap-southeast-1.compute.internal" | |
| ,"version":3,"port":9092}', ZnodeStat(czxid=8589934808, mzxid=8589934808, ctime=1483357566027, mtime=1483357566027, version=0, cversion=0, aversion=0, ephemeralOwner=169270881677082627, dataLength=209, numChildren=0, pzxid=8589934808)) | |
| [2017-01-19 14:47:43,044 DEBUG T:Thread-8 F:log] Sending request(xid=5): Close() | |
| [2017-01-19 14:47:43,047 INFO T:Thread-8 F:_connect_attempt] Closing connection to <ip>:2181 | |
| [2017-01-19 14:47:43,047 INFO T:Thread-8 F:_session_callback] Zookeeper session lost, state: CLOSED | |
| [2017-01-19 14:47:43,048 DEBUG T:MainThread F:connect] Connecting to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,058 DEBUG T:MainThread F:connect] Successfully connected to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,064 INFO T:MainThread F:stop] RequestHandler.stop: about to flush requests queue | |
| [2017-01-19 14:47:43,064 INFO T:MainThread F:_update_brokers] Discovered 3 brokers | |
| [2017-01-19 14:47:43,064 DEBUG T:MainThread F:_update_brokers] Discovered broker id 0: ip-<something>.ap-southeast-1.compute.internal:9092 [498/632] | |
| [2017-01-19 14:47:43,065 DEBUG T:MainThread F:connect] Connecting to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,066 DEBUG T:MainThread F:connect] Successfully connected to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,066 DEBUG T:MainThread F:_update_brokers] Discovered broker id 1: ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,067 DEBUG T:MainThread F:connect] Connecting to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,069 DEBUG T:MainThread F:connect] Successfully connected to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,070 DEBUG T:MainThread F:_update_brokers] Discovered broker id 2: ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,071 DEBUG T:MainThread F:connect] Connecting to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,073 DEBUG T:MainThread F:connect] Successfully connected to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,073 INFO T:MainThread F:_update_topics] Discovered 16 topics | |
| [2017-01-19 14:47:43,074 DEBUG T:MainThread F:_update_topics] Discovered topic 'adsimpressionqueue' | |
| [2017-01-19 14:47:43,074 DEBUG T:MainThread F:_update_topics] Discovered topic 'loadlivepsrdatatoelasticsearch' | |
| [2017-01-19 14:47:43,074 DEBUG T:MainThread F:_update_topics] Discovered topic 'celeryip-<something>.celery.pidbox' | |
| [2017-01-19 14:47:43,074 DEBUG T:MainThread F:_update_topics] Discovered topic 'celeryip-<something>.celery.pidbox' | |
| [2017-01-19 14:47:43,074 DEBUG T:MainThread F:_update_topics] Discovered topic 'ParamQueue' | |
| [2017-01-19 14:47:43,075 DEBUG T:MainThread F:_update_topics] Discovered topic 'celery' | |
| [2017-01-19 14:47:43,075 DEBUG T:MainThread F:_update_topics] Discovered topic 'FetchAndUpdateSmartBasketFromLMA' | |
| [2017-01-19 14:47:43,075 DEBUG T:MainThread F:_update_topics] Discovered topic 'celeryip-<something>.celery.pidbox' | |
| [2017-01-19 14:47:43,075 DEBUG T:MainThread F:_update_topics] Discovered topic 'reportqueue' | |
| [2017-01-19 14:47:43,075 DEBUG T:MainThread F:_update_topics] Discovered topic 'celeryip-<something>.celery.pidbox' | |
| [2017-01-19 14:47:43,075 DEBUG T:MainThread F:_update_topics] Discovered topic 'membercommunicationqueue' | |
| [2017-01-19 14:47:43,076 DEBUG T:MainThread F:_update_topics] Discovered topic 'updateTopMenuCacheQueue' | |
| [2017-01-19 14:47:43,076 DEBUG T:MainThread F:_update_topics] Discovered topic 'celeryip-<something>.celery.pidbox' | |
| [2017-01-19 14:47:43,076 DEBUG T:MainThread F:_update_topics] Discovered topic 'relatedsearchqueue' | |
| [2017-01-19 14:47:43,076 DEBUG T:MainThread F:_update_topics] Discovered topic 'celeryip-<something>.celery.pidbox' | |
| [2017-01-19 14:47:43,078 INFO T:Thread-11 F:_connect] Connecting to <ip>:2181 | |
| [2017-01-19 14:47:43,079 DEBUG T:Thread-11 F:log] Sending request(xid=None): Connect(protocol_version=0, last_zxid_seen=0, time_out=30000, session_id=0, passwd='\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00', read_only=None) | |
| [2017-01-19 14:47:43,082 INFO T:Thread-11 F:_session_callback] Zookeeper connection established, state: CONNECTED | |
| [2017-01-19 14:47:43,085 DEBUG T:Thread-11 F:log] Sending request(xid=1): GetChildren(path='/brokers/ids', watcher=None) | |
| [2017-01-19 14:47:43,087 DEBUG T:Thread-11 F:_read_response] Received response(xid=1): [u'0', u'1', u'2'] | |
| [2017-01-19 14:47:43,087 DEBUG T:Thread-11 F:log] Sending request(xid=2): GetData(path='/brokers/ids/0', watcher=None) | |
| [2017-01-19 14:47:43,092 DEBUG T:Thread-11 F:_read_response] Received response(xid=2): ('{"jmx_port":9090,"timestamp":"1483357467458","endpoints":["PLAINTEXT://ip-<something>.ap-southeast-1.compute.internal:9092"],"host":"ip-<something>.ap-southeast-1.compute.intern | |
| al","version":3,"port":9092}', ZnodeStat(czxid=8589934746, mzxid=8589934746, ctime=1483357467461, mtime=1483357467461, version=0, cversion=0, aversion=0, ephemeralOwner=169270881677082626, dataLength=211, numChildren=0, pzxid=8589934746)) | |
| [2017-01-19 14:47:43,097 DEBUG T:Thread-11 F:log] Sending request(xid=3): GetData(path='/brokers/ids/1', watcher=None) | |
| [2017-01-19 14:47:43,098 DEBUG T:Thread-11 F:_read_response] Received response(xid=3): ('{"jmx_port":9090,"timestamp":"1483357470027","endpoints":["PLAINTEXT://ip-<something>.ap-southeast-1.compute.internal:9092"],"host":"ip-<something>.ap-southeast-1.compute.internal","ver | |
| sion":3,"port":9092}', ZnodeStat(czxid=8589934750, mzxid=8589934750, ctime=1483357470046, mtime=1483357470046, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776925189, dataLength=203, numChildren=0, pzxid=8589934750)) | |
| [2017-01-19 14:47:43,102 DEBUG T:Thread-11 F:log] Sending request(xid=4): GetData(path='/brokers/ids/2', watcher=None) | |
| [2017-01-19 14:47:43,105 DEBUG T:Thread-11 F:_read_response] Received response(xid=4): ('{"jmx_port":9090,"timestamp":"1483357565976","endpoints":["PLAINTEXT://ip-<something>.ap-southeast-1.compute.internal:9092"],"host":"ip-<something>.ap-southeast-1.compute.internal | |
| ","version":3,"port":9092}', ZnodeStat(czxid=8589934808, mzxid=8589934808, ctime=1483357566027, mtime=1483357566027, version=0, cversion=0, aversion=0, ephemeralOwner=169270881677082627, dataLength=209, numChildren=0, pzxid=8589934808)) | |
| [2017-01-19 14:47:43,106 DEBUG T:Thread-11 F:log] Sending request(xid=5): Close() | |
| [2017-01-19 14:47:43,109 INFO T:Thread-11 F:_connect_attempt] Closing connection to <ip>:2181 | |
| [2017-01-19 14:47:43,109 INFO T:Thread-11 F:_session_callback] Zookeeper session lost, state: CLOSED | |
| [2017-01-19 14:47:43,111 DEBUG T:MainThread F:connect] Connecting to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,112 DEBUG T:MainThread F:connect] Successfully connected to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,113 INFO T:MainThread F:stop] RequestHandler.stop: about to flush requests queue | |
| [2017-01-19 14:47:43,113 INFO T:MainThread F:update] Adding 8 partitions | |
| [2017-01-19 14:47:43,113 DEBUG T:MainThread F:update] Adding partition adsimpressionqueue/0 | |
| [2017-01-19 14:47:43,113 DEBUG T:MainThread F:update] Adding partition adsimpressionqueue/1 | |
| [2017-01-19 14:47:43,114 DEBUG T:MainThread F:update] Adding partition adsimpressionqueue/2 | |
| [2017-01-19 14:47:43,114 DEBUG T:MainThread F:update] Adding partition adsimpressionqueue/3 | |
| [2017-01-19 14:47:43,114 DEBUG T:MainThread F:update] Adding partition adsimpressionqueue/4 | |
| [2017-01-19 14:47:43,114 DEBUG T:MainThread F:update] Adding partition adsimpressionqueue/5 | |
| [2017-01-19 14:47:43,114 DEBUG T:MainThread F:update] Adding partition adsimpressionqueue/6 | |
| [2017-01-19 14:47:43,114 DEBUG T:MainThread F:update] Adding partition adsimpressionqueue/7 | |
| [2017-01-19 14:47:43,223 DEBUG T:MainThread F:start] ^-- substep ok | |
| [2017-01-19 14:47:43,224 DEBUG T:MainThread F:_debug] | Consumer: Starting Control | |
| [2017-01-19 14:47:43,224 DEBUG T:MainThread F:update] Updating cluster, attempt 1/3 | |
| [2017-01-19 14:47:43,227 INFO T:Thread-15 F:_connect] Connecting to <ip>:2181 | |
| [2017-01-19 14:47:43,231 DEBUG T:Thread-15 F:log] Sending request(xid=None): Connect(protocol_version=0, last_zxid_seen=0, time_out=30000, session_id=0, passwd='\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00', read_only=None) | |
| [2017-01-19 14:47:43,238 INFO T:Thread-15 F:_session_callback] Zookeeper connection established, state: CONNECTED | |
| [2017-01-19 14:47:43,240 DEBUG T:Thread-15 F:log] Sending request(xid=1): GetChildren(path='/brokers/ids', watcher=None) | |
| [2017-01-19 14:47:43,241 DEBUG T:Thread-15 F:_read_response] Received response(xid=1): [u'0', u'1', u'2'] | |
| [2017-01-19 14:47:43,242 DEBUG T:Thread-15 F:log] Sending request(xid=2): GetData(path='/brokers/ids/0', watcher=None) | |
| [2017-01-19 14:47:43,243 DEBUG T:Thread-15 F:_read_response] Received response(xid=2): ('{"jmx_port":9090,"timestamp":"1483357467458","endpoints":["PLAINTEXT://ip-<something>.ap-southeast-1.compute.internal:9092"],"host":"ip-<something>.ap-southeast-1.compute.intern | |
| al","version":3,"port":9092}', ZnodeStat(czxid=8589934746, mzxid=8589934746, ctime=1483357467461, mtime=1483357467461, version=0, cversion=0, aversion=0, ephemeralOwner=169270881677082626, dataLength=211, numChildren=0, pzxid=8589934746)) | |
| [2017-01-19 14:47:43,243 DEBUG T:Thread-15 F:log] Sending request(xid=3): GetData(path='/brokers/ids/1', watcher=None) | |
| [2017-01-19 14:47:43,245 DEBUG T:Thread-15 F:_read_response] Received response(xid=3): ('{"jmx_port":9090,"timestamp":"1483357470027","endpoints":["PLAINTEXT://ip-<something>.ap-southeast-1.compute.internal:9092"],"host":"ip-<something>.ap-southeast-1.compute.internal","ver | |
| sion":3,"port":9092}', ZnodeStat(czxid=8589934750, mzxid=8589934750, ctime=1483357470046, mtime=1483357470046, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776925189, dataLength=203, numChildren=0, pzxid=8589934750)) | |
| [2017-01-19 14:47:43,245 DEBUG T:Thread-15 F:log] Sending request(xid=4): GetData(path='/brokers/ids/2', watcher=None) | |
| [2017-01-19 14:47:43,247 DEBUG T:Thread-15 F:_read_response] Received response(xid=4): ('{"jmx_port":9090,"timestamp":"1483357565976","endpoints":["PLAINTEXT://ip-<something>.ap-southeast-1.compute.internal:9092"],"host":"ip-<something>.ap-southeast-1.compute.internal | |
| ","version":3,"port":9092}', ZnodeStat(czxid=8589934808, mzxid=8589934808, ctime=1483357566027, mtime=1483357566027, version=0, cversion=0, aversion=0, ephemeralOwner=169270881677082627, dataLength=209, numChildren=0, pzxid=8589934808)) | |
| [2017-01-19 14:47:43,248 DEBUG T:Thread-15 F:log] Sending request(xid=5): Close() | |
| [2017-01-19 14:47:43,250 INFO T:Thread-15 F:_connect_attempt] Closing connection to <ip>:2181 | |
| [2017-01-19 14:47:43,250 INFO T:Thread-15 F:_session_callback] Zookeeper session lost, state: CLOSED | |
| [2017-01-19 14:47:43,252 DEBUG T:MainThread F:connect] Connecting to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,253 DEBUG T:MainThread F:connect] Successfully connected to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,261 INFO T:MainThread F:stop] RequestHandler.stop: about to flush requests queue | |
| [2017-01-19 14:47:43,262 INFO T:MainThread F:_update_brokers] Discovered 3 brokers | |
| [2017-01-19 14:47:43,262 DEBUG T:MainThread F:_update_brokers] Discovered broker id 0: ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,263 DEBUG T:MainThread F:connect] Connecting to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,264 DEBUG T:MainThread F:connect] Successfully connected to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,266 DEBUG T:MainThread F:_update_brokers] Discovered broker id 1: ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,267 DEBUG T:MainThread F:connect] Connecting to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,268 DEBUG T:MainThread F:connect] Successfully connected to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,269 DEBUG T:MainThread F:_update_brokers] Discovered broker id 2: ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,269 DEBUG T:MainThread F:connect] Connecting to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,270 DEBUG T:MainThread F:connect] Successfully connected to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,271 INFO T:MainThread F:_update_topics] Discovered 16 topics | |
| [2017-01-19 14:47:43,271 DEBUG T:MainThread F:_update_topics] Discovered topic 'adsimpressionqueue' | |
| [2017-01-19 14:47:43,271 DEBUG T:MainThread F:_update_topics] Discovered topic 'loadlivepsrdatatoelasticsearch' | |
| [2017-01-19 14:47:43,271 DEBUG T:MainThread F:_update_topics] Discovered topic 'celeryip-<something>.celery.pidbox' | |
| [2017-01-19 14:47:43,271 DEBUG T:MainThread F:_update_topics] Discovered topic 'celeryip-<something>.celery.pidbox' | |
| [2017-01-19 14:47:43,271 DEBUG T:MainThread F:_update_topics] Discovered topic 'ParamQueue' | |
| [2017-01-19 14:47:43,272 DEBUG T:MainThread F:_update_topics] Discovered topic 'celery' | |
| [2017-01-19 14:47:43,272 DEBUG T:MainThread F:_update_topics] Discovered topic 'FetchAndUpdateSmartBasketFromLMA' | |
| [2017-01-19 14:47:43,272 DEBUG T:MainThread F:_update_topics] Discovered topic 'celeryip-<something>.celery.pidbox' | |
| [2017-01-19 14:47:43,272 DEBUG T:MainThread F:_update_topics] Discovered topic 'reportqueue' | |
| [2017-01-19 14:47:43,272 DEBUG T:MainThread F:_update_topics] Discovered topic 'celeryip-<something>.celery.pidbox' | |
| [2017-01-19 14:47:43,273 DEBUG T:MainThread F:_update_topics] Discovered topic 'membercommunicationqueue' | |
| [2017-01-19 14:47:43,273 DEBUG T:MainThread F:_update_topics] Discovered topic 'updateTopMenuCacheQueue' | |
| [2017-01-19 14:47:43,273 DEBUG T:MainThread F:_update_topics] Discovered topic 'celeryip-<something>.celery.pidbox' | |
| [2017-01-19 14:47:43,273 DEBUG T:MainThread F:_update_topics] Discovered topic 'relatedsearchqueue' | |
| [2017-01-19 14:47:43,273 DEBUG T:MainThread F:_update_topics] Discovered topic 'celeryip-<something>.celery.pidbox' | |
| [2017-01-19 14:47:43,274 INFO T:Thread-18 F:_connect] Connecting to <ip>:2181 | |
| [2017-01-19 14:47:43,276 DEBUG T:Thread-18 F:log] Sending request(xid=None): Connect(protocol_version=0, last_zxid_seen=0, time_out=30000, session_id=0, passwd='\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00', read_only=None) | |
| [2017-01-19 14:47:43,279 INFO T:Thread-18 F:_session_callback] Zookeeper connection established, state: CONNECTED | |
| [2017-01-19 14:47:43,282 DEBUG T:Thread-18 F:log] Sending request(xid=1): GetChildren(path='/brokers/ids', watcher=None) | |
| [2017-01-19 14:47:43,284 DEBUG T:Thread-18 F:_read_response] Received response(xid=1): [u'0', u'1', u'2'] | |
| [2017-01-19 14:47:43,285 DEBUG T:Thread-18 F:log] Sending request(xid=2): GetData(path='/brokers/ids/0', watcher=None) | |
| [2017-01-19 14:47:43,287 DEBUG T:Thread-18 F:_read_response] Received response(xid=2): ('{"jmx_port":9090,"timestamp":"1483357467458","endpoints":["PLAINTEXT://ip-<something>.ap-southeast-1.compute.internal:9092"],"host":"ip-<something>.ap-southeast-1.compute.intern | |
| al","version":3,"port":9092}', ZnodeStat(czxid=8589934746, mzxid=8589934746, ctime=1483357467461, mtime=1483357467461, version=0, cversion=0, aversion=0, ephemeralOwner=169270881677082626, dataLength=211, numChildren=0, pzxid=8589934746)) | |
| [2017-01-19 14:47:43,288 DEBUG T:Thread-18 F:log] Sending request(xid=3): GetData(path='/brokers/ids/1', watcher=None) | |
| [2017-01-19 14:47:43,290 DEBUG T:Thread-18 F:_read_response] Received response(xid=3): ('{"jmx_port":9090,"timestamp":"1483357470027","endpoints":["PLAINTEXT://ip-<something>.ap-southeast-1.compute.internal:9092"],"host":"ip-<something>.ap-southeast-1.compute.internal","ver | |
| sion":3,"port":9092}', ZnodeStat(czxid=8589934750, mzxid=8589934750, ctime=1483357470046, mtime=1483357470046, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776925189, dataLength=203, numChildren=0, pzxid=8589934750)) | |
| [2017-01-19 14:47:43,290 DEBUG T:Thread-18 F:log] Sending request(xid=4): GetData(path='/brokers/ids/2', watcher=None) | |
| [2017-01-19 14:47:43,292 DEBUG T:Thread-18 F:_read_response] Received response(xid=4): ('{"jmx_port":9090,"timestamp":"1483357565976","endpoints":["PLAINTEXT://ip-<something>.ap-southeast-1.compute.internal:9092"],"host":"ip-<something>.ap-southeast-1.compute.internal | |
| ","version":3,"port":9092}', ZnodeStat(czxid=8589934808, mzxid=8589934808, ctime=1483357566027, mtime=1483357566027, version=0, cversion=0, aversion=0, ephemeralOwner=169270881677082627, dataLength=209, numChildren=0, pzxid=8589934808)) | |
| [2017-01-19 14:47:43,292 DEBUG T:Thread-18 F:log] Sending request(xid=5): Close() | |
| [2017-01-19 14:47:43,295 INFO T:Thread-18 F:_connect_attempt] Closing connection to <ip>:2181 | |
| [2017-01-19 14:47:43,295 INFO T:Thread-18 F:_session_callback] Zookeeper session lost, state: CLOSED | |
| [2017-01-19 14:47:43,297 DEBUG T:MainThread F:connect] Connecting to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,298 DEBUG T:MainThread F:connect] Successfully connected to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,300 INFO T:MainThread F:stop] RequestHandler.stop: about to flush requests queue | |
| [2017-01-19 14:47:43,300 INFO T:MainThread F:update] Adding 1 partitions | |
| [2017-01-19 14:47:43,300 DEBUG T:MainThread F:update] Adding partition celeryip-<something>.celery.pidbox/0 | |
| [2017-01-19 14:47:43,335 DEBUG T:MainThread F:start] ^-- substep ok | |
| [2017-01-19 14:47:43,335 DEBUG T:MainThread F:_debug] | Consumer: Starting Heart | |
| [2017-01-19 14:47:43,337 DEBUG T:MainThread F:start] ^-- substep ok | |
| [2017-01-19 14:47:43,337 DEBUG T:MainThread F:_debug] | Consumer: Starting event loop | |
| [2017-01-19 14:47:43,337 WARNING T:MainThread F:log] celery@ip-<something> ready. | |
| [2017-01-19 14:47:43,337 DEBUG T:MainThread F:set] basic.qos: prefetch_count->4 | |
| [2017-01-19 14:47:43,341 INFO T:Thread-22 F:_connect] Connecting to <ip>:2181 | |
| [2017-01-19 14:47:43,343 DEBUG T:Thread-22 F:log] Sending request(xid=None): Connect(protocol_version=0, last_zxid_seen=0, time_out=6000, session_id=0, passwd='\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00', read_only=None) | |
| [2017-01-19 14:47:43,346 INFO T:Thread-22 F:_session_callback] Zookeeper connection established, state: CONNECTED | |
| [2017-01-19 14:47:43,349 DEBUG T:Thread-22 F:log] Sending request(xid=1): Exists(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue', watcher=None) | |
| [2017-01-19 14:47:43,351 DEBUG T:Thread-22 F:_read_response] Received response(xid=1): ZnodeStat(czxid=8589937328, mzxid=8589937328, ctime=1484125947011, mtime=1484125947011, version=0, cversion=688, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=8, pzxid=8589987 | |
| 376) | |
| [2017-01-19 14:47:43,351 DEBUG T:Thread-22 F:log] Sending request(xid=2): Create(path='/consumers/kombu-consumer-group/ids/ip-<something>:48008500-4346-46e8-a17b-374d94963230', data='adsimpressionqueue', acl=[ACL(perms=31, acl_list=['ALL'], id=Id(scheme='world', id='an | |
| yone'))], flags=1) | |
| [2017-01-19 14:47:43,356 DEBUG T:Thread-22 F:_read_response] Received response(xid=2): u'/consumers/kombu-consumer-group/ids/ip-<something>:48008500-4346-46e8-a17b-374d94963230' | |
| [2017-01-19 14:47:43,357 DEBUG T:Thread-22 F:log] Sending request(xid=3): GetChildren(path='/brokers/ids', watcher=<bound method ChildrenWatch._watcher of <kazoo.recipe.watchers.ChildrenWatch object at 0x7faec0b07b10>>) | |
| [2017-01-19 14:47:43,358 DEBUG T:Thread-22 F:_read_response] Received response(xid=3): [u'0', u'1', u'2'] | |
| [2017-01-19 14:47:43,358 DEBUG T:Thread-22 F:log] Sending request(xid=4): GetChildren(path='/brokers/topics', watcher=<bound method ChildrenWatch._watcher of <kazoo.recipe.watchers.ChildrenWatch object at 0x7faec0b07bd0>>) | |
| [2017-01-19 14:47:43,360 DEBUG T:Thread-22 F:_read_response] Received response(xid=4): [u'celeryip-<something>.celery.pidbox', u'loadlivepsrdatatoelasticsearch', u'relatedsearchqueue', u'celeryip-<something>.celery.pidbox', u'celery', u'celeryip-<something>.celery.p | |
| idbox', u'ParamQueue', u'adsimpressionqueue', u'celeryip-<something>.celery.pidbox', u'reportqueue', u'FetchAndUpdateSmartBasketFromLMA', u'membercommunicationqueue', u'updateTopMenuCacheQueue', u'celeryip-<something>.celery.pidbox', u'__consumer_offsets', u'celeryi | |
| p-10-166-138-183.celery.pidbox'] | |
| [2017-01-19 14:47:43,360 DEBUG T:Thread-22 F:log] Sending request(xid=5): GetChildren(path='/consumers/kombu-consumer-group/ids', watcher=<bound method ChildrenWatch._watcher of <kazoo.recipe.watchers.ChildrenWatch object at 0x7faec0b07350>>) | |
| [2017-01-19 14:47:43,362 DEBUG T:Thread-22 F:_read_response] Received response(xid=5): [u'ip-<something>:58b286cf-3fc7-4ed7-a7d0-f5594a66faf8', u'ip-<something>:e89c8d45-a1e1-4bbb-b459-364d21b45daf', u'ip-<something>:48008500-4346-46e8-a17b-374d94963230', u'ip-<something> | |
| 44-173-75:b35431a4-94d7-4337-a2b4-918c8925b566', u'ip-<something>:31cc84ff-f305-4669-9dc3-31ebd44d6b9a', u'ip-<something>:04e221d3-c958-4205-b228-0fbe16f3e30e', u'ip-<something>:b8728974-9e01-46b3-9f57-dc51b1b44fcc', u'ip-<something>:88fa1d4a-c99f-45e0-8d4a-caad | |
| 538ef009', u'ip-<something>:b0e99e3f-1c4b-4936-997d-5834dfe22b20', u'ip-<something>:86b4e98e-0442-49be-8213-c1222922a2a3', u'ip-<something>:e16ce444-7c2c-4582-918e-d0daa52022e3', u'ip-<something>:79c83ecd-dcbb-4c86-90fe-a02f12c0b742', u'ip-<something>:10230048 | |
| -236a-4747-b241-7f18a9bba572', u'ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', u'ip-<something>:92807851-8a19-4948-85ee-564485e78fee', u'ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', u'ip-<something>:0b8395bc-8fd1-424d-90fc-e6903bd741b5', u'ip-<something> | |
| 165-129-231:b19e5276-26dc-4c7a-9b98-505c8a8f32f9', u'ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881'] | |
| [2017-01-19 14:47:43,362 INFO T:MainThread F:_rebalance] Rebalancing consumer "ip-<something>:48008500-4346-46e8-a17b-374d94963230" for topic "adsimpressionqueue". | |
| [2017-01-19 14:47:43,363 DEBUG T:Thread-22 F:log] Sending request(xid=6): GetChildren(path='/consumers/kombu-consumer-group/ids', watcher=None) | |
| [2017-01-19 14:47:43,365 DEBUG T:Thread-22 F:_read_response] Received response(xid=6): [u'ip-<something>:58b286cf-3fc7-4ed7-a7d0-f5594a66faf8', u'ip-<something>:e89c8d45-a1e1-4bbb-b459-364d21b45daf', u'ip-<something>:48008500-4346-46e8-a17b-374d94963230', u'ip-<something> | |
| 44-173-75:b35431a4-94d7-4337-a2b4-918c8925b566', u'ip-<something>:31cc84ff-f305-4669-9dc3-31ebd44d6b9a', u'ip-<something>:04e221d3-c958-4205-b228-0fbe16f3e30e', u'ip-<something>:b8728974-9e01-46b3-9f57-dc51b1b44fcc', u'ip-<something>:88fa1d4a-c99f-45e0-8d4a-caad | |
| 538ef009', u'ip-<something>:b0e99e3f-1c4b-4936-997d-5834dfe22b20', u'ip-<something>:86b4e98e-0442-49be-8213-c1222922a2a3', u'ip-<something>:e16ce444-7c2c-4582-918e-d0daa52022e3', u'ip-<something>:79c83ecd-dcbb-4c86-90fe-a02f12c0b742', u'ip-<something>:10230048 | |
| -236a-4747-b241-7f18a9bba572', u'ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', u'ip-<something>:92807851-8a19-4948-85ee-564485e78fee', u'ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', u'ip-<something>:0b8395bc-8fd1-424d-90fc-e6903bd741b5', u'ip-<something> | |
| 165-129-231:b19e5276-26dc-4c7a-9b98-505c8a8f32f9', u'ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881'] | |
| [2017-01-19 14:47:43,365 DEBUG T:Thread-22 F:log] Sending request(xid=7): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:58b286cf-3fc7-4ed7-a7d0-f5594a66faf8', watcher=None) | |
| [2017-01-19 14:47:43,367 DEBUG T:Thread-22 F:_read_response] Received response(xid=7): ('reportqueue', ZnodeStat(czxid=8589982993, mzxid=8589982993, ctime=1484737959459, mtime=1484737959459, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948579, dataLength=1 | |
| 1, numChildren=0, pzxid=8589982993)) | |
| [2017-01-19 14:47:43,367 DEBUG T:Thread-22 F:log] Sending request(xid=8): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:e89c8d45-a1e1-4bbb-b459-364d21b45daf', watcher=None) | |
| [2017-01-19 14:47:43,369 DEBUG T:Thread-22 F:_read_response] Received response(xid=8): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983005, mzxid=8589983005, ctime=1484737961679, mtime=1484737961679, version=0, cversion=0, aversion=0, ephemeralOwner=972132 | |
| 88776948580, dataLength=36, numChildren=0, pzxid=8589983005)) | |
| [2017-01-19 14:47:43,369 DEBUG T:Thread-22 F:log] Sending request(xid=9): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:48008500-4346-46e8-a17b-374d94963230', watcher=None) | |
| [2017-01-19 14:47:43,371 DEBUG T:Thread-22 F:_read_response] Received response(xid=9): ('adsimpressionqueue', ZnodeStat(czxid=8589990049, mzxid=8589990049, ctime=1484817463365, mtime=1484817463365, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776951804, dataL | |
| ength=18, numChildren=0, pzxid=8589990049)) | |
| [2017-01-19 14:47:43,371 DEBUG T:Thread-22 F:log] Sending request(xid=10): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b35431a4-94d7-4337-a2b4-918c8925b566', watcher=None) | |
| [2017-01-19 14:47:43,375 DEBUG T:Thread-22 F:_read_response] Received response(xid=10): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983093, mzxid=8589983093, ctime=1484738084047, mtime=1484738084047, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776948604, dataLength=36, numChildren=0, pzxid=8589983093)) | |
| [2017-01-19 14:47:43,375 DEBUG T:Thread-22 F:log] Sending request(xid=11): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:31cc84ff-f305-4669-9dc3-31ebd44d6b9a', watcher=None) | |
| [2017-01-19 14:47:43,377 DEBUG T:Thread-22 F:_read_response] Received response(xid=11): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983339, mzxid=8589983339, ctime=1484738373001, mtime=1484738373001, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776948707, dataLength=37, numChildren=0, pzxid=8589983339)) | |
| [2017-01-19 14:47:43,377 DEBUG T:Thread-22 F:log] Sending request(xid=12): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:04e221d3-c958-4205-b228-0fbe16f3e30e', watcher=None) | |
| [2017-01-19 14:47:43,378 DEBUG T:Thread-22 F:_read_response] Received response(xid=12): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987303, mzxid=8589987303, ctime=1484751404122, mtime=1484751404122, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776950474, dataLength=36, numChildren=0, pzxid=8589987303)) | |
| [2017-01-19 14:47:43,379 DEBUG T:Thread-22 F:log] Sending request(xid=13): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b8728974-9e01-46b3-9f57-dc51b1b44fcc', watcher=None) | |
| [2017-01-19 14:47:43,380 DEBUG T:Thread-22 F:_read_response] Received response(xid=13): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983278, mzxid=8589983278, ctime=1484738261800, mtime=1484738261800, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776948686, dataLength=36, numChildren=0, pzxid=8589983278)) | |
| [2017-01-19 14:47:43,380 DEBUG T:Thread-22 F:log] Sending request(xid=14): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:88fa1d4a-c99f-45e0-8d4a-caad538ef009', watcher=None) | |
| [2017-01-19 14:47:43,383 DEBUG T:Thread-22 F:_read_response] Received response(xid=14): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983366, mzxid=8589983366, ctime=1484738424188, mtime=1484738424188, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776948715, dataLength=37, numChildren=0, pzxid=8589983366)) | |
| [2017-01-19 14:47:43,384 DEBUG T:Thread-22 F:log] Sending request(xid=15): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b0e99e3f-1c4b-4936-997d-5834dfe22b20', watcher=None) | |
| [2017-01-19 14:47:43,385 DEBUG T:Thread-22 F:_read_response] Received response(xid=15): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987344, mzxid=8589987344, ctime=1484751539804, mtime=1484751539804, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776950489, dataLength=36, numChildren=0, pzxid=8589987344)) | |
| [2017-01-19 14:47:43,386 DEBUG T:Thread-22 F:log] Sending request(xid=16): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:86b4e98e-0442-49be-8213-c1222922a2a3', watcher=None) | |
| [2017-01-19 14:47:43,389 DEBUG T:Thread-22 F:_read_response] Received response(xid=16): ('reportqueue', ZnodeStat(czxid=8589983082, mzxid=8589983082, ctime=1484738083857, mtime=1484738083857, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948603, dataLength= | |
| 11, numChildren=0, pzxid=8589983082)) | |
| [2017-01-19 14:47:43,389 DEBUG T:Thread-22 F:log] Sending request(xid=17): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:e16ce444-7c2c-4582-918e-d0daa52022e3', watcher=None) | |
| [2017-01-19 14:47:43,390 DEBUG T:Thread-22 F:_read_response] Received response(xid=17): ('reportqueue', ZnodeStat(czxid=8589983269, mzxid=8589983269, ctime=1484738261629, mtime=1484738261629, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948685, dataLength= | |
| 11, numChildren=0, pzxid=8589983269)) | |
| [2017-01-19 14:47:43,391 DEBUG T:Thread-22 F:log] Sending request(xid=18): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:79c83ecd-dcbb-4c86-90fe-a02f12c0b742', watcher=None) | |
| [2017-01-19 14:47:43,392 DEBUG T:Thread-22 F:_read_response] Received response(xid=18): ('adsimpressionqueue', ZnodeStat(czxid=8589983334, mzxid=8589983334, ctime=1484738372853, mtime=1484738372853, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948706, data | |
| Length=18, numChildren=0, pzxid=8589983334)) | |
| [2017-01-19 14:47:43,393 DEBUG T:Thread-22 F:log] Sending request(xid=19): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:10230048-236a-4747-b241-7f18a9bba572', watcher=None) | |
| [2017-01-19 14:47:43,394 DEBUG T:Thread-22 F:_read_response] Received response(xid=19): ('adsimpressionqueue', ZnodeStat(czxid=8589987264, mzxid=8589987264, ctime=1484751296214, mtime=1484751296214, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950465, data | |
| Length=18, numChildren=0, pzxid=8589987264)) | |
| [2017-01-19 14:47:43,394 DEBUG T:Thread-22 F:log] Sending request(xid=20): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', watcher=None) | |
| [2017-01-19 14:47:43,396 DEBUG T:Thread-22 F:_read_response] Received response(xid=20): ('adsimpressionqueue', ZnodeStat(czxid=8589987364, mzxid=8589987364, ctime=1484751622280, mtime=1484751622280, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950497, data | |
| Length=18, numChildren=0, pzxid=8589987364)) | |
| [2017-01-19 14:47:43,396 DEBUG T:Thread-22 F:log] Sending request(xid=21): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:92807851-8a19-4948-85ee-564485e78fee', watcher=None) | |
| [2017-01-19 14:47:43,397 DEBUG T:Thread-22 F:_read_response] Received response(xid=21): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987378, mzxid=8589987378, ctime=1484751622445, mtime=1484751622445, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776950498, dataLength=36, numChildren=0, pzxid=8589987378)) | |
| [2017-01-19 14:47:43,398 DEBUG T:Thread-22 F:log] Sending request(xid=22): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', watcher=None) | |
| [2017-01-19 14:47:43,399 DEBUG T:Thread-22 F:_read_response] Received response(xid=22): ('adsimpressionqueue', ZnodeStat(czxid=8589987290, mzxid=8589987290, ctime=1484751403975, mtime=1484751403975, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950473, data | |
| Length=18, numChildren=0, pzxid=8589987290)) | |
| [2017-01-19 14:47:43,400 DEBUG T:Thread-22 F:log] Sending request(xid=23): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:0b8395bc-8fd1-424d-90fc-e6903bd741b5', watcher=None) | |
| [2017-01-19 14:47:43,401 DEBUG T:Thread-22 F:_read_response] Received response(xid=23): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987275, mzxid=8589987275, ctime=1484751296379, mtime=1484751296379, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776950466, dataLength=37, numChildren=0, pzxid=8589987275)) | |
| [2017-01-19 14:47:43,401 DEBUG T:Thread-22 F:log] Sending request(xid=24): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b19e5276-26dc-4c7a-9b98-505c8a8f32f9', watcher=None) | |
| [2017-01-19 14:47:43,403 DEBUG T:Thread-22 F:_read_response] Received response(xid=24): ('reportqueue', ZnodeStat(czxid=8589983354, mzxid=8589983354, ctime=1484738423901, mtime=1484738423901, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948714, dataLength= | |
| 11, numChildren=0, pzxid=8589983354)) | |
| [2017-01-19 14:47:43,403 DEBUG T:Thread-22 F:log] Sending request(xid=25): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881', watcher=None) | |
| [2017-01-19 14:47:43,404 DEBUG T:Thread-22 F:_read_response] Received response(xid=25): ('adsimpressionqueue', ZnodeStat(czxid=8589987334, mzxid=8589987334, ctime=1484751539655, mtime=1484751539655, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950488, data | |
| Length=18, numChildren=0, pzxid=8589987334)) | |
| [2017-01-19 14:47:43,405 INFO T:MainThread F:_decide_partitions] ip-<something>:48008500-4346-46e8-a17b-374d94963230: Balancing 6 participants for 8 partitions. Owning 1 partitions. | |
| [2017-01-19 14:47:43,405 DEBUG T:MainThread F:_decide_partitions] My partitions: ['adsimpressionqueue-2-1'] | |
| [2017-01-19 14:47:43,405 DEBUG T:Thread-22 F:log] Sending request(xid=26): GetChildren(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue', watcher=None) | |
| [2017-01-19 14:47:43,414 DEBUG T:Thread-22 F:_read_response] Received response(xid=26): [u'1-0', u'0-2', u'2-1', u'1-3', u'0-5', u'2-4', u'1-6', u'2-7'] | |
| [2017-01-19 14:47:43,414 DEBUG T:Thread-22 F:log] Sending request(xid=27): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/1-0', watcher=None) | |
| [2017-01-19 14:47:43,417 DEBUG T:Thread-22 F:_read_response] Received response(xid=27): ('ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', ZnodeStat(czxid=8589987371, mzxid=8589987371, ctime=1484751622390, mtime=1484751622390, version=0, cversion=0, aversion=0, eph | |
| emeralOwner=97213288776950497, dataLength=53, numChildren=0, pzxid=8589987371)) | |
| [2017-01-19 14:47:43,417 DEBUG T:Thread-22 F:log] Sending request(xid=28): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/0-2', watcher=None) | |
| [2017-01-19 14:47:43,419 DEBUG T:Thread-22 F:_read_response] Received response(xid=28): ('ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881', ZnodeStat(czxid=8589987340, mzxid=8589987340, ctime=1484751539770, mtime=1484751539770, version=0, cversion=0, aversion=0, eph | |
| emeralOwner=97213288776950488, dataLength=53, numChildren=0, pzxid=8589987340)) | |
| [2017-01-19 14:47:43,419 DEBUG T:Thread-22 F:log] Sending request(xid=29): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/2-1', watcher=None) | |
| [2017-01-19 14:47:43,421 DEBUG T:Thread-22 F:_read_response] Received response(xid=29): ('ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', ZnodeStat(czxid=8589987375, mzxid=8589987375, ctime=1484751622406, mtime=1484751622406, version=0, cversion=0, aversion=0, eph | |
| emeralOwner=97213288776950473, dataLength=53, numChildren=0, pzxid=8589987375)) | |
| [2017-01-19 14:47:43,422 DEBUG T:Thread-22 F:log] Sending request(xid=30): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/1-3', watcher=None) | |
| [2017-01-19 14:47:43,424 DEBUG T:Thread-22 F:_read_response] Received response(xid=30): ('ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', ZnodeStat(czxid=8589987373, mzxid=8589987373, ctime=1484751622400, mtime=1484751622400, version=0, cversion=0, aversion=0, eph | |
| emeralOwner=97213288776950497, dataLength=53, numChildren=0, pzxid=8589987373)) | |
| [2017-01-19 14:47:43,425 DEBUG T:Thread-22 F:log] Sending request(xid=31): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/0-5', watcher=None) | |
| [2017-01-19 14:47:43,426 DEBUG T:Thread-22 F:_read_response] Received response(xid=31): ('ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881', ZnodeStat(czxid=8589987342, mzxid=8589987342, ctime=1484751539773, mtime=1484751539773, version=0, cversion=0, aversion=0, eph | |
| emeralOwner=97213288776950488, dataLength=53, numChildren=0, pzxid=8589987342)) | |
| [2017-01-19 14:47:43,427 DEBUG T:Thread-22 F:log] Sending request(xid=32): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/2-4', watcher=None) | |
| [2017-01-19 14:47:43,428 DEBUG T:Thread-22 F:_read_response] Received response(xid=32): ('ip-<something>:79c83ecd-dcbb-4c86-90fe-a02f12c0b742', ZnodeStat(czxid=8589987376, mzxid=8589987376, ctime=1484751622420, mtime=1484751622420, version=0, cversion=0, aversion=0, ep | |
| hemeralOwner=97213288776948706, dataLength=54, numChildren=0, pzxid=8589987376)) | |
| [2017-01-19 14:47:43,429 DEBUG T:Thread-22 F:log] Sending request(xid=33): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/1-6', watcher=None) | |
| [2017-01-19 14:47:43,430 DEBUG T:Thread-22 F:_read_response] Received response(xid=33): ('ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', ZnodeStat(czxid=8589987374, mzxid=8589987374, ctime=1484751622403, mtime=1484751622403, version=0, cversion=0, aversion=0, eph | |
| emeralOwner=97213288776950473, dataLength=53, numChildren=0, pzxid=8589987374)) | |
| [2017-01-19 14:47:43,430 DEBUG T:Thread-22 F:log] Sending request(xid=34): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/2-7', watcher=None) | |
| [2017-01-19 14:47:43,432 DEBUG T:Thread-22 F:_read_response] Received response(xid=34): ('ip-<something>:10230048-236a-4747-b241-7f18a9bba572', ZnodeStat(czxid=8589987273, mzxid=8589987273, ctime=1484751296307, mtime=1484751296307, version=0, cversion=0, aversion=0, ep | |
| hemeralOwner=97213288776950465, dataLength=54, numChildren=0, pzxid=8589987273)) | |
| [2017-01-19 14:47:43,432 DEBUG T:Thread-22 F:log] Sending request(xid=35): Create(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/2-1', data='ip-<something>:48008500-4346-46e8-a17b-374d94963230', acl=[ACL(perms=31, acl_list=['ALL'], id=Id(scheme='world' | |
| , id='anyone'))], flags=1) | |
| [2017-01-19 14:47:43,436 DEBUG T:Thread-22 F:_read_response] Received error(xid=35) NodeExistsError((), {}) | |
| [2017-01-19 14:47:43,437 INFO T:MainThread F:_update_member_assignment] Unable to acquire partition <pykafka.partition.Partition at 0x7faec0ae6d10 (id=1)>. Retrying | |
| [2017-01-19 14:47:43,437 DEBUG T:Thread-22 F:log] Sending request(xid=36): GetChildren(path='/consumers/kombu-consumer-group/ids', watcher=None) | |
| [2017-01-19 14:47:43,439 DEBUG T:Thread-22 F:_read_response] Received response(xid=36): [u'ip-<something>:58b286cf-3fc7-4ed7-a7d0-f5594a66faf8', u'ip-<something>:e89c8d45-a1e1-4bbb-b459-364d21b45daf', u'ip-<something>:48008500-4346-46e8-a17b-374d94963230', u'ip-<something> | |
| 144-173-75:b35431a4-94d7-4337-a2b4-918c8925b566', u'ip-<something>:31cc84ff-f305-4669-9dc3-31ebd44d6b9a', u'ip-<something>:04e221d3-c958-4205-b228-0fbe16f3e30e', u'ip-<something>:b8728974-9e01-46b3-9f57-dc51b1b44fcc', u'ip-<something>:88fa1d4a-c99f-45e0-8d4a-caa | |
| d538ef009', u'ip-<something>:b0e99e3f-1c4b-4936-997d-5834dfe22b20', u'ip-<something>:86b4e98e-0442-49be-8213-c1222922a2a3', u'ip-<something>:e16ce444-7c2c-4582-918e-d0daa52022e3', u'ip-<something>:79c83ecd-dcbb-4c86-90fe-a02f12c0b742', u'ip-<something>:1023004 | |
| 8-236a-4747-b241-7f18a9bba572', u'ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', u'ip-<something>:92807851-8a19-4948-85ee-564485e78fee', u'ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', u'ip-<something>:0b8395bc-8fd1-424d-90fc-e6903bd741b5', u'ip-<something> | |
| -165-129-231:b19e5276-26dc-4c7a-9b98-505c8a8f32f9', u'ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881'] | |
| [2017-01-19 14:47:43,439 DEBUG T:Thread-22 F:log] Sending request(xid=37): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:58b286cf-3fc7-4ed7-a7d0-f5594a66faf8', watcher=None) | |
| [2017-01-19 14:47:43,443 DEBUG T:Thread-22 F:_read_response] Received response(xid=37): ('reportqueue', ZnodeStat(czxid=8589982993, mzxid=8589982993, ctime=1484737959459, mtime=1484737959459, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948579, dataLength= | |
| 11, numChildren=0, pzxid=8589982993)) | |
| [2017-01-19 14:47:43,443 DEBUG T:Thread-22 F:log] Sending request(xid=38): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:e89c8d45-a1e1-4bbb-b459-364d21b45daf', watcher=None) | |
| [2017-01-19 14:47:43,448 DEBUG T:Thread-22 F:_read_response] Received response(xid=38): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983005, mzxid=8589983005, ctime=1484737961679, mtime=1484737961679, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776948580, dataLength=36, numChildren=0, pzxid=8589983005)) | |
| [2017-01-19 14:47:43,448 DEBUG T:Thread-22 F:log] Sending request(xid=39): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:48008500-4346-46e8-a17b-374d94963230', watcher=None) | |
| [2017-01-19 14:47:43,450 DEBUG T:Thread-22 F:_read_response] Received response(xid=39): ('adsimpressionqueue', ZnodeStat(czxid=8589990049, mzxid=8589990049, ctime=1484817463365, mtime=1484817463365, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776951804, data | |
| Length=18, numChildren=0, pzxid=8589990049)) | |
| [2017-01-19 14:47:43,450 DEBUG T:Thread-22 F:log] Sending request(xid=40): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b35431a4-94d7-4337-a2b4-918c8925b566', watcher=None) | |
| [2017-01-19 14:47:43,452 DEBUG T:Thread-22 F:_read_response] Received response(xid=40): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983093, mzxid=8589983093, ctime=1484738084047, mtime=1484738084047, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776948604, dataLength=36, numChildren=0, pzxid=8589983093)) | |
| [2017-01-19 14:47:43,452 DEBUG T:Thread-22 F:log] Sending request(xid=41): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:31cc84ff-f305-4669-9dc3-31ebd44d6b9a', watcher=None) | |
| [2017-01-19 14:47:43,454 DEBUG T:Thread-22 F:_read_response] Received response(xid=41): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983339, mzxid=8589983339, ctime=1484738373001, mtime=1484738373001, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776948707, dataLength=37, numChildren=0, pzxid=8589983339)) | |
| [2017-01-19 14:47:43,454 DEBUG T:Thread-22 F:log] Sending request(xid=42): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:04e221d3-c958-4205-b228-0fbe16f3e30e', watcher=None) | |
| [2017-01-19 14:47:43,455 DEBUG T:Thread-22 F:_read_response] Received response(xid=42): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987303, mzxid=8589987303, ctime=1484751404122, mtime=1484751404122, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776950474, dataLength=36, numChildren=0, pzxid=8589987303)) | |
| [2017-01-19 14:47:43,456 DEBUG T:Thread-22 F:log] Sending request(xid=43): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b8728974-9e01-46b3-9f57-dc51b1b44fcc', watcher=None) | |
| [2017-01-19 14:47:43,457 DEBUG T:Thread-22 F:_read_response] Received response(xid=43): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983278, mzxid=8589983278, ctime=1484738261800, mtime=1484738261800, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776948686, dataLength=36, numChildren=0, pzxid=8589983278)) | |
| [2017-01-19 14:47:43,458 DEBUG T:Thread-22 F:log] Sending request(xid=44): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:88fa1d4a-c99f-45e0-8d4a-caad538ef009', watcher=None) | |
| [2017-01-19 14:47:43,459 DEBUG T:Thread-22 F:_read_response] Received response(xid=44): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983366, mzxid=8589983366, ctime=1484738424188, mtime=1484738424188, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776948715, dataLength=37, numChildren=0, pzxid=8589983366)) | |
| [2017-01-19 14:47:43,460 DEBUG T:Thread-22 F:log] Sending request(xid=45): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b0e99e3f-1c4b-4936-997d-5834dfe22b20', watcher=None) | |
| [2017-01-19 14:47:43,461 DEBUG T:Thread-22 F:_read_response] Received response(xid=45): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987344, mzxid=8589987344, ctime=1484751539804, mtime=1484751539804, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776950489, dataLength=36, numChildren=0, pzxid=8589987344)) | |
| [2017-01-19 14:47:43,461 DEBUG T:Thread-22 F:log] Sending request(xid=46): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:86b4e98e-0442-49be-8213-c1222922a2a3', watcher=None) | |
| [2017-01-19 14:47:43,463 DEBUG T:Thread-22 F:_read_response] Received response(xid=46): ('reportqueue', ZnodeStat(czxid=8589983082, mzxid=8589983082, ctime=1484738083857, mtime=1484738083857, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948603, dataLength= | |
| 11, numChildren=0, pzxid=8589983082)) | |
| [2017-01-19 14:47:43,463 DEBUG T:Thread-22 F:log] Sending request(xid=47): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:e16ce444-7c2c-4582-918e-d0daa52022e3', watcher=None) | |
| [2017-01-19 14:47:43,466 DEBUG T:Thread-22 F:_read_response] Received response(xid=47): ('reportqueue', ZnodeStat(czxid=8589983269, mzxid=8589983269, ctime=1484738261629, mtime=1484738261629, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948685, dataLength= | |
| 11, numChildren=0, pzxid=8589983269)) | |
| [2017-01-19 14:47:43,466 DEBUG T:Thread-22 F:log] Sending request(xid=48): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:79c83ecd-dcbb-4c86-90fe-a02f12c0b742', watcher=None) | |
| [2017-01-19 14:47:43,468 DEBUG T:Thread-22 F:_read_response] Received response(xid=48): ('adsimpressionqueue', ZnodeStat(czxid=8589983334, mzxid=8589983334, ctime=1484738372853, mtime=1484738372853, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948706, data | |
| Length=18, numChildren=0, pzxid=8589983334)) | |
| [2017-01-19 14:47:43,468 DEBUG T:Thread-22 F:log] Sending request(xid=49): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:10230048-236a-4747-b241-7f18a9bba572', watcher=None) | |
| [2017-01-19 14:47:43,471 DEBUG T:Thread-22 F:_read_response] Received response(xid=49): ('adsimpressionqueue', ZnodeStat(czxid=8589987264, mzxid=8589987264, ctime=1484751296214, mtime=1484751296214, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950465, data | |
| Length=18, numChildren=0, pzxid=8589987264)) | |
| [2017-01-19 14:47:43,471 DEBUG T:Thread-22 F:log] Sending request(xid=50): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', watcher=None) | |
| [2017-01-19 14:47:43,472 DEBUG T:Thread-22 F:_read_response] Received response(xid=50): ('adsimpressionqueue', ZnodeStat(czxid=8589987364, mzxid=8589987364, ctime=1484751622280, mtime=1484751622280, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950497, data | |
| Length=18, numChildren=0, pzxid=8589987364)) | |
| [2017-01-19 14:47:43,473 DEBUG T:Thread-22 F:log] Sending request(xid=51): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:92807851-8a19-4948-85ee-564485e78fee', watcher=None) | |
| [2017-01-19 14:47:43,474 DEBUG T:Thread-22 F:_read_response] Received response(xid=51): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987378, mzxid=8589987378, ctime=1484751622445, mtime=1484751622445, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776950498, dataLength=36, numChildren=0, pzxid=8589987378)) | |
| [2017-01-19 14:47:43,474 DEBUG T:Thread-22 F:log] Sending request(xid=52): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', watcher=None) | |
| [2017-01-19 14:47:43,476 DEBUG T:Thread-22 F:_read_response] Received response(xid=52): ('adsimpressionqueue', ZnodeStat(czxid=8589987290, mzxid=8589987290, ctime=1484751403975, mtime=1484751403975, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950473, data | |
| Length=18, numChildren=0, pzxid=8589987290)) | |
| [2017-01-19 14:47:43,476 DEBUG T:Thread-22 F:log] Sending request(xid=53): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:0b8395bc-8fd1-424d-90fc-e6903bd741b5', watcher=None) | |
| [2017-01-19 14:47:43,478 DEBUG T:Thread-22 F:_read_response] Received response(xid=53): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987275, mzxid=8589987275, ctime=1484751296379, mtime=1484751296379, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776950466, dataLength=37, numChildren=0, pzxid=8589987275)) | |
| [2017-01-19 14:47:43,478 DEBUG T:Thread-22 F:log] Sending request(xid=54): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b19e5276-26dc-4c7a-9b98-505c8a8f32f9', watcher=None) | |
| [2017-01-19 14:47:43,482 DEBUG T:Thread-22 F:_read_response] Received response(xid=54): ('reportqueue', ZnodeStat(czxid=8589983354, mzxid=8589983354, ctime=1484738423901, mtime=1484738423901, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948714, dataLength= | |
| 11, numChildren=0, pzxid=8589983354)) | |
| [2017-01-19 14:47:43,482 DEBUG T:Thread-22 F:log] Sending request(xid=55): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881', watcher=None) | |
| [2017-01-19 14:47:43,484 DEBUG T:Thread-22 F:_read_response] Received response(xid=55): ('adsimpressionqueue', ZnodeStat(czxid=8589987334, mzxid=8589987334, ctime=1484751539655, mtime=1484751539655, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950488, data | |
| Length=18, numChildren=0, pzxid=8589987334)) | |
| [2017-01-19 14:47:43,484 INFO T:MainThread F:_decide_partitions] ip-<something>:48008500-4346-46e8-a17b-374d94963230: Balancing 6 participants for 8 partitions. Owning 1 partitions. | |
| [2017-01-19 14:47:43,484 DEBUG T:MainThread F:_decide_partitions] My partitions: ['adsimpressionqueue-2-1'] | |
| [2017-01-19 14:47:43,484 DEBUG T:Thread-22 F:log] Sending request(xid=56): GetChildren(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue', watcher=None) | |
| [2017-01-19 14:47:43,486 DEBUG T:Thread-22 F:_read_response] Received response(xid=56): [u'1-0', u'0-2', u'1-3', u'0-5', u'2-4', u'1-6', u'2-7'] | |
| [2017-01-19 14:47:43,487 DEBUG T:Thread-22 F:log] Sending request(xid=57): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/1-0', watcher=None) | |
| [2017-01-19 14:47:43,489 DEBUG T:Thread-22 F:_read_response] Received response(xid=57): ('ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', ZnodeStat(czxid=8589987371, mzxid=8589987371, ctime=1484751622390, mtime=1484751622390, version=0, cversion=0, aversion=0, eph | |
| emeralOwner=97213288776950497, dataLength=53, numChildren=0, pzxid=8589987371)) | |
| [2017-01-19 14:47:43,490 DEBUG T:Thread-22 F:log] Sending request(xid=58): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/0-2', watcher=None) | |
| [2017-01-19 14:47:43,491 DEBUG T:Thread-22 F:_read_response] Received response(xid=58): ('ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881', ZnodeStat(czxid=8589987340, mzxid=8589987340, ctime=1484751539770, mtime=1484751539770, version=0, cversion=0, aversion=0, eph | |
| emeralOwner=97213288776950488, dataLength=53, numChildren=0, pzxid=8589987340)) | |
| [2017-01-19 14:47:43,492 DEBUG T:Thread-22 F:log] Sending request(xid=59): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/1-3', watcher=None) | |
| [2017-01-19 14:47:43,494 DEBUG T:Thread-22 F:_read_response] Received response(xid=59): ('ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', ZnodeStat(czxid=8589987373, mzxid=8589987373, ctime=1484751622400, mtime=1484751622400, version=0, cversion=0, aversion=0, eph | |
| emeralOwner=97213288776950497, dataLength=53, numChildren=0, pzxid=8589987373)) | |
| [2017-01-19 14:47:43,494 DEBUG T:Thread-22 F:log] Sending request(xid=60): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/0-5', watcher=None) | |
| [2017-01-19 14:47:43,496 DEBUG T:Thread-22 F:_read_response] Received response(xid=60): ('ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881', ZnodeStat(czxid=8589987342, mzxid=8589987342, ctime=1484751539773, mtime=1484751539773, version=0, cversion=0, aversion=0, eph | |
| emeralOwner=97213288776950488, dataLength=53, numChildren=0, pzxid=8589987342)) | |
| [2017-01-19 14:47:43,497 DEBUG T:Thread-22 F:log] Sending request(xid=61): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/2-4', watcher=None) | |
| [2017-01-19 14:47:43,498 DEBUG T:Thread-22 F:_read_response] Received response(xid=61): ('ip-<something>:79c83ecd-dcbb-4c86-90fe-a02f12c0b742', ZnodeStat(czxid=8589987376, mzxid=8589987376, ctime=1484751622420, mtime=1484751622420, version=0, cversion=0, aversion=0, ep | |
| hemeralOwner=97213288776948706, dataLength=54, numChildren=0, pzxid=8589987376)) | |
| [2017-01-19 14:47:43,499 DEBUG T:Thread-22 F:log] Sending request(xid=62): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/1-6', watcher=None) | |
| [2017-01-19 14:47:43,501 DEBUG T:Thread-22 F:_read_response] Received response(xid=62): ('ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', ZnodeStat(czxid=8589987374, mzxid=8589987374, ctime=1484751622403, mtime=1484751622403, version=0, cversion=0, aversion=0, eph | |
| emeralOwner=97213288776950473, dataLength=53, numChildren=0, pzxid=8589987374)) | |
| [2017-01-19 14:47:43,501 DEBUG T:Thread-22 F:log] Sending request(xid=63): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/2-7', watcher=None) | |
| [2017-01-19 14:47:43,502 DEBUG T:Thread-22 F:_read_response] Received response(xid=63): ('ip-<something>:10230048-236a-4747-b241-7f18a9bba572', ZnodeStat(czxid=8589987273, mzxid=8589987273, ctime=1484751296307, mtime=1484751296307, version=0, cversion=0, aversion=0, ep | |
| hemeralOwner=97213288776950465, dataLength=54, numChildren=0, pzxid=8589987273)) | |
| [2017-01-19 14:47:43,503 DEBUG T:Thread-22 F:log] Sending request(xid=64): Create(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/2-1', data='ip-<something>:48008500-4346-46e8-a17b-374d94963230', acl=[ACL(perms=31, acl_list=['ALL'], id=Id(scheme='world' | |
| , id='anyone'))], flags=1) | |
| [2017-01-19 14:47:43,506 DEBUG T:Thread-22 F:_read_response] Received response(xid=64): u'/consumers/kombu-consumer-group/owners/adsimpressionqueue/2-1' | |
| [2017-01-19 14:47:43,507 INFO T:MainThread F:get_group_coordinator] Attempting to discover offset manager for consumer group 'kombu-consumer-group' | |
| [2017-01-19 14:47:43,532 INFO T:MainThread F:get_group_coordinator] Found coordinator broker with id 0 | |
| [2017-01-19 14:47:43,532 DEBUG T:MainThread F:fetch_offsets] Fetching offsets for 1 partitions from broker id 0 | |
| [2017-01-19 14:47:43,533 DEBUG T:MainThread F:connect] Connecting to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,535 DEBUG T:MainThread F:connect] Successfully connected to ip-<something>.ap-southeast-1.compute.internal:9092 | |
| [2017-01-19 14:47:43,538 DEBUG T:MainThread F:_handle_success] Set offset for partition 1 to 408603 | |
| [2017-01-19 14:47:43,538 DEBUG T:MainThread F:_setup_fetch_workers] Configuring _rdk_consumer... | |
| [2017-01-19 14:47:43,538 DEBUG T:MainThread F:_setup_fetch_workers] Starting _rdk_consumer with {'partition_ids': [1], 'start_offsets': [408604], 'topic_name': 'adsimpressionqueue', 'brokers': 'ip-<something>.ap-southeast-1.compute.internal:9092,ip-<something>.ap-southe | |
| ast-1.compute.internal:9092,ip-<something>.ap-southeast-1.compute.internal:9092'} | |
| [2017-01-19 14:47:43,541 INFO T:MainThread F:_update_member_assignment] Rebalancing Complete. | |
| [2017-01-19 14:47:43,544 INFO T:Thread-26 F:_connect] Connecting to <ip>:2181 | |
| [2017-01-19 14:47:43,546 DEBUG T:Thread-26 F:log] Sending request(xid=None): Connect(protocol_version=0, last_zxid_seen=0, time_out=6000, session_id=0, passwd='\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00', read_only=None) | |
| [2017-01-19 14:47:43,549 INFO T:Thread-26 F:_session_callback] Zookeeper connection established, state: CONNECTED | |
| [2017-01-19 14:47:43,552 DEBUG T:Thread-26 F:log] Sending request(xid=1): Exists(path='/consumers/kombu-consumer-group/owners/celeryip-<something>.celery.pidbox', watcher=None) | |
| [2017-01-19 14:47:43,553 DEBUG T:Thread-26 F:_read_response] Received response(xid=1): ZnodeStat(czxid=331, mzxid=331, ctime=1483079939400, mtime=1483079939400, version=0, cversion=49, aversion=0, ephemeralOwner=0, dataLength=0, numChildren=1, pzxid=8589986750) | |
| [2017-01-19 14:47:43,554 DEBUG T:Thread-26 F:log] Sending request(xid=2): Create(path='/consumers/kombu-consumer-group/ids/ip-<something>:a13ed8bc-9878-4fdb-92a6-735b5d6a6cf5', data='celeryip-<something>.celery.pidbox', acl=[ACL(perms=31, acl_list=['ALL'], id=Id(sch | |
| eme='world', id='anyone'))], flags=1) | |
| [2017-01-19 14:47:43,557 DEBUG T:Thread-22 F:_read_watch_event] Received EVENT: Watch(type=4, state=3, path=u'/consumers/kombu-consumer-group/ids') | |
| [2017-01-19 14:47:43,557 DEBUG T:Thread-26 F:_read_response] Received response(xid=2): u'/consumers/kombu-consumer-group/ids/ip-<something>:a13ed8bc-9878-4fdb-92a6-735b5d6a6cf5' | |
| [2017-01-19 14:47:43,558 DEBUG T:Thread-26 F:log] Sending request(xid=3): GetChildren(path='/brokers/ids', watcher=<bound method ChildrenWatch._watcher of <kazoo.recipe.watchers.ChildrenWatch object at 0x7faec0af6490>>) | |
| [2017-01-19 14:47:43,560 DEBUG T:Thread-22 F:log] Sending request(xid=65): GetChildren(path='/consumers/kombu-consumer-group/ids', watcher=<bound method ChildrenWatch._watcher of <kazoo.recipe.watchers.ChildrenWatch object at 0x7faec0b07350>>) | |
| [2017-01-19 14:47:43,560 DEBUG T:Thread-26 F:_read_response] Received response(xid=3): [u'0', u'1', u'2'] | |
| [2017-01-19 14:47:43,561 DEBUG T:Thread-26 F:log] Sending request(xid=4): GetChildren(path='/brokers/topics', watcher=<bound method ChildrenWatch._watcher of <kazoo.recipe.watchers.ChildrenWatch object at 0x7faec0af6ed0>>) | |
| [2017-01-19 14:47:43,561 DEBUG T:Thread-22 F:_read_response] Received response(xid=65): [u'ip-<something>:58b286cf-3fc7-4ed7-a7d0-f5594a66faf8', u'ip-<something>:e89c8d45-a1e1-4bbb-b459-364d21b45daf', u'ip-<something>:48008500-4346-46e8-a17b-374d94963230', u'ip-<something> | |
| 144-173-75:b35431a4-94d7-4337-a2b4-918c8925b566', u'ip-<something>:31cc84ff-f305-4669-9dc3-31ebd44d6b9a', u'ip-<something>:04e221d3-c958-4205-b228-0fbe16f3e30e', u'ip-<something>:b8728974-9e01-46b3-9f57-dc51b1b44fcc', u'ip-<something>:88fa1d4a-c99f-45e0-8d4a-caa | |
| d538ef009', u'ip-<something>:b0e99e3f-1c4b-4936-997d-5834dfe22b20', u'ip-<something>:a13ed8bc-9878-4fdb-92a6-735b5d6a6cf5', u'ip-<something>:86b4e98e-0442-49be-8213-c1222922a2a3', u'ip-<something>:e16ce444-7c2c-4582-918e-d0daa52022e3', u'ip-<something>:79c83ec | |
| d-dcbb-4c86-90fe-a02f12c0b742', u'ip-<something>:10230048-236a-4747-b241-7f18a9bba572', u'ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', u'ip-<something>:92807851-8a19-4948-85ee-564485e78fee', u'ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', u'ip-<something> | |
| -166-138-183:0b8395bc-8fd1-424d-90fc-e6903bd741b5', u'ip-<something>:b19e5276-26dc-4c7a-9b98-505c8a8f32f9', u'ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881'] | |
| [2017-01-19 14:47:43,562 DEBUG T:Thread-21 F:_consumers_changed] Rebalance triggered by consumer change (ip-<something>:48008500-4346-46e8-a17b-374d94963230) | |
| [2017-01-19 14:47:43,562 DEBUG T:Thread-21 F:commit_offsets] Committing offsets for 1 partitions to broker id 0 | |
| [2017-01-19 14:47:43,562 DEBUG T:Thread-26 F:_read_response] Received response(xid=4): [u'celeryip-<something>.celery.pidbox', u'loadlivepsrdatatoelasticsearch', u'relatedsearchqueue', u'celeryip-<something>.celery.pidbox', u'celery', u'celeryip-<something>.celery.p | |
| idbox', u'ParamQueue', u'adsimpressionqueue', u'celeryip-<something>.celery.pidbox', u'reportqueue', u'FetchAndUpdateSmartBasketFromLMA', u'membercommunicationqueue', u'updateTopMenuCacheQueue', u'celeryip-<something>.celery.pidbox', u'__consumer_offsets', u'celeryi | |
| p-10-166-138-183.celery.pidbox'] | |
| [2017-01-19 14:47:43,563 DEBUG T:Thread-26 F:log] Sending request(xid=5): GetChildren(path='/consumers/kombu-consumer-group/ids', watcher=<bound method ChildrenWatch._watcher of <kazoo.recipe.watchers.ChildrenWatch object at 0x7faec0af6510>>) | |
| [2017-01-19 14:47:43,564 DEBUG T:Thread-26 F:_read_response] Received response(xid=5): [u'ip-<something>:58b286cf-3fc7-4ed7-a7d0-f5594a66faf8', u'ip-<something>:e89c8d45-a1e1-4bbb-b459-364d21b45daf', u'ip-<something>:48008500-4346-46e8-a17b-374d94963230', u'ip-<something> | |
| 44-173-75:b35431a4-94d7-4337-a2b4-918c8925b566', u'ip-<something>:31cc84ff-f305-4669-9dc3-31ebd44d6b9a', u'ip-<something>:04e221d3-c958-4205-b228-0fbe16f3e30e', u'ip-<something>:b8728974-9e01-46b3-9f57-dc51b1b44fcc', u'ip-<something>:88fa1d4a-c99f-45e0-8d4a-caad | |
| 538ef009', u'ip-<something>:b0e99e3f-1c4b-4936-997d-5834dfe22b20', u'ip-<something>:a13ed8bc-9878-4fdb-92a6-735b5d6a6cf5', u'ip-<something>:86b4e98e-0442-49be-8213-c1222922a2a3', u'ip-<something>:e16ce444-7c2c-4582-918e-d0daa52022e3', u'ip-<something>:79c83ecd | |
| -dcbb-4c86-90fe-a02f12c0b742', u'ip-<something>:10230048-236a-4747-b241-7f18a9bba572', u'ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', u'ip-<something>:92807851-8a19-4948-85ee-564485e78fee', u'ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', u'ip-<something> | |
| 166-138-183:0b8395bc-8fd1-424d-90fc-e6903bd741b5', u'ip-<something>:b19e5276-26dc-4c7a-9b98-505c8a8f32f9', u'ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881'] | |
| [2017-01-19 14:47:43,565 INFO T:MainThread F:_rebalance] Rebalancing consumer "ip-<something>:a13ed8bc-9878-4fdb-92a6-735b5d6a6cf5" for topic "celeryip-<something>.celery.pidbox". | |
| [2017-01-19 14:47:43,565 DEBUG T:Thread-26 F:log] Sending request(xid=6): GetChildren(path='/consumers/kombu-consumer-group/ids', watcher=None) | |
| [2017-01-19 14:47:43,566 DEBUG T:Thread-26 F:_read_response] Received response(xid=6): [u'ip-<something>:58b286cf-3fc7-4ed7-a7d0-f5594a66faf8', u'ip-<something>:e89c8d45-a1e1-4bbb-b459-364d21b45daf', u'ip-<something>:48008500-4346-46e8-a17b-374d94963230', u'ip-<something> | |
| 44-173-75:b35431a4-94d7-4337-a2b4-918c8925b566', u'ip-<something>:31cc84ff-f305-4669-9dc3-31ebd44d6b9a', u'ip-<something>:04e221d3-c958-4205-b228-0fbe16f3e30e', u'ip-<something>:b8728974-9e01-46b3-9f57-dc51b1b44fcc', u'ip-<something>:88fa1d4a-c99f-45e0-8d4a-caad | |
| 538ef009', u'ip-<something>:b0e99e3f-1c4b-4936-997d-5834dfe22b20', u'ip-<something>:a13ed8bc-9878-4fdb-92a6-735b5d6a6cf5', u'ip-<something>:86b4e98e-0442-49be-8213-c1222922a2a3', u'ip-<something>:e16ce444-7c2c-4582-918e-d0daa52022e3', u'ip-<something>:79c83ecd | |
| -dcbb-4c86-90fe-a02f12c0b742', u'ip-<something>:10230048-236a-4747-b241-7f18a9bba572', u'ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', u'ip-<something>:92807851-8a19-4948-85ee-564485e78fee', u'ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', u'ip-<something> | |
| 166-138-183:0b8395bc-8fd1-424d-90fc-e6903bd741b5', u'ip-<something>:b19e5276-26dc-4c7a-9b98-505c8a8f32f9', u'ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881'] | |
| [2017-01-19 14:47:43,567 DEBUG T:Thread-26 F:log] Sending request(xid=7): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:58b286cf-3fc7-4ed7-a7d0-f5594a66faf8', watcher=None) | |
| [2017-01-19 14:47:43,568 DEBUG T:Thread-26 F:_read_response] Received response(xid=7): ('reportqueue', ZnodeStat(czxid=8589982993, mzxid=8589982993, ctime=1484737959459, mtime=1484737959459, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948579, dataLength=1 | |
| 1, numChildren=0, pzxid=8589982993)) | |
| [2017-01-19 14:47:43,568 DEBUG T:Thread-26 F:log] Sending request(xid=8): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:e89c8d45-a1e1-4bbb-b459-364d21b45daf', watcher=None) | |
| [2017-01-19 14:47:43,570 DEBUG T:Thread-26 F:_read_response] Received response(xid=8): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983005, mzxid=8589983005, ctime=1484737961679, mtime=1484737961679, version=0, cversion=0, aversion=0, ephemeralOwner=972132 | |
| 88776948580, dataLength=36, numChildren=0, pzxid=8589983005)) | |
| [2017-01-19 14:47:43,570 DEBUG T:Thread-26 F:log] Sending request(xid=9): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:48008500-4346-46e8-a17b-374d94963230', watcher=None) | |
| [2017-01-19 14:47:43,571 INFO T:Thread-21 F:_rebalance] Rebalancing consumer "ip-<something>:48008500-4346-46e8-a17b-374d94963230" for topic "adsimpressionqueue". | |
| [2017-01-19 14:47:43,572 DEBUG T:Thread-26 F:_read_response] Received response(xid=9): ('adsimpressionqueue', ZnodeStat(czxid=8589990049, mzxid=8589990049, ctime=1484817463365, mtime=1484817463365, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776951804, dataL | |
| ength=18, numChildren=0, pzxid=8589990049)) | |
| [2017-01-19 14:47:43,572 DEBUG T:Thread-22 F:log] Sending request(xid=66): GetChildren(path='/consumers/kombu-consumer-group/ids', watcher=None) | |
| [2017-01-19 14:47:43,572 DEBUG T:Thread-26 F:log] Sending request(xid=10): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b35431a4-94d7-4337-a2b4-918c8925b566', watcher=None) | |
| [2017-01-19 14:47:43,574 DEBUG T:Thread-22 F:_read_response] Received response(xid=66): [u'ip-<something>:58b286cf-3fc7-4ed7-a7d0-f5594a66faf8', u'ip-<something>:e89c8d45-a1e1-4bbb-b459-364d21b45daf', u'ip-<something>:48008500-4346-46e8-a17b-374d94963230', u'ip-<something> | |
| 144-173-75:b35431a4-94d7-4337-a2b4-918c8925b566', u'ip-<something>:31cc84ff-f305-4669-9dc3-31ebd44d6b9a', u'ip-<something>:04e221d3-c958-4205-b228-0fbe16f3e30e', u'ip-<something>:b8728974-9e01-46b3-9f57-dc51b1b44fcc', u'ip-<something>:88fa1d4a-c99f-45e0-8d4a-caa | |
| d538ef009', u'ip-<something>:b0e99e3f-1c4b-4936-997d-5834dfe22b20', u'ip-<something>:a13ed8bc-9878-4fdb-92a6-735b5d6a6cf5', u'ip-<something>:86b4e98e-0442-49be-8213-c1222922a2a3', u'ip-<something>:e16ce444-7c2c-4582-918e-d0daa52022e3', u'ip-<something>:79c83ec | |
| d-dcbb-4c86-90fe-a02f12c0b742', u'ip-<something>:10230048-236a-4747-b241-7f18a9bba572', u'ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', u'ip-<something>:92807851-8a19-4948-85ee-564485e78fee', u'ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', u'ip-<something> | |
| -166-138-183:0b8395bc-8fd1-424d-90fc-e6903bd741b5', u'ip-<something>:b19e5276-26dc-4c7a-9b98-505c8a8f32f9', u'ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881'] | |
| [2017-01-19 14:47:43,574 DEBUG T:Thread-22 F:log] Sending request(xid=67): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:58b286cf-3fc7-4ed7-a7d0-f5594a66faf8', watcher=None) | |
| [2017-01-19 14:47:43,574 DEBUG T:Thread-26 F:_read_response] Received response(xid=10): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983093, mzxid=8589983093, ctime=1484738084047, mtime=1484738084047, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776948604, dataLength=36, numChildren=0, pzxid=8589983093)) | |
| [2017-01-19 14:47:43,576 DEBUG T:Thread-26 F:log] Sending request(xid=11): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:31cc84ff-f305-4669-9dc3-31ebd44d6b9a', watcher=None) | |
| [2017-01-19 14:47:43,577 DEBUG T:Thread-22 F:_read_response] Received response(xid=67): ('reportqueue', ZnodeStat(czxid=8589982993, mzxid=8589982993, ctime=1484737959459, mtime=1484737959459, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948579, dataLength= | |
| 11, numChildren=0, pzxid=8589982993)) | |
| [2017-01-19 14:47:43,578 DEBUG T:Thread-26 F:_read_response] Received response(xid=11): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983339, mzxid=8589983339, ctime=1484738373001, mtime=1484738373001, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776948707, dataLength=37, numChildren=0, pzxid=8589983339)) | |
| [2017-01-19 14:47:43,578 DEBUG T:Thread-26 F:log] Sending request(xid=12): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:04e221d3-c958-4205-b228-0fbe16f3e30e', watcher=None) | |
| [2017-01-19 14:47:43,579 DEBUG T:Thread-26 F:_read_response] Received response(xid=12): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987303, mzxid=8589987303, ctime=1484751404122, mtime=1484751404122, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776950474, dataLength=36, numChildren=0, pzxid=8589987303)) | |
| [2017-01-19 14:47:43,580 DEBUG T:Thread-26 F:log] Sending request(xid=13): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b8728974-9e01-46b3-9f57-dc51b1b44fcc', watcher=None) | |
| [2017-01-19 14:47:43,580 DEBUG T:Thread-22 F:log] Sending request(xid=68): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:e89c8d45-a1e1-4bbb-b459-364d21b45daf', watcher=None) | |
| [2017-01-19 14:47:43,581 DEBUG T:Thread-26 F:_read_response] Received response(xid=13): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983278, mzxid=8589983278, ctime=1484738261800, mtime=1484738261800, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776948686, dataLength=36, numChildren=0, pzxid=8589983278)) | |
| [2017-01-19 14:47:43,582 DEBUG T:Thread-26 F:log] Sending request(xid=14): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:88fa1d4a-c99f-45e0-8d4a-caad538ef009', watcher=None) | |
| [2017-01-19 14:47:43,582 DEBUG T:Thread-22 F:_read_response] Received response(xid=68): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983005, mzxid=8589983005, ctime=1484737961679, mtime=1484737961679, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776948580, dataLength=36, numChildren=0, pzxid=8589983005)) | |
| [2017-01-19 14:47:43,582 DEBUG T:Thread-22 F:log] Sending request(xid=69): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:48008500-4346-46e8-a17b-374d94963230', watcher=None) | |
| [2017-01-19 14:47:43,583 DEBUG T:Thread-26 F:_read_response] Received response(xid=14): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983366, mzxid=8589983366, ctime=1484738424188, mtime=1484738424188, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776948715, dataLength=37, numChildren=0, pzxid=8589983366)) | |
| [2017-01-19 14:47:43,583 DEBUG T:Thread-26 F:log] Sending request(xid=15): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b0e99e3f-1c4b-4936-997d-5834dfe22b20', watcher=None) | |
| [2017-01-19 14:47:43,584 DEBUG T:Thread-22 F:_read_response] Received response(xid=69): ('adsimpressionqueue', ZnodeStat(czxid=8589990049, mzxid=8589990049, ctime=1484817463365, mtime=1484817463365, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776951804, data | |
| Length=18, numChildren=0, pzxid=8589990049)) | |
| [2017-01-19 14:47:43,584 DEBUG T:Thread-22 F:log] Sending request(xid=70): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b35431a4-94d7-4337-a2b4-918c8925b566', watcher=None) | |
| [2017-01-19 14:47:43,585 DEBUG T:Thread-26 F:_read_response] Received response(xid=15): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987344, mzxid=8589987344, ctime=1484751539804, mtime=1484751539804, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776950489, dataLength=36, numChildren=0, pzxid=8589987344)) | |
| [2017-01-19 14:47:43,585 DEBUG T:Thread-26 F:log] Sending request(xid=16): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:a13ed8bc-9878-4fdb-92a6-735b5d6a6cf5', watcher=None) | |
| [2017-01-19 14:47:43,586 DEBUG T:Thread-22 F:_read_response] Received response(xid=70): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983093, mzxid=8589983093, ctime=1484738084047, mtime=1484738084047, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776948604, dataLength=36, numChildren=0, pzxid=8589983093)) | |
| [2017-01-19 14:47:43,586 DEBUG T:Thread-22 F:log] Sending request(xid=71): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:31cc84ff-f305-4669-9dc3-31ebd44d6b9a', watcher=None) | |
| [2017-01-19 14:47:43,587 DEBUG T:Thread-26 F:_read_response] Received response(xid=16): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589990106, mzxid=8589990106, ctime=1484817463568, mtime=1484817463568, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776951831, dataLength=37, numChildren=0, pzxid=8589990106)) | |
| [2017-01-19 14:47:43,587 DEBUG T:Thread-26 F:log] Sending request(xid=17): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:86b4e98e-0442-49be-8213-c1222922a2a3', watcher=None) | |
| [2017-01-19 14:47:43,587 DEBUG T:Thread-22 F:_read_response] Received response(xid=71): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983339, mzxid=8589983339, ctime=1484738373001, mtime=1484738373001, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776948707, dataLength=37, numChildren=0, pzxid=8589983339)) | |
| [2017-01-19 14:47:43,588 DEBUG T:Thread-22 F:log] Sending request(xid=72): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:04e221d3-c958-4205-b228-0fbe16f3e30e', watcher=None) | |
| [2017-01-19 14:47:43,588 DEBUG T:Thread-26 F:_read_response] Received response(xid=17): ('reportqueue', ZnodeStat(czxid=8589983082, mzxid=8589983082, ctime=1484738083857, mtime=1484738083857, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948603, dataLength= | |
| 11, numChildren=0, pzxid=8589983082)) | |
| [2017-01-19 14:47:43,589 DEBUG T:Thread-26 F:log] Sending request(xid=18): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:e16ce444-7c2c-4582-918e-d0daa52022e3', watcher=None) | |
| [2017-01-19 14:47:43,589 DEBUG T:Thread-22 F:_read_response] Received response(xid=72): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987303, mzxid=8589987303, ctime=1484751404122, mtime=1484751404122, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776950474, dataLength=36, numChildren=0, pzxid=8589987303)) | |
| [2017-01-19 14:47:43,589 DEBUG T:Thread-22 F:log] Sending request(xid=73): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b8728974-9e01-46b3-9f57-dc51b1b44fcc', watcher=None) | |
| [2017-01-19 14:47:43,590 DEBUG T:Thread-26 F:_read_response] Received response(xid=18): ('reportqueue', ZnodeStat(czxid=8589983269, mzxid=8589983269, ctime=1484738261629, mtime=1484738261629, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948685, dataLength= | |
| 11, numChildren=0, pzxid=8589983269)) | |
| [2017-01-19 14:47:43,590 DEBUG T:Thread-26 F:log] Sending request(xid=19): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:79c83ecd-dcbb-4c86-90fe-a02f12c0b742', watcher=None) | |
| [2017-01-19 14:47:43,591 DEBUG T:Thread-22 F:_read_response] Received response(xid=73): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983278, mzxid=8589983278, ctime=1484738261800, mtime=1484738261800, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776948686, dataLength=36, numChildren=0, pzxid=8589983278)) | |
| [2017-01-19 14:47:43,592 DEBUG T:Thread-22 F:log] Sending request(xid=74): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:88fa1d4a-c99f-45e0-8d4a-caad538ef009', watcher=None) | |
| [2017-01-19 14:47:43,592 DEBUG T:Thread-26 F:_read_response] Received response(xid=19): ('adsimpressionqueue', ZnodeStat(czxid=8589983334, mzxid=8589983334, ctime=1484738372853, mtime=1484738372853, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948706, data | |
| Length=18, numChildren=0, pzxid=8589983334)) | |
| [2017-01-19 14:47:43,592 DEBUG T:Thread-26 F:log] Sending request(xid=20): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:10230048-236a-4747-b241-7f18a9bba572', watcher=None) | |
| [2017-01-19 14:47:43,593 DEBUG T:Thread-22 F:_read_response] Received response(xid=74): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589983366, mzxid=8589983366, ctime=1484738424188, mtime=1484738424188, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776948715, dataLength=37, numChildren=0, pzxid=8589983366)) | |
| [2017-01-19 14:47:43,594 DEBUG T:Thread-26 F:_read_response] Received response(xid=20): ('adsimpressionqueue', ZnodeStat(czxid=8589987264, mzxid=8589987264, ctime=1484751296214, mtime=1484751296214, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950465, data | |
| Length=18, numChildren=0, pzxid=8589987264)) | |
| [2017-01-19 14:47:43,594 DEBUG T:Thread-26 F:log] Sending request(xid=21): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', watcher=None) | |
| [2017-01-19 14:47:43,596 DEBUG T:Thread-26 F:_read_response] Received response(xid=21): ('adsimpressionqueue', ZnodeStat(czxid=8589987364, mzxid=8589987364, ctime=1484751622280, mtime=1484751622280, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950497, data | |
| Length=18, numChildren=0, pzxid=8589987364)) | |
| [2017-01-19 14:47:43,596 DEBUG T:Thread-22 F:log] Sending request(xid=75): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b0e99e3f-1c4b-4936-997d-5834dfe22b20', watcher=None) | |
| [2017-01-19 14:47:43,597 DEBUG T:Thread-26 F:log] Sending request(xid=22): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:92807851-8a19-4948-85ee-564485e78fee', watcher=None) | |
| [2017-01-19 14:47:43,598 DEBUG T:Thread-22 F:_read_response] Received response(xid=75): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987344, mzxid=8589987344, ctime=1484751539804, mtime=1484751539804, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776950489, dataLength=36, numChildren=0, pzxid=8589987344)) | |
| [2017-01-19 14:47:43,598 DEBUG T:Thread-22 F:log] Sending request(xid=76): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:a13ed8bc-9878-4fdb-92a6-735b5d6a6cf5', watcher=None) | |
| [2017-01-19 14:47:43,599 DEBUG T:Thread-26 F:_read_response] Received response(xid=22): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987378, mzxid=8589987378, ctime=1484751622445, mtime=1484751622445, version=0, cversion=0, aversion=0, ephemeralOwner=97213 | |
| 288776950498, dataLength=36, numChildren=0, pzxid=8589987378)) | |
| [2017-01-19 14:47:43,599 DEBUG T:Thread-26 F:log] Sending request(xid=23): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', watcher=None) | |
| [2017-01-19 14:47:43,600 DEBUG T:Thread-22 F:_read_response] Received response(xid=76): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589990106, mzxid=8589990106, ctime=1484817463568, mtime=1484817463568, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776951831, dataLength=37, numChildren=0, pzxid=8589990106)) | |
| [2017-01-19 14:47:43,600 DEBUG T:Thread-22 F:log] Sending request(xid=77): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:86b4e98e-0442-49be-8213-c1222922a2a3', watcher=None) | |
| [2017-01-19 14:47:43,601 DEBUG T:Thread-26 F:_read_response] Received response(xid=23): ('adsimpressionqueue', ZnodeStat(czxid=8589987290, mzxid=8589987290, ctime=1484751403975, mtime=1484751403975, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950473, data | |
| Length=18, numChildren=0, pzxid=8589987290)) | |
| [2017-01-19 14:47:43,602 DEBUG T:Thread-26 F:log] Sending request(xid=24): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:0b8395bc-8fd1-424d-90fc-e6903bd741b5', watcher=None) | |
| [2017-01-19 14:47:43,605 DEBUG T:Thread-22 F:_read_response] Received response(xid=77): ('reportqueue', ZnodeStat(czxid=8589983082, mzxid=8589983082, ctime=1484738083857, mtime=1484738083857, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948603, dataLength= | |
| 11, numChildren=0, pzxid=8589983082)) | |
| [2017-01-19 14:47:43,606 DEBUG T:Thread-26 F:_read_response] Received response(xid=24): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987275, mzxid=8589987275, ctime=1484751296379, mtime=1484751296379, version=0, cversion=0, aversion=0, ephemeralOwner=9721 | |
| 3288776950466, dataLength=37, numChildren=0, pzxid=8589987275)) | |
| [2017-01-19 14:47:43,606 DEBUG T:Thread-26 F:log] Sending request(xid=25): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b19e5276-26dc-4c7a-9b98-505c8a8f32f9', watcher=None) | |
| [2017-01-19 14:47:43,608 DEBUG T:Thread-22 F:log] Sending request(xid=78): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:e16ce444-7c2c-4582-918e-d0daa52022e3', watcher=None) | |
| [2017-01-19 14:47:43,608 DEBUG T:Thread-26 F:_read_response] Received response(xid=25): ('reportqueue', ZnodeStat(czxid=8589983354, mzxid=8589983354, ctime=1484738423901, mtime=1484738423901, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948714, dataLength= | |
| 11, numChildren=0, pzxid=8589983354)) | |
| [2017-01-19 14:47:43,609 DEBUG T:Thread-26 F:log] Sending request(xid=26): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881', watcher=None) | |
| [2017-01-19 14:47:43,609 DEBUG T:Thread-22 F:_read_response] Received response(xid=78): ('reportqueue', ZnodeStat(czxid=8589983269, mzxid=8589983269, ctime=1484738261629, mtime=1484738261629, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948685, dataLength= | |
| 11, numChildren=0, pzxid=8589983269)) | |
| [2017-01-19 14:47:43,610 DEBUG T:Thread-22 F:log] Sending request(xid=79): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:79c83ecd-dcbb-4c86-90fe-a02f12c0b742', watcher=None) | |
| [2017-01-19 14:47:43,610 DEBUG T:Thread-26 F:_read_response] Received response(xid=26): ('adsimpressionqueue', ZnodeStat(czxid=8589987334, mzxid=8589987334, ctime=1484751539655, mtime=1484751539655, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950488, data | |
| Length=18, numChildren=0, pzxid=8589987334)) | |
| [2017-01-19 14:47:43,610 INFO T:MainThread F:_decide_partitions] ip-<something>:a13ed8bc-9878-4fdb-92a6-735b5d6a6cf5: Balancing 2 participants for 1 partitions. Owning 0 partitions. | |
| [2017-01-19 14:47:43,610 DEBUG T:MainThread F:_decide_partitions] My partitions: [] | |
| [2017-01-19 14:47:43,610 WARNING T:MainThread F:_update_member_assignment] No partitions assigned to consumer ip-<something>:a13ed8bc-9878-4fdb-92a6-735b5d6a6cf5 | |
| [2017-01-19 14:47:43,611 DEBUG T:Thread-26 F:log] Sending request(xid=27): GetChildren(path='/consumers/kombu-consumer-group/owners/celeryip-<something>.celery.pidbox', watcher=None) | |
| [2017-01-19 14:47:43,611 DEBUG T:Thread-22 F:_read_response] Received response(xid=79): ('adsimpressionqueue', ZnodeStat(czxid=8589983334, mzxid=8589983334, ctime=1484738372853, mtime=1484738372853, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948706, data | |
| Length=18, numChildren=0, pzxid=8589983334)) | |
| [2017-01-19 14:47:43,611 DEBUG T:Thread-22 F:log] Sending request(xid=80): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:10230048-236a-4747-b241-7f18a9bba572', watcher=None) | |
| [2017-01-19 14:47:43,612 DEBUG T:Thread-26 F:_read_response] Received response(xid=27): [u'1-0'] | |
| [2017-01-19 14:47:43,612 DEBUG T:Thread-26 F:log] Sending request(xid=28): GetData(path='/consumers/kombu-consumer-group/owners/celeryip-<something>.celery.pidbox/1-0', watcher=None) | |
| [2017-01-19 14:47:43,613 DEBUG T:Thread-22 F:_read_response] Received response(xid=80): ('adsimpressionqueue', ZnodeStat(czxid=8589987264, mzxid=8589987264, ctime=1484751296214, mtime=1484751296214, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950465, data | |
| Length=18, numChildren=0, pzxid=8589987264)) | |
| [2017-01-19 14:47:43,613 DEBUG T:Thread-22 F:log] Sending request(xid=81): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', watcher=None) | |
| [2017-01-19 14:47:43,614 DEBUG T:Thread-26 F:_read_response] Received response(xid=28): ('ip-<something>:88fa1d4a-c99f-45e0-8d4a-caad538ef009', ZnodeStat(czxid=8589986750, mzxid=8589986750, ctime=1484749210791, mtime=1484749210791, version=0, cversion=0, aversion=0, ep | |
| hemeralOwner=97213288776948715, dataLength=54, numChildren=0, pzxid=8589986750)) | |
| [2017-01-19 14:47:43,614 INFO T:MainThread F:_update_member_assignment] Rebalancing Complete. | |
| [2017-01-19 14:47:43,615 DEBUG T:Thread-22 F:_read_response] Received response(xid=81): ('adsimpressionqueue', ZnodeStat(czxid=8589987364, mzxid=8589987364, ctime=1484751622280, mtime=1484751622280, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950497, dataLength=18, numChildren=0, pzxid=8589987364)) | |
| [2017-01-19 14:47:43,615 DEBUG T:Thread-22 F:log] Sending request(xid=82): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:92807851-8a19-4948-85ee-564485e78fee', watcher=None) | |
| [2017-01-19 14:47:43,617 DEBUG T:Thread-22 F:_read_response] Received response(xid=82): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987378, mzxid=8589987378, ctime=1484751622445, mtime=1484751622445, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950498, dataLength=36, numChildren=0, pzxid=8589987378)) | |
| [2017-01-19 14:47:43,618 DEBUG T:Thread-22 F:log] Sending request(xid=83): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', watcher=None) | |
| [2017-01-19 14:47:43,620 DEBUG T:Thread-22 F:_read_response] Received response(xid=83): ('adsimpressionqueue', ZnodeStat(czxid=8589987290, mzxid=8589987290, ctime=1484751403975, mtime=1484751403975, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950473, dataLength=18, numChildren=0, pzxid=8589987290)) | |
| [2017-01-19 14:47:43,621 DEBUG T:Thread-22 F:log] Sending request(xid=84): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:0b8395bc-8fd1-424d-90fc-e6903bd741b5', watcher=None) | |
| [2017-01-19 14:47:43,624 DEBUG T:Thread-22 F:_read_response] Received response(xid=84): ('celeryip-<something>.celery.pidbox', ZnodeStat(czxid=8589987275, mzxid=8589987275, ctime=1484751296379, mtime=1484751296379, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950466, dataLength=37, numChildren=0, pzxid=8589987275)) | |
| [2017-01-19 14:47:43,626 DEBUG T:Thread-22 F:log] Sending request(xid=85): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b19e5276-26dc-4c7a-9b98-505c8a8f32f9', watcher=None) | |
| [2017-01-19 14:47:43,627 DEBUG T:Thread-22 F:_read_response] Received response(xid=85): ('reportqueue', ZnodeStat(czxid=8589983354, mzxid=8589983354, ctime=1484738423901, mtime=1484738423901, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948714, dataLength=11, numChildren=0, pzxid=8589983354)) | |
| [2017-01-19 14:47:43,628 DEBUG T:Thread-22 F:log] Sending request(xid=86): GetData(path=u'/consumers/kombu-consumer-group/ids/ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881', watcher=None) | |
| [2017-01-19 14:47:43,631 DEBUG T:Thread-22 F:_read_response] Received response(xid=86): ('adsimpressionqueue', ZnodeStat(czxid=8589987334, mzxid=8589987334, ctime=1484751539655, mtime=1484751539655, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950488, dataLength=18, numChildren=0, pzxid=8589987334)) | |
| [2017-01-19 14:47:43,631 INFO T:Thread-21 F:_decide_partitions] ip-<something>:48008500-4346-46e8-a17b-374d94963230: Balancing 6 participants for 8 partitions. Owning 1 partitions. | |
| [2017-01-19 14:47:43,631 DEBUG T:Thread-21 F:_decide_partitions] My partitions: ['adsimpressionqueue-2-1'] | |
| [2017-01-19 14:47:43,632 DEBUG T:Thread-22 F:log] Sending request(xid=87): GetChildren(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue', watcher=None) | |
| [2017-01-19 14:47:43,634 DEBUG T:Thread-22 F:_read_response] Received response(xid=87): [u'1-0', u'0-2', u'2-1', u'1-3', u'0-5', u'2-4', u'1-6', u'2-7'] | |
| [2017-01-19 14:47:43,634 DEBUG T:Thread-22 F:log] Sending request(xid=88): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/1-0', watcher=None) | |
| [2017-01-19 14:47:43,636 DEBUG T:Thread-22 F:_read_response] Received response(xid=88): ('ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', ZnodeStat(czxid=8589987371, mzxid=8589987371, ctime=1484751622390, mtime=1484751622390, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950497, dataLength=53, numChildren=0, pzxid=8589987371)) | |
| [2017-01-19 14:47:43,637 DEBUG T:Thread-22 F:log] Sending request(xid=89): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/0-2', watcher=None) | |
| [2017-01-19 14:47:43,638 DEBUG T:Thread-22 F:_read_response] Received response(xid=89): ('ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881', ZnodeStat(czxid=8589987340, mzxid=8589987340, ctime=1484751539770, mtime=1484751539770, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950488, dataLength=53, numChildren=0, pzxid=8589987340)) | |
| [2017-01-19 14:47:43,639 DEBUG T:Thread-22 F:log] Sending request(xid=90): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/2-1', watcher=None) | |
| [2017-01-19 14:47:43,641 DEBUG T:Thread-22 F:_read_response] Received response(xid=90): ('ip-<something>:48008500-4346-46e8-a17b-374d94963230', ZnodeStat(czxid=8589990093, mzxid=8589990093, ctime=1484817463517, mtime=1484817463517, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776951804, dataLength=54, numChildren=0, pzxid=8589990093)) | |
| [2017-01-19 14:47:43,653 DEBUG T:Thread-22 F:log] Sending request(xid=91): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/1-3', watcher=None) | |
| [2017-01-19 14:47:43,655 DEBUG T:Thread-22 F:_read_response] Received response(xid=91): ('ip-<something>:64652052-55f6-4468-ae8f-fdce0d1f04e8', ZnodeStat(czxid=8589987373, mzxid=8589987373, ctime=1484751622400, mtime=1484751622400, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950497, dataLength=53, numChildren=0, pzxid=8589987373)) | |
| [2017-01-19 14:47:43,655 DEBUG T:Thread-22 F:log] Sending request(xid=92): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/0-5', watcher=None) | |
| [2017-01-19 14:47:43,657 DEBUG T:Thread-22 F:_read_response] Received response(xid=92): ('ip-<something>:b6e450a9-e06a-4504-943a-ea9ee33b1881', ZnodeStat(czxid=8589987342, mzxid=8589987342, ctime=1484751539773, mtime=1484751539773, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950488, dataLength=53, numChildren=0, pzxid=8589987342)) | |
| [2017-01-19 14:47:43,657 DEBUG T:Thread-22 F:log] Sending request(xid=93): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/2-4', watcher=None) | |
| [2017-01-19 14:47:43,660 DEBUG T:Thread-22 F:_read_response] Received response(xid=93): ('ip-<something>:79c83ecd-dcbb-4c86-90fe-a02f12c0b742', ZnodeStat(czxid=8589987376, mzxid=8589987376, ctime=1484751622420, mtime=1484751622420, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776948706, dataLength=54, numChildren=0, pzxid=8589987376)) | |
| [2017-01-19 14:47:43,660 DEBUG T:Thread-22 F:log] Sending request(xid=94): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/1-6', watcher=None) | |
| [2017-01-19 14:47:43,662 DEBUG T:Thread-22 F:_read_response] Received response(xid=94): ('ip-<something>:ca5ed4bf-3a0e-44b0-a195-be4e5534bbd0', ZnodeStat(czxid=8589987374, mzxid=8589987374, ctime=1484751622403, mtime=1484751622403, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950473, dataLength=53, numChildren=0, pzxid=8589987374)) | |
| [2017-01-19 14:47:43,663 DEBUG T:Thread-22 F:log] Sending request(xid=95): GetData(path='/consumers/kombu-consumer-group/owners/adsimpressionqueue/2-7', watcher=None) | |
| [2017-01-19 14:47:43,665 DEBUG T:Thread-22 F:_read_response] Received response(xid=95): ('ip-<something>:10230048-236a-4747-b241-7f18a9bba572', ZnodeStat(czxid=8589987273, mzxid=8589987273, ctime=1484751296307, mtime=1484751296307, version=0, cversion=0, aversion=0, ephemeralOwner=97213288776950465, dataLength=54, numChildren=0, pzxid=8589987273)) | |
| [2017-01-19 14:47:43,665 INFO T:Thread-21 F:_update_member_assignment] Rebalancing Complete. | |
| [2017-01-19 14:47:44,061 INFO T:0: pykafka.RequestHandler.worker for ip-<something>.ap-southeast-1.compute.internal:9092 F:worker] RequestHandler worker: exiting cleanly | |
| [2017-01-19 14:47:44,113 INFO T:4: pykafka.RequestHandler.worker for ip-<something>.ap-southeast-1.compute.internal:9092 F:worker] RequestHandler worker: exiting cleanly | |
| [2017-01-19 14:47:44,255 INFO T:6: pykafka.RequestHandler.worker for ip-<something>.ap-southeast-1.compute.internal:9092 F:worker] RequestHandler worker: exiting cleanly | |
| [2017-01-19 14:47:44,300 INFO T:10: pykafka.RequestHandler.worker for ip-<something>.ap-southeast-1.compute.internal:9092 F:worker] RequestHandler worker: exiting cleanly |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment