alpakka - alpakka cassandrasource 从 cassandra 连续读取数据

Question

我们正在做一些 POC 以使用 Alpakka CassandraSource 连续读取 cassandra 表。以下是示例代码：

final Statement stmt = new SimpleStatement("SELECT * FROM testdb.emp1").setFetchSize(20);
final CompletionStage<List<Row>> rows =  CassandraSource.create(stmt, session).runWith(Sink.seq(), materializer);
rows.thenAcceptAsync( e -> e.forEach(System.out::println));

上面的代码从 emp1 表中获取行。由于该表不断增长，我们需要在数据可用时继续阅读。有什么方法可以在 CassandraSource 中设置连续读取？

Answer 1

目前不支持在 Alpakka Cassandra 连接器中连续读取表格。但是，您可以通过包装CassandraSource.create一个RestartSource.withBackoff在完成后重新启动 cassandra 源来使其工作。更多关于在文档中重新启动源。