Hi, guys!

Is it possible to initialize my property with an injected resource at inner
static class of Ignite Service?

    private static class LocalListener implements
CacheEntryUpdatedListener<CaseKey, Case> {

        @SpringResource(resourceName = "kafkaProducerProperties")
        private static Properties kafkaProducerProperties;

        private static KafkaProducer<String, String> kafkaProducer;

        @Override
        public void onUpdated(Iterable<CacheEntryEvent&lt;? extends CaseKey,
? extends Case>> events) throws CacheEntryListenerException {
            for (CacheEntryEvent event : events) {

I want the kafkaProducer to be initialized with new
KafkaProducer(kafkaProducerProperties) like this:
kafkaProducer = new KafkaProducer<>(kafkaProducerProperties); 




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

Reply via email to