akka-persistence-cassandra icon indicating copy to clipboard operation
akka-persistence-cassandra copied to clipboard

Offsetstore timeuuidoffset is not being updated

Open gsiewe opened this issue 11 months ago • 0 comments

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?

gsiewe avatar May 19 '25 10:05 gsiewe