2019-02-19T11:53:52,970 DEBUG sc-0-kcons-pool-2 [] Partitions revoked: [22a064b3-a8a8-41d9-b24c-93ed9bef440b-0, 19f0981d-4bad-4b1e-b72e-840666277b35-0] c.m.n.c.k.c.c.p.i.TopicsManager.onPartitionsRevoked 
2019-02-19T11:53:52,978 DEBUG sc-0-kcons-pool-2 [] Partitions assigned: [22a064b3-a8a8-41d9-b24c-93ed9bef440b-0] c.m.n.c.k.c.c.p.i.TopicsManager.onPartitionsAssigned 
2019-02-19T11:53:53,940 INFO main [] tearDown() c.m.n.c.c.KafkaCallbackChannelJEmbeddedKafkaTest.tearDown 
2019-02-19T11:53:53,949 INFO main [] Stopped ServerConnector@5ea2b700{HTTP/1.1,[http/1.1]}{0.0.0.0:0} o.e.j.s.ServerConnector.doStop 
2019-02-19T11:53:54,480 DEBUG sc-0-kcons-pool-2 [] Partitions revoked: [22a064b3-a8a8-41d9-b24c-93ed9bef440b-0] c.m.n.c.k.c.c.p.i.TopicsManager.onPartitionsRevoked 
2019-02-19T11:53:54,575 DEBUG main [] Future await time: PT0.00042823S c.m.n.c.t.f.FutureAsserts.await 
2019-02-19T11:53:54,585 ERROR sc-0-kcons-pool-2 [] Exception on PushChannelConsumer.doRound(), retries left 100, poolIndex: 0, instance: c.m.n.c.k.c.c.p.PushChannelsConsumer@18b27c8a c.m.n.c.k.c.c.m.i.ConsumerAndThreadWrapper.lambda$consumerRunnable$4 
java.lang.NullPointerException: null
	at org.apache.kafka.clients.consumer.StickyAssignor.assign(StickyAssignor.java:223) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.AbstractPartitionAssignor.assign(AbstractPartitionAssignor.java:68) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.performAssignment(ConsumerCoordinator.java:403) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.onJoinLeader(AbstractCoordinator.java:569) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.access$1100(AbstractCoordinator.java:95) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:521) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$JoinGroupResponseHandler.handle(AbstractCoordinator.java:504) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:870) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator$CoordinatorResponseHandler.onSuccess(AbstractCoordinator.java:850) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.RequestFuture$1.onSuccess(RequestFuture.java:204) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.RequestFuture.fireSuccess(RequestFuture.java:167) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.RequestFuture.complete(RequestFuture.java:127) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient$RequestFutureCompletionHandler.fireCompletion(ConsumerNetworkClient.java:575) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.firePendingCompletedRequests(ConsumerNetworkClient.java:389) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:297) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:236) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:215) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.joinGroupIfNeeded(AbstractCoordinator.java:397) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureActiveGroup(AbstractCoordinator.java:340) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:341) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.updateAssignmentMetadataIfNeeded(KafkaConsumer.java:1214) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1179) ~[kafka-clients-2.1.0.jar:?]
	at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:1164) ~[kafka-clients-2.1.0.jar:?]
	at c.m.n.c.k.c.c.p.PushChannelsConsumer.pollDistributeDataAndPauseTopics(PushChannelsConsumer.java:204) ~[classes/:?]
	at c.m.n.c.k.c.c.p.PushChannelsConsumer.doRound(PushChannelsConsumer.java:121) ~[classes/:?]
	at c.m.n.c.k.c.c.m.i.ConsumerAndThreadWrapper.lambda$consumerRunnable$4(ConsumerAndThreadWrapper.java:158) ~[classes/:?]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_151]