ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Andrey Mashenkov <andrey.mashen...@gmail.com>
Subject Re: Local Mode - Kafka Streamer unable to write data
Date Mon, 10 Apr 2017 15:37:57 GMT
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 <pingalesantosh@gmail.com>
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 <pingalesantosh@gmail.com>
> 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

Mime
View raw message