{"level":"DEBUG","timestamp":"2018-11-14T08:41:17.456Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":74,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:17.456Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":35,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:17.456Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":36,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.456Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":36,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.456Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":35,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.456Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":39,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.457Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":36,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.457Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":74,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.457Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":75,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.458Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":75,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.458Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.460Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":40,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.460Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":37,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.460Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":76,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.460Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":36,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:22.460Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":37,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.460Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":40,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.461Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":37,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.461Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":37,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.461Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":36,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.477Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":76,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.477Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":77,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.478Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":77,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.478Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.479Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":41,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.479Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":38,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.479Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":78,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.479Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":37,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:27.479Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":38,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.479Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":38,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.480Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":41,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.481Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":37,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.486Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":78,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.512Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":38,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.512Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":79,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.513Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":79,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.513Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.514Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":42,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.514Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":39,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.514Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":80,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.514Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":38,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:32.514Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":39,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.514Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":80,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.515Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":42,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.515Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":39,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.516Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":38,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.518Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":39,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.519Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":81,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.519Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":81,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.519Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.520Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":43,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.520Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":40,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.520Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":82,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.520Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":39,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:37.520Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":40,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.520Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":43,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.521Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":40,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.521Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":40,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.521Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":82,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.522Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":39,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.522Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":83,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.528Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":83,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.528Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.530Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":44,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.531Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":41,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.531Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":84,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.531Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":40,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:42.531Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":41,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.531Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":41,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.531Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":40,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.532Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":84,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.532Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":41,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.533Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":44,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.533Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":85,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.533Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":85,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.533Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.534Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":45,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.534Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":42,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.534Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":86,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.534Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":41,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:47.534Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":42,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.535Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":45,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.535Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":41,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.536Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":42,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.536Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":86,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.538Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":42,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.538Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":87,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.538Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":87,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.539Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.539Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":46,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.540Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":43,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.540Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":88,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.540Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":42,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:52.540Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":43,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.540Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":88,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.540Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":42,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.540Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":43,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.541Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":46,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.542Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":43,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.542Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":89,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.542Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":89,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.543Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.543Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":47,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.543Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":44,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.544Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":90,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.544Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":43,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:41:57.544Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":44,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.544Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":44,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.544Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":44,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.544Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":43,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.545Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":47,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.545Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":90,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.545Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":91,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.546Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":91,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.546Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.548Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":48,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.548Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":45,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.549Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":92,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.549Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":44,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:02.549Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":45,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.549Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":44,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.549Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":92,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.550Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":45,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.550Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":48,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.550Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":45,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.551Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":93,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.552Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":93,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.552Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.553Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":49,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.553Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":46,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.554Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":94,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.554Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":45,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:07.554Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":46,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.554Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":46,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.555Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":45,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.556Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":94,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.556Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":49,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.557Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":46,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.557Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":95,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.561Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":95,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.561Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.562Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":50,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.562Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":47,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.563Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":96,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.563Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":46,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:12.563Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":47,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.564Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":50,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.564Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":96,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.564Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":47,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.564Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":46,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.564Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":47,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.564Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":97,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.565Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":97,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.565Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.566Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":51,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.566Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":48,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.566Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":98,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.566Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":47,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:17.566Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":48,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.566Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":98,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.567Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":47,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.567Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":51,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.567Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":48,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.568Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":48,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.569Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":99,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.569Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":99,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.569Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.570Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":52,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.570Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":49,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.570Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":100,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.570Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":48,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:22.570Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":49,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.570Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":52,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.571Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":49,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.571Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":49,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.571Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":48,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.572Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":100,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.572Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":101,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.572Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":101,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.572Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.573Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":53,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.573Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":50,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.573Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":102,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.573Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":49,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:27.573Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":50,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.574Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":53,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.574Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":102,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.574Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":50,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.574Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":49,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.575Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":50,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.575Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":103,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.575Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":103,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.576Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.576Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":54,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.576Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":51,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.577Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":104,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.577Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":50,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:32.577Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":51,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.576Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":54,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.577Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":51,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.577Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":51,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.577Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":104,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.578Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":50,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.578Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":105,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.579Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":105,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.579Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.580Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":55,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.580Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":52,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.580Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":106,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.580Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":51,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:37.580Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":52,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.580Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":52,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.581Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":52,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.581Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":51,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.581Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":55,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.582Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":106,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.582Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":107,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.582Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":107,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.582Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.583Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":56,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.583Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":53,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.583Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":108,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.583Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":52,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:42.583Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":53,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.584Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":53,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.584Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":56,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.584Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":53,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.584Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":108,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.585Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":52,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.585Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":109,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.586Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":109,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.586Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.587Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":57,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.587Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":54,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.587Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":110,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.587Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":53,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:47.587Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":54,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.587Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":57,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.588Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":54,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.588Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":110,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.589Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":54,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.589Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":53,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.589Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":111,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.590Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":111,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.590Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.590Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":58,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.591Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":55,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.591Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":112,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.591Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":54,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:52.591Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":55,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.591Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":55,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.591Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":58,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.592Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":112,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.592Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":55,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.592Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":54,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.592Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":113,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.592Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":113,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.593Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.593Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":59,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.593Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":56,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.593Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":114,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.594Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":55,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:42:57.594Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":56,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.594Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":59,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.594Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":56,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.595Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":55,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.596Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":114,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.596Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":56,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.596Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":115,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.596Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":115,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.597Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.597Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":60,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.597Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":57,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.597Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":116,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.598Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":56,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:02.598Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":57,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.598Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":60,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.598Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":57,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.599Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":57,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.599Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":116,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.599Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":56,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.599Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":117,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.600Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":117,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.600Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.602Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":61,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.602Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":58,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.602Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":118,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.602Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":57,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:07.602Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":58,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.602Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":118,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.604Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":61,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.605Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":57,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.605Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":58,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.606Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":58,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.606Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":119,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.606Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":119,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.607Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.608Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":62,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.608Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":59,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.608Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":120,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.608Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":58,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:12.608Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":59,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.609Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":58,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.610Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":120,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.610Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":62,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.610Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":59,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.611Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":59,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.611Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":121,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.612Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":121,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.612Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.613Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":63,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.613Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":60,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.613Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":122,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.613Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":59,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:17.613Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":60,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.613Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":122,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.614Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":63,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.614Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":60,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.614Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":60,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.615Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":59,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.615Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":123,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.617Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":123,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.617Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.618Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":64,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.618Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":61,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.618Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":124,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.618Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":60,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:22.618Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":61,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.619Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":124,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.619Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":64,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.619Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":61,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.619Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":61,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.619Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":60,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.620Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":125,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.620Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":125,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.620Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.621Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":65,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.621Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":62,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.621Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":126,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.621Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":61,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:27.621Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":62,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.621Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":126,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.621Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":65,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.622Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":61,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.622Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":62,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.623Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":62,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.623Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":127,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.624Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":127,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.624Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.625Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":66,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.625Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":63,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.625Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":128,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.625Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":62,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:32.625Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":63,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.625Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":63,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.625Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":128,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.625Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":66,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.626Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":62,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.627Z","logger":"kafkajs","message":"[Connection] Response Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":63,"size":90,"data":"[filtered]"}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.627Z","logger":"kafkajs","message":"[Connection] Request Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":129,"expectResponse":true,"size":137}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.627Z","logger":"kafkajs","message":"[Connection] Response Heartbeat(key: 12, version: 0)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":129,"size":6,"data":{"errorCode":0}}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.628Z","logger":"kafkajs","message":"[ConsumerGroup] Fetching from 1 out of 1 topics","topics":["test_html_v3"],"activeTopics":["test_html_v3"],"pausedTopics":[]}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.628Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka1.com:9092","clientId":"kafka-reader","correlationId":67,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.628Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka2.com:9092","clientId":"kafka-reader","correlationId":64,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.628Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka5.com:9092","clientId":"kafka-reader","correlationId":130,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.628Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka4.com:9092","clientId":"kafka-reader","correlationId":63,"expectResponse":true,"size":111}
{"level":"DEBUG","timestamp":"2018-11-14T08:43:37.628Z","logger":"kafkajs","message":"[Connection] Request Fetch(key: 1, version: 4)","broker":"kafka3.com:9092","clientId":"kafka-reader","correlationId":64,"expectResponse":true,"size":111}

It's hard to say what the problem is based on just this log. Could you share the code for how you subscribe to the topic? I suspect that you are not consuming the topic from the beginning, but rather starting from the latest offset. See fromBeginning: https://github.com/tulios/kafkajs#-consuming-messages-from-kafka

@Nevon I am consuming from the latest offset. Is that a problem? I assumed if the offsets aren't found, the consumer would start consuming from offset 0.

The consumer group will consume from the latest committed offset. If there are no offsets committed, it will either start from the beginning or from the end of the topic, depending on the fromBeginning flag. If you set that flag to true, you'll see some messages being consumed.

@Nevon So with fromBeginning: true, the consumer will read from the latest offset, and if there are no offsets, it will read from the beginning. Am I understanding this correctly?

That's exactly right.

@Nevon Ah, okay. I assumed the option was to force consumers to always read from offset 0. Do you think that should be explicitly mentioned in the README? I can send a PR if you think it is worthwhile.

Reading through the readme now, it isn't very clear what reading from the beginning means, so it should probably be more explicit. If you could add another section to the Consumer documentation, similar to for example "Pause & Resume", for subscribe, where you explain that the fromBeginning option allows the consumer group to start reading from the earliest available offset if there are no committed offsets to resume from.

@Nevon Cool, I'll do that. Quick question - What's the use-case for this? When fromBeginning is false and there are no offsets, why shouldn't KafkaJS just start reading from offset 0?


Support Canonical Correspondence Analyses

This type of analysis would be an alternative to emperor-based PCoA plots, as I understand it.

For reference, here was a related thread from the QIIME 1 era: https://github.com/biocore/qiime/issues/1183

CCA provides a lot more info than PCoA, including association with explanatory variables (see here), so would be a really cool method to support. AFAIK it's commonly used in soil/ecology research, though I don't know if there are issues with compositionality.

This would be a good thing to support! The technical aspects in emperor need some work but it wouldn't bee too hard to make it happen if we coordinate some concerted effort.

It would be great to see CCA as well as other methods from vegan. I had discussions with vegan creator Jari Oksanen about adapting vegan functions for Python last week in Oulu. Presumably this would be part of q2-diversity rather than a future q2-vegan plugin. Also see issue #123.

Slightly unrelated: I pushed a PR to Emperor with the necessary functionality to display biplots https://github.com/biocore/emperor/pull/646

Jari suggested the main dependencies of the vegan ordination methods are (with their Python implementations):

Single value decomposition (SVD) - numpy.linalg.svd
QR decomposition - scipy.linalg.qr

So I think the main dependencies are in place. I'm cc'ing @mortonjt so he is in the loop.

Thanks @cuttlefishh! Porting these functions to Python would be great, but it is worth pointing out that it isn't a strict requirement for getting them exposed in QIIME 2 as methods. We have the ability to wrap non-python functionality (for examples, check out q2-dada2, q2-phylogeny, and q2-alignment, to name a few). The only real requirement for official QIIME 2 plugins is that the dependencies are available via conda - but that is only for our official plugins - unofficial plugins are welcome to do whatever they want for dependencies.

Just curious if this was added as a plugin to qiime diversity ?

No, not yet - are you interested in contributing?


fixed the events list on events landing (IE7)

@sparkdevelopment can you review?

@marcincichon Looks good


Random Name Generator using Vanilla JS

Pull Request for WebMasterLog 💡
Issue Title: Random Name Generator using Vanilla JS

Name of the project : Random Name Generator
Category: Vanilla-JS
Name: Sohan RoyChowdhury.
GitHub ID: https://github.com/SohanRC
Idenitfy yourself: JWOC

Closes:
#65
Describe the add-ons or changes you've made 📃
Made a Random Name Generator Project which generates names of random people based on the gender provided by the user as input.
Type of change ☑

What sort of change have you made:

[X] New feature (non-breaking change which adds functionality)

How Has This Been Tested? ⚙
Tested In on local System and It worked perfectly !
Checklist: ☑

[X] My code follows the Contributing Guidelines & Code of Conduct of this project.
[X] This PR does not contain plagiarized content.
[X] I have performed a self-review of my own code.
[X] I have commented my code, particularly wherever it was hard to understand.
[X] I have made corresponding changes to the documentation.
[X] My changes generate no new warnings.
[X] I have added things that prove my fix is effective or that my feature works.
[X] Any dependent changes have been merged and published in downstream modules.

Screenshots 📷

Note to reviewers 📄

@Avdhesh-Varshney Please review this PR !!

@Avdhesh-Varshney Please review this PR

@Avdhesh-Varshney Please check now


bees: 0.6.2 -> 0.6.3

Motivation for this change
Update bees to the latest version: https://github.com/Zygo/bees/releases
Things done

[x] Tested using sandboxing (nix.useSandbox on NixOS, or option sandbox in nix.conf on non-NixOS linux)
Built on platform(s)

[x] NixOS
[ ] macOS
[ ] other Linux distributions

[x] Tested via one or more NixOS test(s) if existing and applicable for the change (look inside nixos/tests)
[x] Tested compilation of all pkgs that depend on this change using nix-shell -p nixpkgs-review --run "nixpkgs-review wip"
[x] Tested execution of all binary files (usually in ./result/bin/)
[ ] Determined the impact on package closure size (by running nix path-info -S before and after)
[ ] Ensured that relevant documentation is up to date
[x] Fits CONTRIBUTING.md.

Result of nixpkgs-review pr 100257 1

1 package built:

bees

I'm rolling out that change locally to test it. Meanwhile the actual maintainer @charles-dyfis-net should do a review.

I'm rolling out that change locally to test it. Meanwhile the actual maintainer @charles-dyfis-net should do a review.

LGTM! (Thank you for taking care of this -- my apologies for not catching the release and doing the update myself; I've been running a build off master, and thus wasn't watching the stable branch closely).


Include Boringssl fips_fragments files in headers for building (upmerge from v1.10.x)

Upmerges #14515

****************************************************************

libgrpc.so

     VM SIZE        FILE SIZE
 ++++++++++++++  ++++++++++++++

  [ = ]       0        0  [ = ]

****************************************************************

libgrpc++.so

     VM SIZE        FILE SIZE
 ++++++++++++++  ++++++++++++++

  [ = ]       0        0  [ = ]

[trickle] No significant performance differences

[microbenchmarks] No significant performance differences

Windows test failure: #14491


[r] Provide context() accessor

Issue and/or context:
Per #1011 and the spec, an accessor named context() is desired.
Changes:
The existing one is renamed in the R code and the generated Rd documentation.  Tests are not affected.
Notes for Reviewer:
closes #1011
SC 27095

@mlin this has been open for a few days, and I want to merge this on the accept by @johnkerl .
Please let me know if you have any concerns, we can surely address those in a follow-up PR.


Investigate parallelism in EMR steps

Only one step runs at a time right now. That's inconvenient and we should come up with a plan to fix it.

Investigated, initial work done and we have a plan :tada:
Closing in favor of #1746


Running AppImage in Linux installs but loops without launching

Running the AppImage file in Linux prompts for the folder to install and runs through the install script. Once it completes (successfully), the button pops up to "Launch". Clicking the button restarts the install process. There is no way to actually launch the app...

I am also experiencing this unfortunate loop in Ubuntu 22.04. Looking forward to solving this so can get started!

This was resolved in the latest version, thanks again!

I also confirm that this issue is resolved.