I'm having an issue where the journalBatch queue is just filling up with
messages and no writes are happening to Cassandra.
After examining the heap dump and thread stacks I can see that the variable
Eventsourced.writeInProgress set to 'true' which prevents writes of the
messages in journalBat
On Mon, Jan 16, 2017 at 11:57 PM, Alan Burlison
wrote:
> On 16/01/17 21:22, Patrik Nordwall wrote:
>
> You should not serialize PersistentRepr, unless you are using a key-value
>> store that can only store one single value per key.
>>
>
> It's a flat file so the concept of columns only exists ins
Akka version?
tis 17 jan. 2017 kl. 02:53 skrev Dai Yinhua :
> Hi,
>
> I was running a akka cluster, but when I start only one instance of the
> akka application, then it will throw below exception repeatedly, can you
> help to explain what is the issue and how to avoid it.
>
> [ERROR] [01/17/2017
Hi,
I was running a akka cluster, but when I start only one instance of the
akka application, then it will throw below exception repeatedly, can you
help to explain what is the issue and how to avoid it.
[ERROR] [01/17/2017 07:54:57.033]
[RTAPCluster-akka.actor.default-dispatcher-12]
[akka.re
On 16/01/17 21:22, Patrik Nordwall wrote:
You should not serialize PersistentRepr, unless you are using a key-value
store that can only store one single value per key.
It's a flat file so the concept of columns only exists insofar as I
define it - which is why I was intending to serialize to
On 16/01/17 20:45, Konrad Malawski wrote:
Pick a Journal which does this, simple.
Akka has absolutely no control over how a given Akka Persistence Journal
Plugin decides to persist things.
Research the available journals and which allows to save things like this.
I have, I've been unable to f
You should not serialize PersistentRepr, unless you are using a key-value
store that can only store one single value per key. Instead, grab the meta
data fields from PersistentRepr and save them in separate columns. Grab the
payload, serialize it, and save its bytes (the json) in a separate column.
Pick a Journal which does this, simple.
Akka has absolutely no control over how a given Akka Persistence Journal
Plugin decides to persist things.
Research the available journals and which allows to save things like this.
You did not mention which datastore you're using, which is very very
releva
I'm trying to write a persistence journal plugin (AsyncWriteJournal)
that saves entirely in JSON. I've created a serializer that serializes
to JSON and hooked that up along with my custom journal plugin, and
whilst the objects I'm saving are being persisted as JSON, the
PersistentRepr that wraps th
I'd like to be able to use akka-http with chunked responses. I'd like to know
if I can do the same thing in akka-http as with the playframework. The
following is from playframework documentation.
def index = Action {
val source = Source.apply(List("kiki", "foo", "bar"))
Ok.chunked(source)
Hi, Can you anyone plz let me know that how to enable tls or ssl support in
io tcp?
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>> Search the archives: https://groups.googl
I should clarify my post. My messages aren't backing up in those three
queues at the same time, the problem has moved each time I've changed the
actor's queuing behavior. The first time I examined a heap dump all the
objects were in the mailbox of the actor. So I changed the mailbox to use a
bo
12 matches
Mail list logo