Hi,
On Wed, Aug 10, 2016 at 10:26 PM, tigerfoot wrote:
> For whoever finds this thread and struggles with the same problem... I've
> found a solution that fixed it for me.
>
> implicit val materializer = ActorMaterializer(
> ActorMaterializerSettings(system)
> .withAutoFusing(false)
For whoever finds this thread and struggles with the same problem... I've
found a solution that fixed it for me.
implicit val materializer = ActorMaterializer(
ActorMaterializerSettings(system)
.withAutoFusing(false) // flows with LateKafka get messed up if this
is true!
)
Disabling
Hi guys,
Yeah, I knew the first thing ya'll would need is a reproducer, but sadly
its wired into a lot of heavy complexity, and... I can't even reproduce it
consistently. It sometimes fails.
I haven't (consciously) set auto-fusing or fuzzing--it's whatever the
defaults are out-of-the-box.
fi
Hi Greg,
On Sat, Aug 6, 2016 at 1:11 AM, tigerfoot wrote:
> I'm having a nasty issue I hope someone can help me with.
>
> I have some stream code like this:
>
> val contentAssembly = Flow[CRec].map { crec =>
> println("HERE!")
> val x = expression.render(crec.value).asInsta
I'm having a nasty issue I hope someone can help me with.
I have some stream code like this:
val contentAssembly = Flow[CRec].map { crec =>
println("HERE!")
val x =
expression.render(crec.value).asInstanceOf[Message[OutputWrapper]]
println("X is "+x)
(crec,