06 Mar 2018 14:07:01,012 INFO  [PollableSourceRunner-KafkaSource-sourceKafka] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitResponseHandler.handle:542)  - Offset commit for group flume.mpns failed due to NOT_COORDINATOR_FOR_GROUP, will find new coordinator and retry
06 Mar 2018 14:07:01,013 INFO  [PollableSourceRunner-KafkaSource-sourceKafka] (org.apache.kafka.clients.consumer.internals.AbstractCoordinator.coordinatorDead:529)  - Marking the coordinator 2147483589 dead.
06 Mar 2018 14:07:01,240 INFO  [PollableSourceRunner-KafkaSource-sourceKafka] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitResponseHandler.handle:542)  - Offset commit for group flume.mpns failed due to NOT_COORDINATOR_FOR_GROUP, will find new coordinator and retry
06 Mar 2018 14:07:01,240 INFO  [PollableSourceRunner-KafkaSource-sourceKafka] (org.apache.kafka.clients.consumer.internals.AbstractCoordinator.coordinatorDead:529)  - Marking the coordinator 2147483646 dead.
06 Mar 2018 14:07:01,354 INFO  [PollableSourceRunner-KafkaSource-sourceKafka] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitResponseHandler.handle:542)  - Offset commit for group flume.mpns failed due to NOT_COORDINATOR_FOR_GROUP, will find new coordinator and retry
06 Mar 2018 14:07:01,354 INFO  [PollableSourceRunner-KafkaSource-sourceKafka] (org.apache.kafka.clients.consumer.internals.AbstractCoordinator.coordinatorDead:529)  - Marking the coordinator 2147483646 dead.
06 Mar 2018 14:07:01,479 INFO  [PollableSourceRunner-KafkaSource-sourceKafka] (org.apache.kafka.clients.consumer.internals.ConsumerCoordinator$OffsetCommitResponseHandler.handle:542)  - Offset commit for group flume.mpns failed due to NOT_COORDINATOR_FOR_GROUP, will find new coordinator and retry
06 Mar 2018 14:07:01,479 INFO  [PollableSourceRunner-KafkaSource-sourceKafka] (org.apache.kafka.clients.consumer.internals.AbstractCoordinator.coordinatorDead:529)  - Marking the coordinator 2147483646 dead.