Re: [akka-user] Using Akka in Eclipse

I use Eclipse-based Scala IDE. I import Maven projects. But I often have to right click on the project and do Maven -> Update Project. I also often have to do Scala -> Restart Presentation Compiler. Not sure if that's helpful. On Mon, Jul 3, 2017 at 11:45 AM, John Arnold

Re: [akka-user] Using Akka in Eclipse

Patrik, So, I imported the quickstart project as a Maven project. Looking at the build path, I see several jars in my ~/.m2/repository directory. I guess, and not being familiar enough with Maven nor Lightbend, that when I invoked the maven compile exec:exec that it pulled the required jar

Re: [akka-user] Using Akka in Eclipse

I think Eclipse has a plugin that understands a maven pom and adds the needed dependendencies to the project. You can import a maven project. In this case you are missing a transitive dependency. Trying to add/maintain those manually will be a pain so I suggest that you let the IDE/plugin handle

[akka-user] Using Akka in Eclipse

Using the Quickstart example (which builds and runs using Maven), I decided to try it in Eclipse. I added the 2 jars from my akka build, akka-actor_2.11-2.5-SNAPSHOT.jar and akka-testkit_2.11-2.5-SNAPSHOT.jar, and the sample program built successfully. Running produced an error:

Re: [akka-user] Alpakka SSE recovery

Sure thing. On Monday, July 3, 2017 at 11:07:09 AM UTC-4, loe...@posteo.de wrote: > > Thanks. That looks definitely like a bug. > Could you please open an issue against Alpakka? > > Cheers > Heiko > > > Am 03.07.2017 um 16:35 schrieb Bayarmunkh Davaadorj >: > > Hi, > > Here

Re: [akka-user] Alpakka SSE recovery

Thanks. That looks definitely like a bug. Could you please open an issue against Alpakka? Cheers Heiko > Am 03.07.2017 um 16:35 schrieb Bayarmunkh Davaadorj : > > Hi, > > Here are 3 scenarios I tested. > > 1. The server is unavailable, the client starts - the client is

Re: [akka-user] Alpakka SSE recovery

Hi, Here are 3 scenarios I tested. 1. The server is unavailable, the client starts - the client is unable to connect to the server when the server starts up. 2. The server is available, the client connects to the server. Then the server gets restarted before sending any message to the client -

Re: [akka-user] Role of Akka in SMACK

Hi again, Thought I'd share some numbers on performance comparison between Kafka Connect and Apache Spark. In my case, for ingesting data from Kafka to HDFS (HDP), Kafka Connect performs ~25% faster than Apache Spark. Both consumers read from a single, non-partitioned Kafka topic containing 5

Re: [akka-user] remoting comparison: Artery vs Netty

Likely bottlenecked either by network or serialization method (or quite possibly both?). -- Cheers, √ On Jul 3, 2017 1:06 PM, "Patrik Nordwall" wrote: > What is the unit of the values in the table, e.g. 416? I guess it's > milliseconds? > > That doesn't match our

Re: [akka-user] remoting comparison: Artery vs Netty

What is the unit of the values in the table, e.g. 416? I guess it's milliseconds? That doesn't match our tests at all. We have measured 800k msg/s for the 100 byte payload.

Re: [akka-user] Alpakka SSE recovery

It should just work. If not, it’s a bug. Could you please create a simple reproducer? Thanks Heiko -- Heiko Seeberger Home: heikoseeberger.de Twitter: @hseeberger Public key: keybase.io/hseeberger > Am 03.07.2017 um 07:52 schrieb Bayarmunkh Davaadorj : > > > Hi, > > I'm

[akka-user] remoting comparison: Artery vs Netty

Hi guys. We are migrating our application from akka 2.4 to 2.5 and among other there is new remoting available. The throughput Before switching from netty to artery we decided to compare them. So I created the app with two modules: sender & receiver with 16 remote actors spawned by sender on

[akka-user] Remoting comparison: Artery vs Netty

Hi guys. We are migrating out application to new version of akka (2.4 -> 2.5) and among other the is a new version of remoting available. Before switch from netty to artery we decided to compare them. I tested them with three types of message sizes: 100 bytes, 1000 bytes, 1bytes with

[akka-user] How to syncronize cold streams of different frequency based on timestamped data

Hi I need to make a fan-in stage where I zip together data of different streams with different frequency. Imagine that you have a stream of replayable realtime sensor data and anotherone of replayable hourly data. To make a simple example I have timestamped events like realtimeStream =

Re: [akka-user] How to colocate two different actor types?

Some pointers: https://github.com/akka/akka/blob/master/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ClusterSharding.scala#L206 https://github.com/akka/akka/blob/master/akka-cluster-sharding/src/main/scala/akka/cluster/sharding/ShardCoordinator.scala#L60 On Sun, Jul 2, 2017 at

[akka-user] Alpakka SSE recovery

Hi, I'm using Alpakka SSE https://github.com/akka/alpakka/tree/master/sse. What's a good way to reconnect to the server when the server gets restarted? Currently it just stays hanging. Thanks -- >> Read the docs: http://akka.io/docs/ >> Check the FAQ: >>