2017-01-21 03:45:53,237 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Marking the coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) dead for group edge-creation-group
2017-01-21 03:45:53,238 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) for group edge-creation-group.
2017-01-21 03:45:53,239 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Marking the coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) dead for group event-saved-group
2017-01-21 03:45:53,240 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) for group event-saved-group.
2017-01-21 03:45:53,250 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Marking the coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) dead for group event-saved-group
2017-01-21 03:45:53,251 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) for group event-saved-group.
2017-01-21 03:45:53,254 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Marking the coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) dead for group event-saved-group
2017-01-21 03:45:53,255 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) for group event-saved-group.
2017-01-21 03:45:59,242 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2] for group event-saved-group
2017-01-21 03:45:59,242 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:45:59,244 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [edge-creation-prod-2-4] for group edge-creation-group
2017-01-21 03:45:59,244 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group edge-creation-group
2017-01-21 03:45:59,252 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group
2017-01-21 03:45:59,252 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:45:59,256 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-7] for group event-saved-group
2017-01-21 03:45:59,256 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:45:59,261 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group
2017-01-21 03:45:59,261 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:45:59,357 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [edge-creation-prod-2-8] for group edge-creation-group
2017-01-21 03:45:59,357 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group edge-creation-group
2017-01-21 03:45:59,359 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 12
2017-01-21 03:45:59,359 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-2] for group event-saved-group
2017-01-21 03:45:59,360 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 12
2017-01-21 03:45:59,360 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 12
2017-01-21 03:45:59,360 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-8] for group event-saved-group
2017-01-21 03:45:59,360 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9] for group event-saved-group
2017-01-21 03:45:59,360 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 12
2017-01-21 03:45:59,360 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-5] for group event-saved-group
2017-01-21 03:45:59,909 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group edge-creation-group with generation 11
2017-01-21 03:45:59,909 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group edge-creation-group with generation 11
2017-01-21 03:45:59,909 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [edge-creation-prod-2-6] for group edge-creation-group
2017-01-21 03:45:59,909 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [edge-creation-prod-2-4] for group edge-creation-group
2017-01-21 03:46:09,874 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [vertex-creation-prod-2-2, vertex-creation-prod-2-3] for group vertex-creation-group
2017-01-21 03:46:09,875 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group vertex-creation-group
2017-01-21 03:46:10,261 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group vertex-creation-group with generation 8
2017-01-21 03:46:10,261 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [vertex-creation-prod-2-0, vertex-creation-prod-2-1] for group vertex-creation-group
2017-01-21 03:46:12,703 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [edge-creation-prod-2-4] for group edge-creation-group
2017-01-21 03:46:12,703 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group edge-creation-group
2017-01-21 03:46:12,703 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9] for group event-saved-group
2017-01-21 03:46:12,703 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:12,703 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2] for group event-saved-group
2017-01-21 03:46:12,703 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:12,703 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-5] for group event-saved-group
2017-01-21 03:46:12,704 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:12,704 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-8] for group event-saved-group
2017-01-21 03:46:12,704 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:12,704 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [edge-creation-prod-2-6] for group edge-creation-group
2017-01-21 03:46:12,704 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group edge-creation-group
2017-01-21 03:46:12,708 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 13
2017-01-21 03:46:12,708 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 13
2017-01-21 03:46:12,708 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [] for group event-saved-group
2017-01-21 03:46:12,708 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 13
2017-01-21 03:46:12,708 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 13
2017-01-21 03:46:12,709 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [] for group event-saved-group
2017-01-21 03:46:12,709 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-7] for group event-saved-group
2017-01-21 03:46:12,709 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-3] for group event-saved-group
2017-01-21 03:46:12,709 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group edge-creation-group with generation 12
2017-01-21 03:46:12,709 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group edge-creation-group with generation 12
2017-01-21 03:46:12,709 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [edge-creation-prod-2-8] for group edge-creation-group
2017-01-21 03:46:12,709 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [edge-creation-prod-2-4] for group edge-creation-group
2017-01-21 03:46:15,714 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-3] for group event-saved-group
2017-01-21 03:46:15,714 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:15,715 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-7] for group event-saved-group
2017-01-21 03:46:15,715 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:15,792 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group
2017-01-21 03:46:15,792 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:15,792 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group
2017-01-21 03:46:15,792 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:15,797 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 14
2017-01-21 03:46:15,797 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-3] for group event-saved-group
2017-01-21 03:46:15,797 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 14
2017-01-21 03:46:15,797 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 14
2017-01-21 03:46:15,797 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-7] for group event-saved-group
2017-01-21 03:46:15,797 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 14
2017-01-21 03:46:15,797 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [] for group event-saved-group
2017-01-21 03:46:15,797 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [] for group event-saved-group
2017-01-21 03:48:13,820 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group
2017-01-21 03:48:13,820 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:15,913 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-7] for group event-saved-group
2017-01-21 03:48:15,913 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:15,917 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-3] for group event-saved-group
2017-01-21 03:48:15,917 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:16,608 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group
2017-01-21 03:48:16,608 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:16,615 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 15
2017-01-21 03:48:16,615 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [] for group event-saved-group
2017-01-21 03:48:16,615 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 15
2017-01-21 03:48:16,615 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 15
2017-01-21 03:48:16,615 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 15
2017-01-21 03:48:16,615 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-3] for group event-saved-group
2017-01-21 03:48:16,615 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [] for group event-saved-group
2017-01-21 03:48:16,615 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6] for group event-saved-group
2017-01-21 03:48:19,618 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-3] for group event-saved-group
2017-01-21 03:48:19,618 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:19,621 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group
2017-01-21 03:48:19,621 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:19,621 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group
2017-01-21 03:48:19,621 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:19,629 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 16
2017-01-21 03:48:19,629 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-7] for group event-saved-group
2017-01-21 03:48:19,630 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 16
2017-01-21 03:48:19,630 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 16
2017-01-21 03:48:19,630 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-1] for group event-saved-group
2017-01-21 03:48:19,630 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9] for group event-saved-group
2017-01-21 03:48:22,632 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-7] for group event-saved-group
2017-01-21 03:48:22,632 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:22,633 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-1] for group event-saved-group
2017-01-21 03:48:22,633 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:22,649 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 17
2017-01-21 03:48:22,649 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-5] for group event-saved-group
2017-01-21 03:48:22,649 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 17
2017-01-21 03:48:22,649 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-1] for group event-saved-group
2017-01-21 03:48:25,651 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-1] for group event-saved-group
2017-01-21 03:48:25,651 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:25,651 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-5] for group event-saved-group
2017-01-21 03:48:25,652 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:25,661 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 18
2017-01-21 03:48:25,661 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 18
2017-01-21 03:48:25,661 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6] for group event-saved-group
2017-01-21 03:48:25,662 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-2, event-saved-prod-2-3] for group event-saved-group