0

Lagom セットアップ用に外部 Cassandra をセットアップしようとしています。

ルートポンで私が書いた

                    <configuration>
                        <unmanagedServices>
                            <cas_native>http://ip:9042</cas_native>
                        </unmanagedServices>
                        <cassandraEnabled>false</cassandraEnabled>
                    </configuration>

私のimpl application.confで

akka {
persistent {
  journal {
  akka.persistence.journal.plugin = "this-cassandra-journal"

      this-cassandra-journal {
        contact-points = ["10.15.2.179"]
        port = 9042
        cluster-id = "cas_native"

        keyspace = "hello"

        authentication.username = "cassandra"
        authentication.password = "rodney"
        # Parameter indicating whether the journal keyspace should be auto created
        keyspace-autocreate = true

        # Parameter indicating whether the journal tables should be auto created
        tables-autocreate = true
      }
  }

  snapshot-store {
    akka.persistence.snapshot-store.plugin = "this-cassandra-snapshot-store"

      this-cassandra-snapshot-store {
        contact-points = ["10.15.2.179"]
        port = 9042
        cluster-id = "cas_native"

        keyspace = "hello_snap"
        authentication.username = "cassandra"
        authentication.password = "rodney"
        # Parameter indicating whether the journal keyspace should be auto created
        keyspace-autocreate = true

        # Parameter indicating whether the journal tables should be auto created
        tables-autocreate = true
      }
    }

}

しかし、私はエラーが発生します

[warn] a.p.c.j.CassandraJournal - Failed to connect to Cassandra and initialize.
 It will be retried on demand. Caused by: Authentication error on host /10.15.2.
179:9042: Host /10.15.2.179:9042 requires authentication, but no authenticator f
ound in Cluster configuration
[warn] a.p.c.s.CassandraSnapshotStore - Failed to connect to Cassandra and initi
alize. It will be retried on demand. Caused by: Authentication error on host /10
.15.2.179:9042: Host /10.15.2.179:9042 requires authentication, but no authentic
ator found in Cluster configuration
[warn] a.p.c.j.CassandraJournal - Failed to connect to Cassandra and initialize.
 It will be retried on demand. Caused by: Authentication error on host /10.15.2.
179:9042: Host /10.15.2.179:9042 requires authentication, but no authenticator f
ound in Cluster configuration
[error] a.c.s.PersistentShardCoordinator - Persistence failure when replaying ev
ents for persistenceId [/sharding/ProductCoordinator]. Last known sequence numbe
r [0]
com.datastax.driver.core.exceptions.AuthenticationException: Authentication erro
r on host /10.15.2.179:9042: Host /10.15.2.179:9042 requires authentication, but
 no authenticator found in Cluster configuration
        at com.datastax.driver.core.AuthProvider$1.newAuthenticator(AuthProvider
.java:40)
        at com.datastax.driver.core.Connection$5.apply(Connection.java:250)
        at com.datastax.driver.core.Connection$5.apply(Connection.java:234)
        at com.google.common.util.concurrent.Futures$AsyncChainingFuture.doTrans
form(Futures.java:1442)
        at com.google.common.util.concurrent.Futures$AsyncChainingFuture.doTrans
form(Futures.java:1433)
        at com.google.common.util.concurrent.Futures$AbstractChainingFuture.run(
Futures.java:1408)
        at com.google.common.util.concurrent.Futures$2$1.run(Futures.java:1177)
        at com.google.common.util.concurrent.MoreExecutors$DirectExecutorService
.execute(MoreExecutors.java:310)
        at com.google.common.util.concurrent.Futures$2.execute(Futures.java:1174
)

私もこの設定を提供しようとしました

lagom.persistence.read-side {
  cassandra {
  }
}

Cassandra の資格情報を提供して機能させるにはどうすればよいですか?

4

1 に答える 1

4

Lagom では、すでに と の設定を使用しakka-persistence-cassandraている場合があります(ソース コードの reference.conf を参照し、下にスクロールして を探します)。Cassandra 永続化に対する Lagom のサポートは、Akka 永続化実装として既に宣言されているため、構成する必要はありません。journalsnapshot-storecassandra-snapshot-store.authentication.*akka-persistence-cassandra

akka.persistence.journal.plugin = cassandra-journal akka.persistence.snapshot-store.plugin = cassandra-snapshot-store

https://github.com/lagom/lagom/blob/c63383c343b02bd0c267ff176bfb4e48c7202d7d/persistence-cassandra/core/src/main/resources/play/reference-overrides.conf#L5-L6を参照してください。

Lagom を Cassandra に接続するときに構成する最後の 3 番目のビットは、Lagom の読み取り側です。デフォルトapplication.confをオーバーライドすると、それも可能です。

各ストレージが異なる Cassandra Ring/Keyspace/credentials/... を使用する可能性があるため、個別に調整できることに注意してください。

Lagom docsの追加情報を参照してください。

于 2017-03-07T12:42:08.810 に答える