To add to this, I have set autoFlushFrequency to 10. This frequency is really high. I also tried calling flush manually in the code. Nothing happens.
On Fri, Apr 7, 2017 at 4:04 PM, Santosh Pingale <[email protected]> wrote: > Hi guys > > I am running Ignite in local mode and trying to write data with the help > of Kafka Streamer but it turns out data is not put into the cache no matter > how you try to do it. On the other hand, cache.put works just fine. At > moment, I am doing cache.put with MultipleTupleExtractor, but that > completely misses the point of Streamer implementation. I am not sure whats > wrong. > > Ignite version : 1.9.0 > Minimal Configs: > grid.name = "triggers" > client.mode = false > discovery.addresses = "127.0.0.1" > cache mode = "LOCAL" > > and other configurations like names and statistics. > > Some help will be hugely appreciated. >
