2017-01-21 10:09:37,061 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-5, event-saved-prod-2-4, event-saved-prod-2-3] for group event-saved-group
2017-01-21 10:09:37,061 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:09:37,088 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-7, event-saved-prod-2-6] for group event-saved-group
2017-01-21 10:09:37,088 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:09:37,562 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8] for group event-saved-group
2017-01-21 10:09:37,562 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:09:37,568 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 28
2017-01-21 10:09:37,568 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 28
2017-01-21 10:09:37,569 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:09:37,569 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:09:37,571 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 28
2017-01-21 10:09:37,571 [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-3] for group event-saved-group
2017-01-21 10:12:57,097 [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 10:12:57,097 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0] for group event-saved-group
2017-01-21 10:12:57,097 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:12:58,910 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:12:58,910 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:12:59,069 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:12:59,070 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:14:37,681 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 29
2017-01-21 10:14:37,681 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:14:37,681 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 29
2017-01-21 10:14:37,681 [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-3] for group event-saved-group
2017-01-21 10:14:37,681 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 29
2017-01-21 10:14:37,681 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:17:49,721 [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 10:17:49,721 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 10:17:49,721 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:17:50,211 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:17:50,211 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:17:50,268 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:17:50,268 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:19:37,787 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 30
2017-01-21 10:19:37,788 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:19:37,789 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 30
2017-01-21 10:19:37,789 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 30
2017-01-21 10:19:37,789 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:19:37,789 [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-3] for group event-saved-group
2017-01-21 10:23:45,857 [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 10:23:45,857 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 10:23:45,857 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:23:47,085 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:23:47,085 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:23:47,227 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:23:47,227 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:24:37,827 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 31
2017-01-21 10:24:37,827 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 31
2017-01-21 10:24:37,827 [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-3] for group event-saved-group
2017-01-21 10:24:37,827 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 31
2017-01-21 10:24:37,827 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:24:37,827 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:29:27,441 [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 10:29:27,441 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 10:29:27,441 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:29:29,287 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:29:29,287 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:29:29,362 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:29:29,362 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:29:37,902 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 32
2017-01-21 10:29:37,902 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:29:37,903 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 32
2017-01-21 10:29:37,903 [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-3] for group event-saved-group
2017-01-21 10:29:37,903 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 32
2017-01-21 10:29:37,903 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:33:19,130 [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 10:33:19,130 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 10:33:19,130 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:33:20,177 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:33:20,177 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:33:20,559 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:33:20,559 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:34:38,013 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 33
2017-01-21 10:34:38,013 [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-3] for group event-saved-group
2017-01-21 10:34:38,013 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 33
2017-01-21 10:34:38,013 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:34:38,013 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 33
2017-01-21 10:34:38,013 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:37:44,750 [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 10:37:44,750 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 10:37:44,750 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:37:47,562 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:37:47,562 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:37:47,571 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:37:47,571 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:39:38,044 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 34
2017-01-21 10:39:38,044 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 34
2017-01-21 10:39:38,044 [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-3] for group event-saved-group
2017-01-21 10:39:38,044 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 34
2017-01-21 10:39:38,044 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:39:38,044 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:42:40,206 [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 10:42:40,206 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 10:42:40,206 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:42:41,512 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:42:41,512 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:42:41,570 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:42:41,570 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:44:38,080 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 35
2017-01-21 10:44:38,080 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 35
2017-01-21 10:44:38,080 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:44:38,080 [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-3] for group event-saved-group
2017-01-21 10:44:38,081 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 35
2017-01-21 10:44:38,081 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:47:40,485 [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 10:47:40,485 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 10:47:40,485 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:47:41,605 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:47:41,605 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:47:41,609 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:47:41,609 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:49:38,137 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 36
2017-01-21 10:49:38,137 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:49:38,137 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 36
2017-01-21 10:49:38,137 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:49:38,137 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 36
2017-01-21 10:49:38,137 [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-3] for group event-saved-group
2017-01-21 10:52:38,158 [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 10:52:38,158 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 10:52:38,158 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:52:38,697 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:52:38,697 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:52:38,697 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:52:38,697 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:54:38,233 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 37
2017-01-21 10:54:38,233 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 37
2017-01-21 10:54:38,233 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 37
2017-01-21 10:54:38,233 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:54:38,233 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:54:38,233 [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-3] for group event-saved-group
2017-01-21 10:57:42,927 [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 10:57:42,927 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 10:57:42,927 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:57:44,810 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:57:44,810 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:57:44,810 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:57:44,810 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 10:59:38,283 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 38
2017-01-21 10:59:38,283 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 38
2017-01-21 10:59:38,283 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 38
2017-01-21 10:59:38,283 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 10:59:38,283 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 10:59:38,283 [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-3] for group event-saved-group
2017-01-21 11:02:43,951 [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 11:02:43,951 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 11:02:43,951 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:02:44,838 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:02:44,838 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:02:44,839 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:02:44,839 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:04:38,329 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 39
2017-01-21 11:04:38,330 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 39
2017-01-21 11:04:38,330 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:04:38,330 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:04:38,330 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 39
2017-01-21 11:04:38,330 [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-3] for group event-saved-group
2017-01-21 11:07:47,403 [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 11:07:47,403 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 11:07:47,403 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:07:47,654 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:07:47,654 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:07:47,958 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:07:47,958 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:09:38,378 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 40
2017-01-21 11:09:38,378 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:09:38,380 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 40
2017-01-21 11:09:38,380 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 40
2017-01-21 11:09:38,380 [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-3] for group event-saved-group
2017-01-21 11:09:38,380 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:12:51,283 [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 11:12:51,283 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 11:12:51,284 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:12:53,926 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:12:53,926 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:12:53,958 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:12:53,958 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:14:38,395 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 41
2017-01-21 11:14:38,396 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:14:38,396 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 41
2017-01-21 11:14:38,396 [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-3] for group event-saved-group
2017-01-21 11:14:38,396 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 41
2017-01-21 11:14:38,396 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:17:51,872 [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 11:17:51,872 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 11:17:51,872 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:17:53,957 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:17:53,958 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:17:53,976 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:17:53,976 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:19:38,444 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 42
2017-01-21 11:19:38,444 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 42
2017-01-21 11:19:38,444 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:19:38,444 [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-3] for group event-saved-group
2017-01-21 11:19:38,445 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 42
2017-01-21 11:19:38,445 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:24:02,007 [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 11:24:02,007 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 11:24:02,007 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:24:02,618 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:24:02,618 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:24:02,761 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:24:02,761 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:24:38,505 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 43
2017-01-21 11:24:38,505 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 43
2017-01-21 11:24:38,505 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:24:38,505 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:24:38,505 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 43
2017-01-21 11:24:38,505 [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-3] for group event-saved-group
2017-01-21 11:28:51,852 [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 11:28:51,852 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 11:28:51,852 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:28:53,998 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:28:53,998 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:28:54,088 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:28:54,089 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:29:38,550 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 44
2017-01-21 11:29:38,550 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 44
2017-01-21 11:29:38,550 [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-3] for group event-saved-group
2017-01-21 11:29:38,550 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:29:38,550 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 44
2017-01-21 11:29:38,551 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:32:55,898 [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 11:32:55,898 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 11:32:55,898 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:32:56,678 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:32:56,678 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:32:57,154 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:32:57,155 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:34:38,647 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 45
2017-01-21 11:34:38,648 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 45
2017-01-21 11:34:38,648 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:34:38,648 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:34:38,648 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 45
2017-01-21 11:34:38,648 [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-3] for group event-saved-group
2017-01-21 11:37:51,899 [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 11:37:51,900 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 11:37:51,900 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:37:54,094 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:37:54,094 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:37:54,204 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:37:54,204 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:39:38,727 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 46
2017-01-21 11:39:38,727 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 46
2017-01-21 11:39:38,727 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:39:38,727 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 46
2017-01-21 11:39:38,727 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:39:38,727 [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-3] for group event-saved-group
2017-01-21 11:42:52,298 [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 11:42:52,299 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 11:42:52,299 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:42:54,257 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:42:54,257 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:42:54,276 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:42:54,276 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:44:38,819 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 47
2017-01-21 11:44:38,819 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 47
2017-01-21 11:44:38,819 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:44:38,819 [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-3] for group event-saved-group
2017-01-21 11:44:38,819 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 47
2017-01-21 11:44:38,819 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:47:51,156 [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 11:47:51,156 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 11:47:51,156 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:47:51,348 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:47:51,349 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:47:51,349 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:47:51,349 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:49:38,880 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 48
2017-01-21 11:49:38,880 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 48
2017-01-21 11:49:38,880 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 48
2017-01-21 11:49:38,880 [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-3] for group event-saved-group
2017-01-21 11:49:38,880 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:49:38,880 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:52:49,291 [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 11:52:49,291 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 11:52:49,291 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:52:51,484 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:52:51,484 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:52:51,486 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:52:51,487 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:54:38,916 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 49
2017-01-21 11:54:38,916 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 49
2017-01-21 11:54:38,916 [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-3] for group event-saved-group
2017-01-21 11:54:38,916 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 49
2017-01-21 11:54:38,917 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:54:38,917 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:57:51,515 [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 11:57:51,515 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 11:57:51,515 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:57:54,504 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:57:54,504 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:57:54,504 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:57:54,504 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 11:59:38,957 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 50
2017-01-21 11:59:38,957 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 50
2017-01-21 11:59:38,957 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 11:59:38,957 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 11:59:38,957 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 50
2017-01-21 11:59:38,957 [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-3] for group event-saved-group
2017-01-21 12:02:53,684 [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 12:02:53,684 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 12:02:53,684 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:02:54,565 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:02:54,565 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:02:54,566 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:02:54,566 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:04:38,973 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 51
2017-01-21 12:04:38,973 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 51
2017-01-21 12:04:38,973 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 51
2017-01-21 12:04:38,973 [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-3] for group event-saved-group
2017-01-21 12:04:38,973 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:04:38,973 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:07:52,686 [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 12:07:52,686 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 12:07:52,686 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:07:54,600 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:07:54,600 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:07:54,600 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:07:54,600 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:09:39,039 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 52
2017-01-21 12:09:39,039 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 52
2017-01-21 12:09:39,039 [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-3] for group event-saved-group
2017-01-21 12:09:39,039 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:09:39,039 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 52
2017-01-21 12:09:39,040 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:12:53,008 [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 12:12:53,008 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 12:12:53,008 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:12:54,644 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:12:54,644 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:12:54,644 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:12:54,644 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:14:39,111 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 53
2017-01-21 12:14:39,111 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 53
2017-01-21 12:14:39,112 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 53
2017-01-21 12:14:39,112 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:14:39,112 [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-3] for group event-saved-group
2017-01-21 12:14:39,112 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:17:56,603 [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 12:17:56,603 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 12:17:56,603 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:17:57,711 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:17:57,711 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:17:57,712 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:17:57,712 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:19:39,176 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 54
2017-01-21 12:19:39,177 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 54
2017-01-21 12:19:39,176 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 54
2017-01-21 12:19:39,177 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:19:39,177 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:19:39,177 [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-3] for group event-saved-group
2017-01-21 12:23:45,627 [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 12:23:45,627 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 12:23:45,627 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:23:45,658 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:23:45,658 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:23:45,711 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:23:45,711 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:24:39,211 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 55
2017-01-21 12:24:39,212 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:24:39,217 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 55
2017-01-21 12:24:39,217 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:24:39,218 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 55
2017-01-21 12:24:39,218 [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-3] for group event-saved-group
2017-01-21 12:29:39,722 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:29:39,723 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:29:39,938 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:29:39,938 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:29:39,942 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 56
2017-01-21 12:29:39,942 [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
2017-01-21 12:29:39,942 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 56
2017-01-21 12:29:39,942 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7, event-saved-prod-2-6, event-saved-prod-2-5] for group event-saved-group
2017-01-21 12:29:46,916 [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 12:29:46,916 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 12:29:46,916 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:29:48,944 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7, event-saved-prod-2-6, event-saved-prod-2-5] for group event-saved-group
2017-01-21 12:29:48,944 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:33:46,377 [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 12:33:46,377 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 12:33:46,377 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:34:39,971 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 57
2017-01-21 12:34:39,971 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 57
2017-01-21 12:34:39,971 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:34:39,971 [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-3] for group event-saved-group
2017-01-21 12:34:39,972 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 57
2017-01-21 12:34:39,973 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:38:05,191 [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 12:38:05,191 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously 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
2017-01-21 12:38:05,192 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:38:07,130 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:38:07,130 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:38:07,349 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:38:07,349 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:39:39,995 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 58
2017-01-21 12:39:39,995 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 58
2017-01-21 12:39:39,995 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:39:39,995 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:39:39,996 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 58
2017-01-21 12:39:39,996 [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-3] for group event-saved-group
2017-01-21 12:42:59,534 [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 12:42:59,534 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 12:42:59,534 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:43:01,542 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:43:01,542 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:43:01,543 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:43:01,543 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:44:40,068 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 59
2017-01-21 12:44:40,068 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:44:40,068 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 59
2017-01-21 12:44:40,068 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:44:40,069 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 59
2017-01-21 12:44:40,069 [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-3] for group event-saved-group
2017-01-21 12:47:54,247 [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 12:47:54,248 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 12:47:54,248 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:47:55,352 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:47:55,352 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:47:55,454 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:47:55,454 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:49:40,182 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 60
2017-01-21 12:49:40,182 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 60
2017-01-21 12:49:40,182 [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-3] for group event-saved-group
2017-01-21 12:49:40,182 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 60
2017-01-21 12:49:40,182 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:49:40,182 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:52:53,756 [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 12:52:53,756 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 12:52:53,757 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:52:55,750 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:52:55,750 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:52:55,750 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:52:55,750 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:54:40,209 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 61
2017-01-21 12:54:40,209 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 61
2017-01-21 12:54:40,209 [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-3] for group event-saved-group
2017-01-21 12:54:40,209 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:54:40,210 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 61
2017-01-21 12:54:40,210 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:57:55,239 [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 12:57:55,240 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 12:57:55,240 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:57:55,764 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:57:55,764 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:57:55,766 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:57:55,766 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 12:59:40,307 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 62
2017-01-21 12:59:40,307 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 62
2017-01-21 12:59:40,307 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 62
2017-01-21 12:59:40,307 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 12:59:40,307 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 12:59:40,307 [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-3] for group event-saved-group
2017-01-21 13:02:59,530 [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 13:02:59,530 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 13:02:59,530 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 13:03:01,450 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 13:03:01,450 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 13:03:01,812 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 13:03:01,812 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 13:04:40,365 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 63
2017-01-21 13:04:40,365 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 13:04:40,365 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 63
2017-01-21 13:04:40,365 [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-3] for group event-saved-group
2017-01-21 13:04:40,365 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 63
2017-01-21 13:04:40,365 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 13:08:04,005 [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 13:08:04,006 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 13:08:04,006 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 13:08:05,126 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 13:08:05,127 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 13:08:05,128 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 13:08:05,128 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 13:09:40,483 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 64
2017-01-21 13:09:40,483 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 64
2017-01-21 13:09:40,483 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 64
2017-01-21 13:09:40,483 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 13:09:40,483 [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-3] for group event-saved-group
2017-01-21 13:09:40,483 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 13:13:01,910 [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 13:13:01,910 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 13:13:01,910 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 13:13:02,001 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 13:13:02,001 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 13:13:02,059 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 13:13:02,059 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 13:14:40,552 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 65
2017-01-21 13:14:40,552 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 65
2017-01-21 13:14:40,552 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 65
2017-01-21 13:14:40,552 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 13:14:40,552 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 13:14:40,552 [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-3] for group event-saved-group
2017-01-21 13:18:03,116 [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 13:18:03,116 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-2, event-saved-prod-2-1, event-saved-prod-2-0, event-saved-prod-2-3] for group event-saved-group
2017-01-21 13:18:03,117 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 13:18:05,073 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 13:18:05,073 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 13:18:05,149 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 13:18:05,149 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group
2017-01-21 13:19:40,610 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 66
2017-01-21 13:19:40,610 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 66
2017-01-21 13:19:40,610 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-6, event-saved-prod-2-5, event-saved-prod-2-4] for group event-saved-group
2017-01-21 13:19:40,610 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8, event-saved-prod-2-7] for group event-saved-group
2017-01-21 13:19:40,610 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 66
2017-01-21 13:19:40,610 [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-3] for group event-saved-group
2017-01-21 13:21:01,028 [INFO] org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: 
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	value.serializer = class org.apache.kafka.common.serialization.StringSerializer
2017-01-21 13:21:01,045 [INFO] org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: 
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	value.serializer = class org.apache.kafka.common.serialization.StringSerializer
2017-01-21 13:21:01,113 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.1
2017-01-21 13:21:01,113 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : f10ef2720b03b247
2017-01-21 13:21:01,310 [INFO] org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: 
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	value.serializer = class org.apache.kafka.common.serialization.StringSerializer
2017-01-21 13:21:01,311 [INFO] org.apache.kafka.clients.producer.ProducerConfig - ProducerConfig values: 
	key.serializer = class org.apache.kafka.common.serialization.StringSerializer
	partitioner.class = class org.apache.kafka.clients.producer.internals.DefaultPartitioner
	value.serializer = class org.apache.kafka.common.serialization.StringSerializer