flux Spring XD 1.3.1 avec Cassandra 3.0

Question

J'utilise DSE 5.0.5 qui viennent avec Cassandra 3.0.11

Je suis en train d'utiliser Spring XD 1.3.1 pour se connecter à Cassandra

I avoir un module de processeur qui traite les données et un puits qui ingère réellement les données.

Je suis en train de créer flux comme ci-dessous

stream create --name ingestion-stream --definition "http --port=9020 

|ingestion-transformer| cassandra-3 --contactPoints='1.2.3.4.' -- 

keyspace='mykeyspace' --ingestQuery='insert into table1(column1,column2,column3) 

values (?,?,?)'" --deploy 

Le courant d'injection est le nom, transformateur d'ingestion est le module qui transforme les données. Je suis presque sûr qu'il n'y a pas de problème avec ça.

Mais dans le « cassandra-3 » qui est un module évier, je suis face à problème

La création de flux échoue, ce qui donne ci-dessous une erreur dans le journal

2017-02-17T12:45:21+0530 1.3.1.RELEASE ERROR DeploymentsPathChildrenCache-0 boot.SpringApplication - Application startup failed

- alors il y a beaucoup de code d'erreur ----

Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.data.cassandra.mapping.CassandraMappingContext]: Circular reference involving containing bean 'cassandraConfiguration' - consider declaring the factory method as static for independence from its containing instance. Factory method 'cassandraMapping' threw exception; nested exception is java.lang.NoClassDefFoundError: Could not initialize class org.springframework.data.cassandra.mapping.CassandraSimpleTypeHolder

Mon module évier utilise

-cassandra chauffeur- core-3.0.0.jar et cassandra-driver-dse-3.0.0-alpha5.jar

J'ai aussi placé ces deux dans xd/lib/

Il fonctionnait très bien avec Cassandra et 2.2.5 Spring XD 1.3.0

Answer 1

Les données de ressort pour Apache Cassandra 1.4.x et les versions antérieures ne fonctionnent pas avec cassandra-driver-core-3.x et versions ultérieures. Spring Data pour Apache Cassandra 1.4.x ne supporte que la version 2.1 du pilote. Les données de ressort pour Apache Cassandra 1.5.x prennent en charge cassandra-driver-core-3.x et les versions ultérieures.

La mise à niveau du pilote de la version 2.1 à la version 3.x s'accompagne d'une série de modifications de rupture, c'est-à-dire que vous bénéficiez d'exceptions au démarrage de l'application.