Re: code sample for cluster configuration

2018-02-07 Thread Rajesh Kishore
Thanks Pavel, I am aware about this code.
I am able to establish a cluster as well. I have following requirement:
>From my application - I want to retrieve/insert records on different
cluster server. My application code is single instance , my application
code should be unaware from which ignite cluster server its
retrieving/inserting the data.
Would just setting Ignition.setClientMode(true) is enough for this usecase,
would my application to push the data to one of the portioned cluster
server ?

Thanks,
Rajesh

On Wed, Feb 7, 2018 at 8:43 PM, Vinokurov Pavel 
wrote:

> Hi Rajesh,
>
> There is a good sample with enabled persistance -
> https://github.com/apache/ignite/blob/master/examples/
> src/main/java/org/apache/ignite/examples/persistentstore/
> PersistentStoreExample.java
> Also documentation about Ignite persistance  presented in
> https://apacheignite.readme.io/docs/distributed-persistent-store.
>
>
> 2018-02-07 13:14 GMT+03:00 Rajesh Kishore :
>
>> Hi,
>>
>> I want to try a two node setup for Ignite cluster with native file based
>> persistence enabled .
>>
>> Any samples, or pointer ?
>>
>>
>> -Rajesh
>>
>
>
>
> --
>
> Regards
>
> Pavel Vinokurov
>


Re: code sample for cluster configuration

2018-02-07 Thread Vinokurov Pavel
Hi Rajesh,

There is a good sample with enabled persistance -
https://github.com/apache/ignite/blob/master/examples/src/main/java/org/apache/ignite/examples/persistentstore/PersistentStoreExample.java
Also documentation about Ignite persistance  presented in
https://apacheignite.readme.io/docs/distributed-persistent-store.


2018-02-07 13:14 GMT+03:00 Rajesh Kishore :

> Hi,
>
> I want to try a two node setup for Ignite cluster with native file based
> persistence enabled .
>
> Any samples, or pointer ?
>
>
> -Rajesh
>



-- 

Regards

Pavel Vinokurov


continuous query - changes from local server only

2018-02-07 Thread Som Som
hi.

I have a cache with cachemode = partitioned and 2 server nodes that share
parts of the cache data according to the affinity function. Then I run the
client node on one of the computers where the server node is located. How
to configure a continuous query on the client node to receive events only
from server nodes located on the same machine?


Re: Enable Kerberos on Ignite Kafka streamer / support for new consumer config

2018-02-07 Thread jackson.dickson
Thanks Andrew for your response.

As per this documentation (
https://docs.confluent.io/3.0.0/kafka/sasl.html#sasl-configuration-for-kafka-clients

 
), SASL auth is supported only for new Kafka consumers. The new kafka
consumers connect to the Kafka brokers directly instead of zookeeper


Below two security config are required to be specified in the consumers
configs which are only supported in the new Kafka consumer config.
security.protocol
sasl.kerberos.service.name

Refer -  https://kafka.apache.org/0100/documentation.html#oldconsumerconfigs
  

The ignite kafka streamer uses old consumer config
(kafka.consumer.ConsumerConfig). I get below errors in the log file if I
specify these new consumer configs.

2018-02-07 05:11:42.432|myapp|ip-x-x-x-x.myserver|[main]|INFO
|||kafka.utils.VerifiableProperties:info|68|Verifying properties
2018-02-07 05:11:42.454|myapp|ip-x-x-x-x.myserver|[main]|WARN
|||kafka.utils.VerifiableProperties:warn|83|Property auto.reset.offset
is not valid
2018-02-07 05:11:42.455|myapp|ip-x-x-x-x.myserver|[main]|INFO
|||kafka.utils.VerifiableProperties:info|68|Property group.id is
overridden to ignio-kafka-streamer
2018-02-07 05:11:42.455|myapp|ip-x-x-x-x.myserver|[main]|WARN
|||kafka.utils.VerifiableProperties:warn|83|Property
sasl.kerberos.service.name is not valid
2018-02-07 05:11:42.455|myapp|ip-x-x-x-x.myserver|[main]|WARN
|||kafka.utils.VerifiableProperties:warn|83|Property security.protocol
is not valid



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/


code sample for cluster configuration

2018-02-07 Thread Rajesh Kishore
Hi,

I want to try a two node setup for Ignite cluster with native file based
persistence enabled .

Any samples, or pointer ?


-Rajesh


Re: Enable Kerberos on Ignite Kafka streamer / support for new consumer config

2018-02-07 Thread Andrey Mashenkov
Hi Jackson,

Ignite supports kafka-0.10.0.1 version.
Kafka official docs has support some kerberos options [1].
So, it should be possible to enable Kerberos with certain options in
ConsumerConfig.


[1] https://kafka.apache.org/0100/documentation.html#brokerconfigs

On Wed, Feb 7, 2018 at 7:49 AM, jackson.dickson 
wrote:

> Hi,
>
> We are trying to enable Kerberos in our Ignite-Kafka env. Kerberos is
> supported in Kafka consumers using the newer consumer configs. As per Kafka
> documentation, Kerberos is only supported on the newer KAfka consumers.
>
> It seems the Ignite KafkaStreamer only supports using the old consumer
> config.
>
> Is there any way to setup Kerberos auth on KafkaStreamer?
>
> Thanks,
> Jackson
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>



-- 
Best regards,
Andrey V. Mashenkov


Re: Text Query question

2018-02-07 Thread Jet.Yuen
Hi dkarachentsev,
   Thanks for your answer!  hmm, so I need to put data again after restart.


Regards, 
jet 






--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/


Re: Text Query question

2018-02-07 Thread dkarachentsev
Hi Jet,

Full text search creates Lucene in-memory indexes and after restart they are
not available, so you cannot use it with persistence. @QuerySqlField enables
DB indexes that are able to work with persisted data, and probably no way to
rebuild them for now.

Thanks!
-Dmitry



--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/