Skip to content

Instantly share code, notes, and snippets.

@siddharth96

siddharth96/pykafka_logs.log

Last active January 19, 2017 10:55
Show Gist options
  • Save siddharth96/58c9326cd2edd090c47a6641ee76f317 to your computer and use it in GitHub Desktop.
Save siddharth96/58c9326cd2edd090c47a6641ee76f317 to your computer and use it in GitHub Desktop.
Download ZIP
PyKafka logs with use_rdkafka=True
Raw
pykafka_logs.log
[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