带有Cassandra 3.0的SpringXD1.3.1流

Question

我使用的是随Cassandra 3.0.11附带的DSE 5.0.5

我正在尝试使用SpringXD1.3.1连接到Cassandra

我有一个处理数据的处理器模块和一个实际摄取数据的接收器。

我正在尝试创建如下流

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

注入流是名称，摄取-转换器是转换数据的模块.我几乎可以肯定这是没有问题的。

但是在"cassandra-3“这个水槽模块中，我面临着问题。

流创建失败，在日志中出现以下错误

2017-02-17T12:45:21+0530 1.3.1 startup错误配置路径儿童failed 0 boot.SpringApplication -应用程序启动失败

--然后有很多错误代码

原因是: org.springframework.beans.BeanInstantiationException:未能实例化包含bean 'cassandraConfiguration‘的org.springframework.data.cassandra.mapping.CassandraMappingContext:循环引用--考虑将工厂方法声明为静态的，以便独立于其包含实例。工厂方法'cassandraMapping‘抛出异常；嵌套异常为java.lang.NoClassDefFoundError:无法初始化类java.lang.NoClassDefFoundError

我的Sink模块正在使用

卡桑德拉-驱动-核心-3.0.0.jar和卡桑德拉-驱动-dse-3.0.0-字母5.jar

我也把这两个放在xd/lib/中。

它在Cassandra 2.2.5和SpringXD1.3.0中运行良好。

Answer 1

ApacheCassandra1.4.x和更早版本的Spring数据不适用于cassandra-driver-core-3.x和更高版本。ApacheCassandra1.4.x的Spring数据只支持驱动程序2.1版本。

ApacheCassandra1.5.x的Spring数据支持cassandra-driver-core-3.x及更高版本。

驱动程序从2.1升级到3.x会带来一系列破坏性的更改，这就是您在应用程序启动时得到的异常。