Aaronontheweb on 1.4.16
Aaronontheweb on dev
Added v1.4.16 release notes (#1… (compare)
Aaronontheweb on 1.4.16
Added v1.4.16 release notes (compare)
Aaronontheweb on dev
Correct warning on circuit too … (compare)
dependabot-preview[bot] on nuget
dependabot-preview[bot] on dev
Bump AkkaVersion from 1.4.14 to… (compare)
dependabot-preview[bot] on nuget
NewtonSoftJsonSerializer
Hey guys,
I have data duplication issue when using TCP. I'm sending from "for" loop on client and reply with the same message from akka (echo).
If the message size 15 bytes + 4 for length, everything is perfect (sent 20k messages that is arrived in order and no duplication).
If message size more than that, duplications arrived. The pattern here is 1,2,3,4,2,3,4,5,6,7,8,2,3,4,5,6,7,8,9,10, ... (not always)
From my investigation the issue caused by
I have a repro project and will send to anyone who volunteers for investigation :)
akka {
stdout-loglevel = DEBUG
loglevel = DEBUG
loggers=["Akka.Logger.Serilog.SerilogLogger, Akka.Logger.Serilog"]
log-config-on-start = on
actor {
provider = "cluster"
}
remote {
dot-netty.tcp {
hostname = "127.0.0.1"
port = 8081
maximum-frame-size = 256000b
}
}
cluster {
seed-nodes = ["akka.tcp://tradex@127.0.0.1:4053"] # address of seed node
roles = ["ordersync", "logger"] # roles this member is in
role.["ordersync"].min-nr-of-members = 3 # crawler role minimum node count
# auto downing is NOT safe for production deployments.
# you may want to use it during development, read more about it in the docs.
#
# auto-down-unreachable-after = 10s
}
}
IActorRef<obj>
, but then you'll catch any obj matching signature, including system messages sent to an actor. There's no easy way to just filter them out. Once I'll be done with porting akka-typed, then this will be much easier and consistent to do.