Stack Overflow
Stack Overflow

Questions tagged [akka.net-streams]

16 questions
3
votes
0 answers

Does Kafka support creating projections from multiple category streams?

We are using EventStore for our event sourced solution. We would like to export events into Kafka and do stream processing using Kafka. In EventStore each type of stream belongs to a category, for example Order, Customer, Payment etc. Under each…
epitka
  • 17,275
  • 20
  • 88
  • 141
2
votes
1 answer

Akka.Net: Reactive Streams over the network

I am trying to implement both the Source as origin and the Sink as remote, and then the Sink as origin and the Source as remote, Type 1 and Type 2 workflows within the AkkaStreamsModel Respectively. Type 1 creates a SourceRef and passes this to the…
Brett
  • 43
  • 6
2
votes
2 answers

How to use Akka.Streams.*.ConcatMany in F#?

I want to create a flow that creates a new source (it will be a persistence query) out of incoming elements, and then flattens the results. Something like this simplified example: var z = Source.Single(1).ConcatMany(i => Source.Single(i)); this…
pmbanka
  • 1,902
  • 17
  • 24
2
votes
0 answers

Akka.net journal reader missing events

In our application we are using Akka.net, with event sourcing. The persistent actors save their events in an SQL Server database. We also have view actors, which subscribe to these events, using a journal reader/persistence query, to create…
George
  • 315
  • 3
  • 15
2
votes
1 answer

Sending stream (e.g. file) from actor to actor

I want to sent data from a stream in one actor to a stream in another actor. In the end this should work with remote actors. With Akka.NET Streams this should be an easy task but maybe I have misconcepted it. This is part of the SenderActor: var…
ZoolWay
  • 5,411
  • 6
  • 42
  • 76
1
vote
1 answer

Simple TCP server with Akka.NET

Hi I'm learning to use Akka.net and what I want to do is, create a simple TCP server that will periodically send data to the tcp connection. (which will then be picked up by a processingjs client and display in the output) Not sure what I'm missing…
Romesh D. Niriella
  • 470
  • 6
  • 20
1
vote
1 answer

How to enqueue items into akka.net queue source

After creating a queue source in akka.net streams, how can I add items to the queue? There is no Enqueue, Add or Offer method in created object. Source> source = Source.Queue(100,…
Yaniv Shalom
  • 11
  • 3
0
votes
2 answers

How to merge events from 2 Event Sourcing systems

I need to merge events coming from 2 different event sourcing systems handled by Akka.Net Persistence module. The merge must sort events based on their timestamp, and I found the MergeSorted operator in Akka.Stream that does exactly what I need…
Daniele Armanasco
  • 7,289
  • 9
  • 43
  • 55
0
votes
1 answer

Akka.net Persistence Query -Events by Tag- stream order guarantee

I am working on building a solution with Akka.net that will allow for a persistence query that queries multiple tags. One of the ways i thought of doing this was to simply materialize 1 stream for each tag and then use akka.net stream abstractions…
Patrick Wood
  • 25
  • 5
0
votes
0 answers

In Akka.Net can we derive TcpStream actor from Tcp actor?

In Akka.Net can we derive TcpStream actor from Tcp actor ? I created a Tcp actor using Context.System.Tcp().Tell(new IoTcp.Connect(endPoint)); Then I register my self as the handler Sender.Tell(new IoTcp.Register(Self, true, true)); The endpoint…
Alex David
  • 585
  • 1
  • 11
  • 32
0
votes
1 answer

How to Integrate Akka.Net Streams with AspNet core, or giraffe

When I use Giraffe or ASP.Net Core in general, I can create an actor system, add it as a service and then get It thought the request handler select any actor and ask/tell a message. Either using Cluster.Sharding or a normal user/actor I know it will…
Coding Edgar
  • 1,285
  • 1
  • 8
  • 22
0
votes
1 answer

Akka.Streams.Amqp.IncomingMessage.Envelope.RoutingKey value is incorrect

I am trying to read the incoming message on RabbitMQ via Akka.streams.Ampq source but the RoutingKey is incorrect. Another concerning issue that the envelope does not contain the exchange name. //code coming back with incorrect key public void…
Lizo Matala
  • 64
  • 7
0
votes
1 answer

Creating an async stream source

I have an expensive method to call for creating a batch of source items: private Task> GetUnprocessedBatch(int batchSize) { //impl } I want to populate new items only when there is no item to process(or it falls below a certain…
Ufuk Hacıoğulları
  • 37,978
  • 12
  • 114
  • 156
0
votes
1 answer

Why isn't my Akka.NET Stream Subscriber receiving messages?

I'm am having a go at writing a simple Akka.NET streams flow. The Source is an IActorRef. The Sink is a ISubscriber. I am using TestKit to implement it as a unit test: [Fact] public void AkkaStreams_ActorSourcePublisherSink_Works() { using (var…
mistakenot
  • 554
  • 3
  • 14
0
votes
1 answer

Is it a good idea to use kinesis for message passing in akka.net

We're currently building an actor system with DDD Principles on top of Akka.NET. We have several missing points in how to make our service resilient: At-Most-Once-Delivery by default between Actors Resilience of the actors mailboxes FSMActors are…
trialgod
  • 302
  • 1
  • 15
1
2