infinispan/infinispan-cachestore-cassandra

Infinispan Cassandra Cache Store

Infinispan, In-Memory Distributed Data Store

Infinispan is an open-source in-memory data grid that offers flexible deployment options and robust capabilities for storing, managing, and processing data.

Infinispan provides a key/value data store that can hold all types of data, from Java objects to plain text.

Infinispan distributes your data across elastically scalable clusters to guarantee high availability and fault tolerance, whether you use Infinispan as a volatile cache or a persistent data store.

Getting Started

• Documentation
• 5 Minutes Getting Started
• Simple Tutorials

Contributing

For contributing guidelines please refer to this document. All contributions are subject to Developer Certificate of Origin (DCO).

The Infinispan project team

infinispan-cachestore-cassandra's Issues

Failure deploying jar with dependencies on Infinispan Server

Deploying the jar-with-dependencies on to Infinispan Server fails with the following log:

08:33:09,832 ERROR [org.jboss.msc.service.fail] (MSC service thread 1-6) MSC000001: Failed to start service jboss.deployment.unit."infinispan-cachestore-cassandra-9.4.1-SNAPSHOT-jar-with-dependencies.jar".POST_MODULE: org.jboss.msc.service.StartException in service jboss.deployment.unit."infinispan-cachestore-cassandra-9.4.1-SNAPSHOT-jar-with-dependencies.jar".POST_MODULE: WFLYSRV0153: Failed to process phase POST_MODULE of deployment "infinispan-cachestore-cassandra-9.4.1-SNAPSHOT-jar-with-dependencies.jar"
	at [email protected]//org.jboss.as.server.deployment.DeploymentUnitPhaseService.start(DeploymentUnitPhaseService.java:151)
	at [email protected]//org.jboss.msc.service.ServiceControllerImpl$StartTask.startService(ServiceControllerImpl.java:1736)
	at [email protected]//org.jboss.msc.service.ServiceControllerImpl$StartTask.execute(ServiceControllerImpl.java:1698)
	at [email protected]//org.jboss.msc.service.ServiceControllerImpl$ControllerTask.run(ServiceControllerImpl.java:1556)
	at [email protected]//org.jboss.threads.ContextClassLoaderSavingRunnable.run(ContextClassLoaderSavingRunnable.java:35)
	at [email protected]//org.jboss.threads.EnhancedQueueExecutor.safeRun(EnhancedQueueExecutor.java:1985)
	at [email protected]//org.jboss.threads.EnhancedQueueExecutor$ThreadBody.doRunTask(EnhancedQueueExecutor.java:1487)
	at [email protected]//org.jboss.threads.EnhancedQueueExecutor$ThreadBody.run(EnhancedQueueExecutor.java:1378)
	at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: java.lang.ExceptionInInitializerError
	at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
	at java.base/jdk.internal.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
	at java.base/jdk.internal.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
	at java.base/java.lang.reflect.Constructor.newInstance(Constructor.java:490)
	at org.infinispan.extension:[email protected]//org.jboss.as.clustering.infinispan.cs.deployment.AbstractCacheStoreExtensionProcessor.addServices(AbstractCacheStoreExtensionProcessor.java:50)
	at org.infinispan.extension:[email protected]//org.jboss.as.clustering.infinispan.cs.deployment.AbstractCacheStoreExtensionProcessor.deploy(AbstractCacheStoreExtensionProcessor.java:33)
	at [email protected]//org.jboss.as.server.deployment.DeploymentUnitPhaseService.start(DeploymentUnitPhaseService.java:144)
	... 8 more
Caused by: java.lang.IllegalArgumentException: Logger implementation class org.infinispan.persistence.cassandra.logging.Log_$logger has no matching constructor
	at org.jboss.logging:[email protected]//org.jboss.logging.Logger$1.run(Logger.java:2562)
	at java.base/java.security.AccessController.doPrivileged(Native Method)
	at org.jboss.logging:[email protected]//org.jboss.logging.Logger.getMessageLogger(Logger.java:2529)
	at org.jboss.logging:[email protected]//org.jboss.logging.Logger.getMessageLogger(Logger.java:2516)
	at org.infinispan.core:[email protected]//org.infinispan.util.logging.LogFactory.getLog(LogFactory.java:23)
	at deployment.infinispan-cachestore-cassandra-9.4.1-SNAPSHOT-jar-with-dependencies.jar//org.infinispan.persistence.cassandra.CassandraStore.<clinit>(CassandraStore.java:48)
	... 15 more

How to configure authentication with Cassandra

We are using Cassandra with authentication (username and password).
Could you please suggest how to configure cassandra username and password.

Is Infinispan-cachestore-cassandra project alive?

Hi,

Following the docs of Infinispan I've noticed it's possible to use a particular cachestore to persist the cached data in some fashion.. I'd like to test some solutions for a POC and looking at the code of this repository, it seems this project is dead.

Is there an interest to make this project updated with the latest version of Infinispan or thinking to a different cachestores (not only the default) is not so important for the Infinispan project?

I'm speaking about all the different cachestore projects (mongodb, leveldb, berkeleydb etc.)

Andrea

Tag and release 13.0.10.Final

@tristantarrant @jabolina In order to use the newly updated version of this cache-store, it would be nice if you tagged and released a new version.

Preferrably to a public maven-repository as well.

Thank you!

Update to Infinispan 14.x.x

Infinispan 14 has been released, so this extension has to be updated as well. I can do it myself, as soon as i get around to it.

Compatibility with Infinispan 6 or 7

Does this work with either? There doesn't seem to be a module for Cassandra in either and the configuration does not load.

Add SSL-Configuration for Cassandra Driver

Currently there is only a flag to enable or disable SSL. An improvement would be to expose the SSL options of the driver, see https://docs.datastax.com/en/developer/java-driver/4.14/manual/core/ssl/.

9.4.11: ISPN000026: Caught exception purging data container!: java.lang.NullPointerException

To reproduce:

1. Configure the cache-container as follows:

<cache-container name="local" default-cache="default" statistics="true">
    <local-cache name="default"/>
    <local-cache name="sessions">
        <persistence>
            <store class="org.infinispan.persistence.cassandra.CassandraStore" shared="true">
                <property name="keyspace">foo</property>
                <property name="entryTable">bar</property>
                <property name="readConsistencyLevel">LOCAL_ONE</property>
                <property name="readSerialConsistencyLevel">SERIAL</property>
                <property name="writeConsistencyLevel">QUORUM</property>
                <property name="writeSerialConsistencyLevel">SERIAL</property>
                <property name="autoCreateKeyspace">true</property>
                <property name="replicationStrategy">{'class':'SimpleStrategy','replication_factor':1}</property>
                <property name="compression">{'sstable_compression':'LZ4Compressor'}</property>
                <property name="useSsl">false</property>
                <property name="servers">localhost[9042]</property>
                <property name="connectionPool.heartbeatIntervalSeconds">30</property>
                <property name="connectionPool.idleTimeoutSeconds">120</property>
                <property name="connectionPool.poolTimeoutMillis">2000</property>
            </store>
        </persistence>
    </local-cache>
</cache-container>

2. Build and copy infinispan-cachestore-cassandra-9.4.1-SNAPSHOT-jar-with-dependencies.jar into standalone/deployments/ inside the ISPN distribution. I used this commit.
3. Run cassandra on the same host.
4. Run standalone.sh with the modified config file.

After starting the following message will appear in the logs at regular intervals:

WARN  [org.infinispan.persistence.manager.PersistenceManagerImpl] (pool-9-thread-1) ISPN000026: Caught exception purging data container!: java.lang.NullPointerException
	at org.infinispan.core:[email protected]//org.infinispan.persistence.manager.PersistenceManagerImpl.lambda$purgeExpired$6(PersistenceManagerImpl.java:454)
	at java.base/java.util.ArrayList.forEach(ArrayList.java:1540)
	at org.infinispan.core:[email protected]//org.infinispan.persistence.manager.PersistenceManagerImpl.purgeExpired(PersistenceManagerImpl.java:465)
	at org.infinispan.core:[email protected]//org.infinispan.expiration.impl.ExpirationManagerImpl.processExpiration(ExpirationManagerImpl.java:111)
	at org.infinispan.core:[email protected]//org.infinispan.expiration.impl.ExpirationManagerImpl$ScheduledTask.run(ExpirationManagerImpl.java:245)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515)
	at java.base/java.util.concurrent.FutureTask.runAndReset(FutureTask.java:305)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:305)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
	at java.base/java.lang.Thread.run(Thread.java:834)

Note: I'm actually running the docker container in the last step above, but I get the same error when running ISPN natively on a Mac (Mojave).

How to use this ? any spring boot example ? to use remote JBoss/infinispan ? will it work with JBoss/infinispan 9.4?

Need a spring boot example to use this.

How to use this ? any spring boot example ? to use remote JBoss/infinispan ? will it work with JBoss/infinispan 9.4?