datastax-eventsourcing:如何使用CassandraDSE进行事件源和重播的小代码示例

活动采购 该演示演示了如何使用Cassandra和DSE来存储和重播事件。 要使用Spark，您需要提供自己的Cassandra和Spark部署。 在本演示中，我们将使用DSE，因为它们已经集成。 首先，我们在SearchAnalyics模式启动DSE，使我们能够同时使用Spark和DSE搜索- 该实现使用存储桶将所有数据分组到特定的时间桶中以进行重放。 在此示例中使用的时间段为1分钟，但可以使用任何时间段。 同样取决于需要保留多少天，几个月，几年的事件，将事件分布在不同的表层上可能会有所帮助。 要创建模式，请运行以下命令 mvn clean compile exec:java -Dexec.mainClass="com.datastax.demo.SchemaSetup" -DcontactPoints=localhost 要创建solr核心以使我们的表可搜索，请运行以下命令 d