Try to replace lambda with a static class. Most likely it currently serializes objects that you do not expect to be serialized, like KafkaFileConsumer and its fields. With a static class you will be able to make sure that only required data is included.
-Val -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/
