akka-persistence-cassandra
akka-persistence-cassandra copied to clipboard
Offsetstore timeuuidoffset is not being updated
Versions used
Lagom 1.6.0 akka 2.6.9 akka-http 10.1.11 akka-persistence-cassandra 0.101
Expected Behavior
When events are stored in tag_views and messages tables, the ReadSideProcessor should get the events after some time.
Actual Behavior
The ReadSideProcessor is only getting the events after the restart of the service.
Relevant logs
I couldn't find any logs helping to understand the issue, even after enabling DEBUG.
Reproducible Test Case
Config
This is a part of my config
cassandra-snapshot-store {
keyspace = feedbackservice
write-consistency = "ONE"
read-consistency = "ONE"
contact-points = [${CASSANDRA_CONTACT_POINT_ONE},${CASSANDRA_CONTACT_POINT_TWO}]
session-provider = akka.persistence.cassandra.ConfigSessionProvider
replication-strategy = "NetworkTopologyStrategy"
data-center-replication-factors = ["DC3-ChatYamo:2", "DC4-ChatYamo:1"]
local-datacenter = ""
local-datacenter = ${?CASSANDRA_LOCAL_DATACENTER}
keyspace-autocreate = false
tables-autocreate = false
}
cassandra-journal {
keyspace = feedbackservice
write-consistency = "ONE"
read-consistency = "ONE"
contact-points = [${CASSANDRA_CONTACT_POINT_ONE},${CASSANDRA_CONTACT_POINT_TWO}]
session-provider = akka.persistence.cassandra.ConfigSessionProvider
replication-strategy = "NetworkTopologyStrategy"
data-center-replication-factors = ["DC3-ChatYamo:2", "DC4-ChatYamo:1"]
local-datacenter = ""
local-datacenter = ${?CASSANDRA_LOCAL_DATACENTER}
keyspace-autocreate = false
tables-autocreate = false
}
lagom {
persistence.read-side.cassandra {
keyspace = feedbackservice
write-consistency = "ONE"
read-consistency = "ONE"
max-result-size = 1000
contact-points = [${CASSANDRA_CONTACT_POINT_ONE},${CASSANDRA_CONTACT_POINT_TWO}]
session-provider = akka.persistence.cassandra.ConfigSessionProvider
replication-strategy = "NetworkTopologyStrategy"
data-center-replication-factors = ["DC3-ChatYamo:2", "DC4-ChatYamo:1"]
local-datacenter = ""
local-datacenter = ${?CASSANDRA_LOCAL_DATACENTER}
keyspace-autocreate = false
tables-autocreate = false
}
# Circuit breaker settings - add or update
circuit-breaker {
default {
max-failures = 5
call-timeout = 20s
reset-timeout = 60s
}
}
cluster.exit-jvm-when-system-terminated = on
}
is there something i’m missing or doing wrong? Can someone please help?