After more than one week trying to understand why this feature it wasn't
working one of my work mates found the reason.
We were using Apache Cassandra 2.0.14 that has a bug regarding static
columns: https://issues.apache.org/jira/browse/CASSANDRA-8502. The bug is
fixed in version 2.0.16 that we
Our BIG MISTAKE was that we totally forgot to read this simple lines of the
Cassandra Plugin's README file
"This version of akka-persistence-cassandra depends on Akka 2.4 and Scala
2.11.6. It is compatible with Cassandra 2.1.6 or higher (versions < 2.1.6
have a static column bug). Versions
Hi Patrick,
I am facing similar issues. Nearly losing around 40 to 50 % of the messages.
Running it on 2 node cluster(each is m4.xlarge machine)
There are two actors-
-- Conf :
---
akka {
loglevel = "INFO"
loggers = ["akka.event.slf4j.Slf4jLogger"]
log-dead-letters-during-shutdown
Consumers are IO bound.
On Wednesday, 28 October 2015 20:21:16 UTC+5:30, Arpit Rajpurohit wrote:
>
> Hi,
>
> Following is my app.conf. I am losing almost 50% of the messages. Is it
> because of the ClusterRouterPool ?
>
> Running it on 2 node cluster(each is m4.xlarge machine)
>
> There are two
Hi,
I have the following configuration which works fine but because we are
externalizing so that IT admins have full control of it, we need to be able
to mimic the *include "common"* section programmatically, here is the
configution:
include "common"
engine {
cluster.name = ${engine.cluster
I tried using withFallback(...) which has different semantics and behavior,
I need something that emulates include programmatically.
On Thursday, October 29, 2015 at 2:31:59 PM UTC, Guido Medina wrote:
>
> Hi,
>
> I have the following configuration which works fine but because we are
> externali
make the common.conf the application.conf and then load the externally
provided config with ConfigFactory.load?
On Thu, Oct 29, 2015 at 5:03 PM, Guido Medina wrote:
> I tried using withFallback(...) which has different semantics and
> behavior, I need something that emulates include programmatic
I tried renaming "common.conf" to "application.conf" but the thing is that
I'm not making a fat jar so the side effect you were expecting is not
happening, it would at been a nice trick though, it is not a big deal to
add *include "common"*, common.jar is one dependency of the project, we
avoid
Hey Sam,
if you are extending TestKitBase trait then his is the way to go :
TestActorRef[TestActor].underlyingActor.context
On Thursday, February 19, 2015 at 5:58:15 PM UTC+1, Sam Halliday wrote:
>
> On Thursday, 19 February 2015 16:54:47 UTC, Heiko Seeberger wrote:
>>
>> What about using an
Hi guys,
we're a startup company in social networking and we're now looking for new
backend developers, with solid Scala background and ideally with some Akka
experience, to join our young, agile, international and remote team. Akka
experience is not a requirement, but will definitely be an adv
I ran into the same issue in a staging environment with Akka 2.3.12 and
Cassandra as persistent backend. I did what Patrik suggested and believe it
is triggered by corrupted data by having started a second cluster for a
short period of time (2 minutes).
I am now trying to repair the data by del
Hi Heiko,
>From an engineering perspective, I genuinely believe you can make anything
work.
How well it works - how well it copes with faults etc - is where the rubber
the meets the road.
If you need fault tolerance, and horizintal scalability (as opposed to
vertical scale) - why would you not
Hi, I want to use akka.actor.Stash API. Is it possible to use
unstashAll(filterPredicate: Any ⇒ Boolean) method with Predicate in Java,
if yes can you please give an example code of usage.
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://
That's private API, please do not use it (it is marked as "INTERNAL API").
If you find yourself needing such filtering things, you should maintain a stash
yourself (keep a list of items in the actor).
--
Cheers,
Konrad 'ktoso’ Malawski
Akka @ Typesafe
On 29 October 2015 at 14:10:41, Gohar Gaspa
Update: I was able to recover after deleting some messages. I also found
this relevant issue https://github.com/akka/akka/issues/17955
I deleted the events persisted by the second cluster and all persistent
actors affected by it (that's probably optional and depends on your data
model), but wha
is there any way to override tell method of actorref and maintain counter
in override method to get count of al sent messages
--
>> Read the docs: http://akka.io/docs/
>> Check the FAQ:
>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>
Thats more of a task for monitoring tools, i.e. our reactive monitoring
than manually building the same :)
https://www.typesafe.com/blog/introducing-reactive-monitoring-v1-0-beta-reactive-platform
On Oct 29, 2015 23:03, "akkauser" wrote:
> is there any way to override tell method of actorref and
17 matches
Mail list logo
