Hi Santosh, KafkaStreamer has 10 seconds retry timeout. Try to reduce it. Please, share you config and sample code if it would not helpful.
On Fri, Apr 7, 2017 at 5:12 PM, Santosh Pingale <[email protected]> wrote: > 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. >> > > -- Best regards, Andrey V. Mashenkov
