Ensar Sarajčić
Ensar Sarajčić
@pront I think I am now stuck on this :smile: Maybe there is a better way to handle this, but it feels like I need to define some of the...
@pront @lukesteensen I have finally managed to get some more time to focus on this and wrap my head around the whole topology building and running process and after a...
Is it possible to achieve something similar with `MsgPackDynamicSerializer` right now? I will look into this. Could you provide an example code of what you are trying to achieve?
> Sorry for the delayed response, I've been trying to use MsgPackDynamicSerializer but doesn't seem to work for me, but maybe it's skill issue. What I'm trying to achieve is...
I have made this just a draft, to confirm if it makes sense to add these to the existing `aggregate` transform. Right now I have just added an enum and...
I still need to clean some things up here, since it is a bit messy, but I wanted to get initial review on this.
@pront The CI has failed due to 502 error. Can we restart it so this can get merged?
I have left this as a draft, since I am not sure how to handle shutdown (which shutdown signal to use) and how to name the task (or maybe run...
@pront Any suggestion for running this separate task? It is currently started as following: ```rust running_topology.utilization_task = // TODO: how to name this custom task? Some(tokio::spawn(Task::new("".into(), "", async move {...
I haven't been able to figure out what causes these component validation tests to get stuck when stopping the topology. I can see that the utilization task stops properly, but...