Bean injection in Cache store implementation

2019-06-01 Thread Komal Chugh
I am overriding write method of cache store and using FactoryBuilder.factoryOf method in the cache configuration. But I need to inject spring bean in the cache store implementation. I tried using @SpringResource by defining that bean in xml file, but there are a lot of nested beans which are

Re: Questions on IgniteDataStreamer

2019-06-01 Thread Om Thacker
Hello vbm, I am working on the exact same problem. Did you find the solution for the same. I am using following code in my client application which will listen to kafka connect (confluent). I have one to one mapping for kafka topic and ignite cache. When there is an insert into db, the kafka