Martin Krasser

Thanks for clarifying Andrew. This means that our fold 1 results are now close (and I don't seem to have any gross errors in my training setup). I meanwhile also...

@seanmacavaney do you have any updates on this? I'm in the process of selecting potential candidates for a ranking pipeline and it is therefore important for me to be able...

To be more precise regarding > e.g. the set of query ids in `vbert-robust-f1.run` is **different** from the set of query ids in `data/robust/f1.test.run`, and also `cedrknrm-robust-f1.run` the number of...

This is something [already supported for the Akka-Camel integration](https://github.com/krasserm/streamz/blob/973054d43f64bf90450599237f294256c7beb03f/streamz-camel-akka/src/main/scala/streamz/camel/akka/EndpointConsumerReplier.scala#L51) but not yet implemented for FS2-Camel. When consuming a message from a Camel endpoint, you usually want to reply with an...

@igreenfield glad to hear 😃. Essentially, this is going to be a special case of (a more generic) [EndpointConsumerReplier](https://github.com/krasserm/streamz/blob/master/streamz-camel-akka/src/main/scala/streamz/camel/akka/EndpointConsumerReplier.scala#L48) which is going to replace [EndpointConsumer](https://github.com/krasserm/streamz/blob/master/streamz-camel-akka/src/main/scala/streamz/camel/akka/EndpointConsumer.scala#L39). I still plan working on...

Here: https://github.com/krasserm/streamz/blob/master/streamz-camel-akka/src/main/scala/streamz/camel/akka/EndpointConsumerReplier.scala#L76

What are you trying to achieve?

By adding an `ack` to the DSL that works like [reply](https://github.com/krasserm/streamz/blob/v-0.8.1/streamz-camel-akka/README.md#receiving-in-out-message-exchanges-from-an-endpoint) except that `ack` only completes the exchange without setting a response.

What exactly is unclear?

`reply` works in conjunction with [receiveReuqest](https://github.com/krasserm/streamz/blob/master/streamz-camel-akka/src/main/scala/streamz/camel/akka/scaladsl/package.scala#L133) which uses [EndpointConsumerReplier](https://github.com/krasserm/streamz/blob/master/streamz-camel-akka/src/main/scala/streamz/camel/akka/EndpointConsumerReplier.scala) under the hood. `ack` requires a re-implementation of [receive](https://github.com/krasserm/streamz/blob/master/streamz-camel-akka/src/main/scala/streamz/camel/akka/scaladsl/package.scala#L116) so that is uses a modified version of `EndpointConsumerReplier` under the hood...