2017-01-21 03:46:09,882 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Marking the coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) dead for group vertex-creation-group
2017-01-21 03:46:09,883 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) for group vertex-creation-group.
2017-01-21 03:46:09,887 [WARN] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Auto offset commit failed for group vertex-creation-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.
2017-01-21 03:46:09,887 [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:46:09,903 [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:46:09,904 [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:46:09,905 [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:46:09,905 [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:46:09,905 [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:46:09,906 [WARN] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Auto offset commit failed for group event-saved-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.
2017-01-21 03:46:09,906 [WARN] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Auto offset commit failed for group event-saved-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.
2017-01-21 03:46:09,906 [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:09,907 [WARN] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Auto offset commit failed for group vertex-creation-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.
2017-01-21 03:46:09,907 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:09,907 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [vertex-creation-prod-2-0, vertex-creation-prod-2-1] for group vertex-creation-group
2017-01-21 03:46:09,907 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group vertex-creation-group
2017-01-21 03:46:09,907 [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:46:09,907 [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:46:09,907 [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:46:09,908 [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:46:09,908 [WARN] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Auto offset commit failed for group event-saved-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.
2017-01-21 03:46:09,909 [WARN] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Auto offset commit failed for group event-saved-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.
2017-01-21 03:46:09,909 [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:09,909 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:09,909 [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:46:09,909 [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:46:09,909 [WARN] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Auto offset commit failed for group event-saved-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.
2017-01-21 03:46:09,909 [WARN] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Auto offset commit failed for group event-saved-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.
2017-01-21 03:46:09,909 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6] for group event-saved-group
2017-01-21 03:46:09,909 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:09,911 [WARN] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Auto offset commit failed for group edge-creation-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.
2017-01-21 03:46:09,911 [WARN] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Auto offset commit failed for group edge-creation-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.
2017-01-21 03:46:09,911 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [edge-creation-prod-2-7] for group edge-creation-group
2017-01-21 03:46:09,911 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group edge-creation-group
2017-01-21 03:46:09,912 [WARN] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Auto offset commit failed for group edge-creation-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.
2017-01-21 03:46:09,912 [WARN] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Auto offset commit failed for group edge-creation-group: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member. This means that the time between subsequent calls to poll() was longer than the configured max.poll.interval.ms, which typically implies that the poll loop is spending too much time message processing. You can address this either by increasing the session timeout or by reducing the maximum size of batches returned in poll() with max.poll.records.
2017-01-21 03:46:09,912 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [edge-creation-prod-2-5] for group edge-creation-group
2017-01-21 03:46:09,912 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group edge-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-2, vertex-creation-prod-2-3] for group vertex-creation-group
2017-01-21 03:46:12,709 [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.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 [event-saved-prod-2-6] 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-0] 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.ConsumerCoordinator - Setting newly assigned partitions [edge-creation-prod-2-7] for group edge-creation-group
2017-01-21 03:46:12,709 [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 [event-saved-prod-2-9] for group event-saved-group
2017-01-21 03:46:12,710 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group edge-creation-group with generation 12
2017-01-21 03:46:12,710 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [edge-creation-prod-2-5] for group edge-creation-group
2017-01-21 03:46:12,910 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group
2017-01-21 03:46:12,910 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:15,711 [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:15,711 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:15,712 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6] for group event-saved-group
2017-01-21 03:46:15,712 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:46:15,712 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-0] for group event-saved-group
2017-01-21 03:46:15,712 [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.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 [] for group event-saved-group
2017-01-21 03:46:15,797 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-0] for group event-saved-group
2017-01-21 03:46:15,797 [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: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,798 [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:13,971 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6] for group event-saved-group
2017-01-21 03:48:13,971 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:13,988 [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:48:13,988 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:13,988 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-0] for group event-saved-group
2017-01-21 03:48:13,988 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:14,626 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group
2017-01-21 03:48:14,626 [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.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.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-5] 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.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-8] 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,616 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-0] for group event-saved-group
2017-01-21 03:48:19,623 [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:48:19,623 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:19,623 [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:19,623 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:19,624 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group
2017-01-21 03:48:19,624 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:19,624 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-0] for group event-saved-group
2017-01-21 03:48:19,624 [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.AbstractCoordinator - Successfully joined group event-saved-group with generation 16
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-8] for group event-saved-group
2017-01-21 03:48:19,629 [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:19,629 [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: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,630 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-0] 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-3] 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,632 [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:48:22,632 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining 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-0] 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,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.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-6] 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-0] for group event-saved-group
2017-01-21 03:48:22,649 [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:25,652 [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:25,652 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:25,652 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-0] 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.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-4] for 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,662 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-1, event-saved-prod-2-0] for group event-saved-group
2017-01-21 03:48:28,663 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-4] for group event-saved-group
2017-01-21 03:48:28,663 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:28,669 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 19
2017-01-21 03:48:28,669 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-1, event-saved-prod-2-0] for group event-saved-group
2017-01-21 03:48:31,672 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-1, event-saved-prod-2-0] for group event-saved-group
2017-01-21 03:48:31,672 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 03:48:31,677 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 20
2017-01-21 03:48:31,677 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-4, event-saved-prod-2-3] for group event-saved-group