2017-01-21 05:08:49,445 [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 05:08:49,452 [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 05:08:49,517 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.1 2017-01-21 05:08:49,518 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : f10ef2720b03b247 2017-01-21 05:08:49,820 [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 05:08:49,821 [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 05:08:49,828 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.1 2017-01-21 05:08:49,828 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : f10ef2720b03b247 2017-01-21 05:08:55,876 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,877 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,901 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.1 2017-01-21 05:08:55,901 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : f10ef2720b03b247 2017-01-21 05:08:55,902 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,903 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,906 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.1 2017-01-21 05:08:55,906 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : f10ef2720b03b247 2017-01-21 05:08:55,911 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,912 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,920 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.1 2017-01-21 05:08:55,920 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : f10ef2720b03b247 2017-01-21 05:08:55,921 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,921 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,933 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.1 2017-01-21 05:08:55,933 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : f10ef2720b03b247 2017-01-21 05:08:55,937 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,938 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,939 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.1 2017-01-21 05:08:55,939 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : f10ef2720b03b247 2017-01-21 05:08:55,943 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,943 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,950 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.1 2017-01-21 05:08:55,950 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : f10ef2720b03b247 2017-01-21 05:08:55,964 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,964 [INFO] org.apache.kafka.clients.consumer.ConsumerConfig - ConsumerConfig values: key.deserializer = class org.apache.kafka.common.serialization.StringDeserializer partition.assignment.strategy = [class org.apache.kafka.clients.consumer.RangeAssignor] value.deserializer = class org.apache.kafka.common.serialization.StringDeserializer 2017-01-21 05:08:55,966 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka version : 0.10.1.1 2017-01-21 05:08:55,966 [INFO] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId : f10ef2720b03b247 2017-01-21 05:08:56,537 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) for group event-saved-group. 2017-01-21 05:08:56,537 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) for group event-saved-group. 2017-01-21 05:08:56,537 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) for group event-saved-group. 2017-01-21 05:08:56,538 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group 2017-01-21 05:08:56,538 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group 2017-01-21 05:08:56,539 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group 2017-01-21 05:08:56,539 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group 2017-01-21 05:08:56,540 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group 2017-01-21 05:08:56,540 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group 2017-01-21 05:08:56,543 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) for group event-saved-group. 2017-01-21 05:08:56,543 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group event-saved-group 2017-01-21 05:08:56,543 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group 2017-01-21 05:08:56,545 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) for group edge-creation-group. 2017-01-21 05:08:56,545 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group edge-creation-group 2017-01-21 05:08:56,545 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group edge-creation-group 2017-01-21 05:08:56,546 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) for group edge-creation-group. 2017-01-21 05:08:56,547 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group edge-creation-group 2017-01-21 05:08:56,547 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group edge-creation-group 2017-01-21 05:08:56,556 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group event-saved-group 2017-01-21 05:08:56,561 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 23 2017-01-21 05:08:56,561 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 23 2017-01-21 05:08:56,564 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 23 2017-01-21 05:08:56,568 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly 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 05:08:56,568 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-9, event-saved-prod-2-8] for group event-saved-group 2017-01-21 05:08:56,568 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [event-saved-prod-2-7, event-saved-prod-2-6] for group event-saved-group 2017-01-21 05:08:56,573 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered coordinator 10.10.2.88:9092 (id: 2147483647 rack: null) for group vertex-creation-group. 2017-01-21 05:08:56,574 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Revoking previously assigned partitions [] for group vertex-creation-group 2017-01-21 05:08:56,574 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - (Re-)joining group vertex-creation-group 2017-01-21 05:08:56,575 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group event-saved-group with generation 23 2017-01-21 05:08:56,575 [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] for group event-saved-group 2017-01-21 05:08:59,034 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group edge-creation-group with generation 14 2017-01-21 05:08:59,040 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [edge-creation-prod-2-7] for group edge-creation-group 2017-01-21 05:08:59,040 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group edge-creation-group with generation 14 2017-01-21 05:08:59,042 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [edge-creation-prod-2-4] for group edge-creation-group 2017-01-21 05:08:59,070 [INFO] org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Successfully joined group vertex-creation-group with generation 10 2017-01-21 05:08:59,071 [INFO] org.apache.kafka.clients.consumer.internals.ConsumerCoordinator - Setting newly assigned partitions [vertex-creation-prod-2-2, vertex-creation-prod-2-3] for group vertex-creation-group