Re: How to set cache name in Kafka connect?

[Andrey Gura]

Hi,

you should get data streamer using cache name. You example should be
modified like this:

            Ignition.setClientMode(true);

                try (Ignite ignite =
Ignition.start("D:/Applns/apache-ignite-fabric-1.6.0-bin/apache-ignite-fabric-1.6.0-bin/examples/config/example-ignite.xml"))
{
                                String cacheName = "Democache"; //
NAME OF YOUR CACHE
                                CacheConfiguration<Integer, String>
cfg = new CacheConfiguration<>();
                                cfg.setName();
                                IgniteCache<Integer, String> cache =
ignite.getOrCreateCache(cfg);

                        try (IgniteDataStreamer<String, String> stmr =
ignite.dataStreamer(cacheName)) // USE CACHE NAME HERE
{
                                stmr.allowOverwrite(true);

                                KafkaStreamer<String, String, String>
kafkaStreamer = new KafkaStreamer<>();

                                kafkaStreamer.setIgnite(ignite);
                                kafkaStreamer.setStreamer(stmr);
                                kafkaStreamer.setTopic("cachetest3");
                                kafkaStreamer.setThreads(4);

                                Properties settings = new Properties();
                                settings.put("bootstrap.servers",
"192.168.15.120:9092");
                                settings.put("group.id", "test");
                                settings.put("zookeeper.connect",
"192.168.15.120:2181");

settings.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");

settings.put("key.deserializer","org.apache.kafka.common.serialization.StringDeserializer");

settings.put("value.serializer","org.apache.kafka.common.serialization.StringSerializer");

settings.put("value.deserializer","org.apache.kafka.common.serialization.StringDeserializer");

                                kafka.consumer.ConsumerConfig config =
new ConsumerConfig(settings);
                                kafkaStreamer.setConsumerConfig(config);

                                StringDecoder strDecoder = new StringDecoder(new
VerifiableProperties());
                                kafkaStreamer.setKeyDecoder(strDecoder);
                                kafkaStreamer.setValueDecoder(strDecoder);

                                kafkaStreamer.start();
                        } finally {
                                kafkaStreamer.stop();
                        }

                }

On Wed, May 17, 2017 at 3:52 PM, Humphrey <hmmlo...@gmail.com> wrote:
> Take a look here.
>
> http://apache-ignite-users.70518.x6.nabble.com/Kindly-tell-me-where-to-find-these-jar-files-td12649.html
>
> Here I posted some code.
>
> Humphrey
>
>
>
> --
> View this message in context: 
> http://apache-ignite-users.70518.x6.nabble.com/How-to-set-cache-name-in-Kafka-connect-tp12959p12969.html
> Sent from the Apache Ignite Users mailing list archive at Nabble.com.