gistfile1.txt

2016-07-15 15:56:02,923 - pykafka.producer - DEBUG - Sending 795 messages to broker 12
2016-07-15 15:56:02,927 - pykafka.producer - DEBUG - Sending 949 messages to broker 11
2016-07-15 15:56:03,024 - pykafka.producer - DEBUG - Successfully sent 949/949 messages to broker 11
2016-07-15 15:56:08,025 - pykafka.producer - DEBUG - Sending 60 messages to broker 11
2016-07-15 15:56:08,041 - pykafka.producer - DEBUG - Successfully sent 60/60 messages to broker 11
2016-07-15 15:56:08,041 - pykafka.producer - INFO - Worker exited for broker ue1d-kafka-beta1b.lan.cogtree.com:9092
2016-07-15 15:56:08,041 [INFO] pykafka.producer - Worker exited for broker ue1d-kafka-beta1b.lan.cogtree.com:9092
2016-07-15 15:56:15,000 - pykafka.producer - INFO - Starting new produce worker for broker 11
2016-07-15 15:56:15,000 [INFO] pykafka.producer - Starting new produce worker for broker 11
2016-07-15 15:56:15,006 - pykafka.producer - INFO - Starting new produce worker for broker 12
2016-07-15 15:56:15,006 [INFO] pykafka.producer - Starting new produce worker for broker 12
2016-07-15 15:56:15,007 - pykafka.producer - INFO - Starting new produce worker for broker 10
2016-07-15 15:56:15,007 [INFO] pykafka.producer - Starting new produce worker for broker 10
2016-07-15 15:56:15,008 - pykafka.producer - DEBUG - Re-producing 69875 queued messages after update
2016-07-15 15:56:16,943 - pykafka.producer - WARNING - Produce request for raw_pixels_test/2 to ue1d-kafka-beta1a.lan.cogtree.com:9092 failed with error code 6.
2016-07-15 15:56:16,943 [WARNING] pykafka.producer - Produce request for raw_pixels_test/2 to ue1d-kafka-beta1a.lan.cogtree.com:9092 failed with error code 6.
2016-07-15 15:56:16,943 - pykafka.cluster - DEBUG - Updating cluster, attempt 1/3
2016-07-15 15:56:16,944 - pykafka.connection - DEBUG - Connecting to ue1d-kafka-beta1a.lan.cogtree.com:9092
2016-07-15 15:56:16,954 - pykafka.connection - DEBUG - Successfully connected to ue1d-kafka-beta1a.lan.cogtree.com:9092
2016-07-15 15:56:16,996 - pykafka.handlers - INFO - RequestHandler.stop: about to flush requests queue
2016-07-15 15:56:16,996 [INFO] pykafka.handlers - RequestHandler.stop: about to flush requests queue
2016-07-15 15:56:16,998 - pykafka.cluster - INFO - Discovered 3 brokers
2016-07-15 15:56:16,998 [INFO] pykafka.cluster - Discovered 3 brokers
2016-07-15 15:56:16,998 - pykafka.cluster - INFO - Broker ue1d-kafka-beta1a.lan.cogtree.com:9092 metadata unchanged. Continuing.
2016-07-15 15:56:16,998 [INFO] pykafka.cluster - Broker ue1d-kafka-beta1a.lan.cogtree.com:9092 metadata unchanged. Continuing.
2016-07-15 15:56:16,998 - pykafka.cluster - INFO - Broker ue1d-kafka-beta1b.lan.cogtree.com:9092 metadata unchanged. Continuing.
2016-07-15 15:56:16,998 [INFO] pykafka.cluster - Broker ue1d-kafka-beta1b.lan.cogtree.com:9092 metadata unchanged. Continuing.
2016-07-15 15:56:16,998 - pykafka.cluster - INFO - Broker ue1d-kafka-beta1c.lan.cogtree.com:9092 metadata unchanged. Continuing.
2016-07-15 15:56:16,998 [INFO] pykafka.cluster - Broker ue1d-kafka-beta1c.lan.cogtree.com:9092 metadata unchanged. Continuing.
2016-07-15 15:56:16,998 - pykafka.cluster - INFO - Discovered 1 topics
2016-07-15 15:56:16,998 [INFO] pykafka.cluster - Discovered 1 topics
2016-07-15 15:56:16,998 - pykafka.topic - INFO - Adding 200 partitions
2016-07-15 15:56:16,998 [INFO] pykafka.topic - Adding 200 partitions
2016-07-15 15:56:16,999 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770990 (id=1)>
2016-07-15 15:56:16,999 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770990 (id=1)>
2016-07-15 15:56:17,000 - pykafka.partition - INFO - Updating leader for <pykafka.partition.Partition at 0x27703d0 (id=2)> from broker 12 to broker 10
2016-07-15 15:56:17,000 [INFO] pykafka.partition - Updating leader for <pykafka.partition.Partition at 0x27703d0 (id=2)> from broker 12 to broker 10
2016-07-15 15:56:17,000 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x27703d0 (id=2)>
2016-07-15 15:56:17,000 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x27703d0 (id=2)>
2016-07-15 15:56:17,001 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x27709d0 (id=4)>
2016-07-15 15:56:17,001 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x27709d0 (id=4)>
2016-07-15 15:56:17,002 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770a90 (id=7)>
2016-07-15 15:56:17,002 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770a90 (id=7)>
2016-07-15 15:56:17,002 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770b50 (id=10)>
2016-07-15 15:56:17,002 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770b50 (id=10)>
2016-07-15 15:56:17,003 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770c10 (id=13)>
2016-07-15 15:56:17,003 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770c10 (id=13)>
2016-07-15 15:56:17,004 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770cd0 (id=16)>
2016-07-15 15:56:17,004 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770cd0 (id=16)>
2016-07-15 15:56:17,005 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770d90 (id=19)>
2016-07-15 15:56:17,005 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770d90 (id=19)>
2016-07-15 15:56:17,006 - pykafka.partition - INFO - Updating leader for <pykafka.partition.Partition at 0x2770dd0 (id=20)> from broker 12 to broker 10
2016-07-15 15:56:17,006 [INFO] pykafka.partition - Updating leader for <pykafka.partition.Partition at 0x2770dd0 (id=20)> from broker 12 to broker 10
2016-07-15 15:56:17,006 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770dd0 (id=20)>
2016-07-15 15:56:17,006 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770dd0 (id=20)>
2016-07-15 15:56:17,007 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770e50 (id=22)>
2016-07-15 15:56:17,007 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770e50 (id=22)>
2016-07-15 15:56:17,007 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770f10 (id=25)>
2016-07-15 15:56:17,007 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770f10 (id=25)>
2016-07-15 15:56:17,008 - pykafka.partition - INFO - Updating leader for <pykafka.partition.Partition at 0x2770f50 (id=26)> from broker 12 to broker 10
2016-07-15 15:56:17,008 [INFO] pykafka.partition - Updating leader for <pykafka.partition.Partition at 0x2770f50 (id=26)> from broker 12 to broker 10
2016-07-15 15:56:17,009 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770f50 (id=26)>
2016-07-15 15:56:17,009 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770f50 (id=26)>
2016-07-15 15:56:17,009 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770fd0 (id=28)>
2016-07-15 15:56:17,009 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2770fd0 (id=28)>
2016-07-15 15:56:17,010 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x27750d0 (id=31)>
2016-07-15 15:56:17,010 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x27750d0 (id=31)>
2016-07-15 15:56:17,011 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775190 (id=34)>
2016-07-15 15:56:17,011 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775190 (id=34)>
2016-07-15 15:56:17,012 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775250 (id=37)>
2016-07-15 15:56:17,012 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775250 (id=37)>
2016-07-15 15:56:17,012 - pykafka.partition - INFO - Updating leader for <pykafka.partition.Partition at 0x2775290 (id=38)> from broker 12 to broker 10
2016-07-15 15:56:17,012 [INFO] pykafka.partition - Updating leader for <pykafka.partition.Partition at 0x2775290 (id=38)> from broker 12 to broker 10
2016-07-15 15:56:17,013 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775290 (id=38)>
2016-07-15 15:56:17,013 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775290 (id=38)>
2016-07-15 15:56:17,013 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775310 (id=40)>
2016-07-15 15:56:17,013 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775310 (id=40)>
2016-07-15 15:56:17,014 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x27753d0 (id=43)>
2016-07-15 15:56:17,014 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x27753d0 (id=43)>
2016-07-15 15:56:17,015 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775490 (id=46)>
2016-07-15 15:56:17,015 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775490 (id=46)>
2016-07-15 15:56:17,016 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775550 (id=49)>
2016-07-15 15:56:17,016 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775550 (id=49)>
2016-07-15 15:56:17,017 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775610 (id=52)>
2016-07-15 15:56:17,017 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775610 (id=52)>
2016-07-15 15:56:17,017 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x27756d0 (id=55)>
2016-07-15 15:56:17,017 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x27756d0 (id=55)>
2016-07-15 15:56:17,019 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775850 (id=61)>
2016-07-15 15:56:17,019 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775850 (id=61)>
2016-07-15 15:56:17,028 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775a90 (id=70)>
2016-07-15 15:56:17,028 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775a90 (id=70)>
2016-07-15 15:56:17,029 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775b50 (id=73)>
2016-07-15 15:56:17,029 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775b50 (id=73)>
2016-07-15 15:56:17,029 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775c10 (id=76)>
2016-07-15 15:56:17,029 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775c10 (id=76)>
2016-07-15 15:56:17,030 - pykafka.partition - INFO - Updating leader for <pykafka.partition.Partition at 0x2775c50 (id=77)> from broker 12 to broker 10
2016-07-15 15:56:17,030 [INFO] pykafka.partition - Updating leader for <pykafka.partition.Partition at 0x2775c50 (id=77)> from broker 12 to broker 10
2016-07-15 15:56:17,031 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775c50 (id=77)>
2016-07-15 15:56:17,031 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775c50 (id=77)>
2016-07-15 15:56:17,031 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775cd0 (id=79)>
2016-07-15 15:56:17,031 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775cd0 (id=79)>
2016-07-15 15:56:17,032 - pykafka.partition - INFO - Updating leader for <pykafka.partition.Partition at 0x2775d10 (id=80)> from broker 12 to broker 10
2016-07-15 15:56:17,032 [INFO] pykafka.partition - Updating leader for <pykafka.partition.Partition at 0x2775d10 (id=80)> from broker 12 to broker 10
2016-07-15 15:56:17,032 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775d10 (id=80)>
2016-07-15 15:56:17,032 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775d10 (id=80)>
2016-07-15 15:56:17,033 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775d90 (id=82)>
2016-07-15 15:56:17,033 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775d90 (id=82)>
2016-07-15 15:56:17,033 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775e50 (id=85)>
2016-07-15 15:56:17,033 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775e50 (id=85)>
2016-07-15 15:56:17,034 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775f10 (id=88)>
2016-07-15 15:56:17,034 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775f10 (id=88)>
2016-07-15 15:56:17,034 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775fd0 (id=91)>
2016-07-15 15:56:17,034 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2775fd0 (id=91)>
2016-07-15 15:56:17,035 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x27780d0 (id=94)>
2016-07-15 15:56:17,035 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x27780d0 (id=94)>
2016-07-15 15:56:17,036 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778190 (id=97)>
2016-07-15 15:56:17,036 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778190 (id=97)>
2016-07-15 15:56:17,036 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778250 (id=100)>
2016-07-15 15:56:17,036 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778250 (id=100)>
2016-07-15 15:56:17,037 - pykafka.partition - INFO - Updating leader for <pykafka.partition.Partition at 0x2778290 (id=101)> from broker 12 to broker 10
2016-07-15 15:56:17,037 [INFO] pykafka.partition - Updating leader for <pykafka.partition.Partition at 0x2778290 (id=101)> from broker 12 to broker 10
2016-07-15 15:56:17,037 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778290 (id=101)>
2016-07-15 15:56:17,037 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778290 (id=101)>
2016-07-15 15:56:17,038 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778310 (id=103)>
2016-07-15 15:56:17,038 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778310 (id=103)>
2016-07-15 15:56:17,039 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x27783d0 (id=106)>
2016-07-15 15:56:17,039 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x27783d0 (id=106)>
2016-07-15 15:56:17,039 - pykafka.partition - INFO - Updating leader for <pykafka.partition.Partition at 0x2778410 (id=107)> from broker 12 to broker 10
2016-07-15 15:56:17,039 [INFO] pykafka.partition - Updating leader for <pykafka.partition.Partition at 0x2778410 (id=107)> from broker 12 to broker 10
2016-07-15 15:56:17,040 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778410 (id=107)>
2016-07-15 15:56:17,040 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778410 (id=107)>
2016-07-15 15:56:17,040 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778490 (id=109)>
2016-07-15 15:56:17,040 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778490 (id=109)>
2016-07-15 15:56:17,041 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778550 (id=112)>
2016-07-15 15:56:17,041 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778550 (id=112)>
2016-07-15 15:56:17,041 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778610 (id=115)>
2016-07-15 15:56:17,041 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778610 (id=115)>
2016-07-15 15:56:17,042 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x27786d0 (id=118)>
2016-07-15 15:56:17,042 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x27786d0 (id=118)>
2016-07-15 15:56:17,042 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778790 (id=121)>
2016-07-15 15:56:17,042 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778790 (id=121)>
2016-07-15 15:56:17,043 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778850 (id=124)>
2016-07-15 15:56:17,043 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778850 (id=124)>
2016-07-15 15:56:17,043 - pykafka.partition - INFO - Updating leader for <pykafka.partition.Partition at 0x2778890 (id=125)> from broker 12 to broker 10
2016-07-15 15:56:17,043 [INFO] pykafka.partition - Updating leader for <pykafka.partition.Partition at 0x2778890 (id=125)> from broker 12 to broker 10
2016-07-15 15:56:17,044 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778890 (id=125)>
2016-07-15 15:56:17,044 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778890 (id=125)>
2016-07-15 15:56:17,045 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778910 (id=127)>
2016-07-15 15:56:17,045 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778910 (id=127)>
2016-07-15 15:56:17,046 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x27789d0 (id=130)>
2016-07-15 15:56:17,046 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x27789d0 (id=130)>
2016-07-15 15:56:17,046 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778a90 (id=133)>
2016-07-15 15:56:17,046 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778a90 (id=133)>
2016-07-15 15:56:17,046 - pykafka.partition - INFO - Updating leader for <pykafka.partition.Partition at 0x2778ad0 (id=134)> from broker 12 to broker 10
2016-07-15 15:56:17,046 [INFO] pykafka.partition - Updating leader for <pykafka.partition.Partition at 0x2778ad0 (id=134)> from broker 12 to broker 10
2016-07-15 15:56:17,051 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778ad0 (id=134)>
2016-07-15 15:56:17,051 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778ad0 (id=134)>
2016-07-15 15:56:17,052 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778b50 (id=136)>
2016-07-15 15:56:17,052 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778b50 (id=136)>
2016-07-15 15:56:17,053 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778c10 (id=139)>
2016-07-15 15:56:17,053 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778c10 (id=139)>
2016-07-15 15:56:17,053 - pykafka.partition - INFO - Updating leader for <pykafka.partition.Partition at 0x2778c50 (id=140)> from broker 12 to broker 10
2016-07-15 15:56:17,053 [INFO] pykafka.partition - Updating leader for <pykafka.partition.Partition at 0x2778c50 (id=140)> from broker 12 to broker 10
2016-07-15 15:56:17,054 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778c50 (id=140)>
2016-07-15 15:56:17,054 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778c50 (id=140)>
2016-07-15 15:56:17,054 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778d90 (id=145)>
2016-07-15 15:56:17,054 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778d90 (id=145)>
2016-07-15 15:56:17,055 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778e50 (id=148)>
2016-07-15 15:56:17,055 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778e50 (id=148)>
2016-07-15 15:56:17,056 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778f10 (id=151)>
2016-07-15 15:56:17,056 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778f10 (id=151)>
2016-07-15 15:56:17,056 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778fd0 (id=154)>
2016-07-15 15:56:17,056 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x2778fd0 (id=154)>
2016-07-15 15:56:17,057 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b190 (id=160)>
2016-07-15 15:56:17,057 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b190 (id=160)>
2016-07-15 15:56:17,057 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b250 (id=163)>
2016-07-15 15:56:17,057 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b250 (id=163)>
2016-07-15 15:56:17,058 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b310 (id=166)>
2016-07-15 15:56:17,058 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b310 (id=166)>
2016-07-15 15:56:17,058 - pykafka.partition - INFO - Updating leader for <pykafka.partition.Partition at 0x277b350 (id=167)> from broker 12 to broker 10
2016-07-15 15:56:17,058 [INFO] pykafka.partition - Updating leader for <pykafka.partition.Partition at 0x277b350 (id=167)> from broker 12 to broker 10
2016-07-15 15:56:17,059 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b350 (id=167)>
2016-07-15 15:56:17,059 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b350 (id=167)>
2016-07-15 15:56:17,060 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b3d0 (id=169)>
2016-07-15 15:56:17,060 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b3d0 (id=169)>
2016-07-15 15:56:17,060 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b490 (id=172)>
2016-07-15 15:56:17,060 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b490 (id=172)>
2016-07-15 15:56:17,061 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b550 (id=175)>
2016-07-15 15:56:17,061 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b550 (id=175)>
2016-07-15 15:56:17,061 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b610 (id=178)>
2016-07-15 15:56:17,061 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b610 (id=178)>
2016-07-15 15:56:17,062 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b6d0 (id=181)>
2016-07-15 15:56:17,062 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b6d0 (id=181)>
2016-07-15 15:56:17,062 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b790 (id=184)>
2016-07-15 15:56:17,062 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b790 (id=184)>
2016-07-15 15:56:17,063 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b850 (id=187)>
2016-07-15 15:56:17,063 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b850 (id=187)>
2016-07-15 15:56:17,064 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b910 (id=190)>
2016-07-15 15:56:17,064 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b910 (id=190)>
2016-07-15 15:56:17,064 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b9d0 (id=193)>
2016-07-15 15:56:17,064 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277b9d0 (id=193)>
2016-07-15 15:56:17,065 - pykafka.partition - INFO - Updating in sync replicas list for <pykafka.partition.Partition at 0x277bb50 (id=199)>
2016-07-15 15:56:17,065 [INFO] pykafka.partition - Updating in sync replicas list for <pykafka.partition.Partition at 0x277bb50 (id=199)>
2016-07-15 15:56:18,004 - pykafka.handlers - INFO - RequestHandler worker: exiting cleanly
2016-07-15 15:56:18,004 [INFO] pykafka.handlers - RequestHandler worker: exiting cleanly
2016-07-15 15:56:20,021 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:56:20,023 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:56:20,024 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:56:20,054 - pykafka.producer - DEBUG - Sending 944 messages to broker 12
2016-07-15 15:56:20,091 - pykafka.producer - DEBUG - Sending 964 messages to broker 10
2016-07-15 15:56:20,091 - pykafka.producer - DEBUG - Sending 946 messages to broker 11
2016-07-15 15:56:20,153 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:56:20,216 - pykafka.producer - WARNING - Broker ue1d-kafka-beta1a.lan.cogtree.com:9092 disconnected. Retrying.
2016-07-15 15:56:20,216 [WARNING] pykafka.producer - Broker ue1d-kafka-beta1a.lan.cogtree.com:9092 disconnected. Retrying.
2016-07-15 15:56:20,261 - pykafka.producer - DEBUG - Successfully sent 946/946 messages to broker 11
2016-07-15 15:56:25,180 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:56:25,269 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:56:25,276 - pykafka.producer - DEBUG - Sending 948 messages to broker 11
2016-07-15 15:56:25,340 - pykafka.producer - DEBUG - Successfully sent 948/948 messages to broker 11
2016-07-15 15:56:30,204 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:56:30,352 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:56:30,409 - pykafka.producer - DEBUG - Sending 949 messages to broker 11
2016-07-15 15:56:30,517 - pykafka.producer - DEBUG - Successfully sent 949/949 messages to broker 11
2016-07-15 15:56:35,213 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:56:35,557 - pykafka.producer - DEBUG - Sending 711 messages to broker 11
2016-07-15 15:56:35,648 - pykafka.producer - DEBUG - Successfully sent 711/711 messages to broker 11
2016-07-15 15:56:40,230 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:56:45,282 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:56:50,310 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:56:55,317 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:57:00,324 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:57:05,329 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:57:10,337 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:57:15,362 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:57:20,388 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:57:25,402 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:57:30,406 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:57:35,410 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:57:40,466 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:57:45,497 - pykafka.producer - DEBUG - max_request_size reached. producing batch
2016-07-15 15:57:50,505 - pykafka.producer - DEBUG - max_request_size reached. producing batch