Mark

Projections are a `scan` / `reduce` over a `F[A]` where `F[_]` can be akka-stream Source, scala `List`, monix `Observable` etc. You could compose them by using Kleisli arrows.

Sad to see this stale, did some digging. KafkaProducer as in 0.9 (http://kafka.apache.org/090/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html) only supports send which returns a Future. We could "block" on this, emulating the old sync API....

The Java database driver seems to buffer the writes in the background. The protocol itself (https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol#AGuideToTheKafkaProtocol-ProduceRequest) supports sending a `MessageSet` to a topic + partition which is what we want.

It would be great to have akka-persistence working on the latest kafka version. I've pointed Kafka on Twitter (https://twitter.com/mark_dj/status/737334591795695616) to this topic in the hopes they can help us out...

> Uhm, it's a by design API breakage as far as I know I am not sure if I understand you 😄 What API will break? To make my point...

Great work @maciekciolek! > To be honest, I am thinking about writing it from the beginning using Actor with TCP support. I have scodec code for the ProduceRequest/ProduceResponse in case...

This can also be achieved more generally: ```scala implicit def coercibleShow[N, P](implicit ev: Coercible[N, P], R: Show[P]): Show[N] = R.contramap[N](ev.apply) implicit def coercibleEq[N, P](implicit ev: Coercible[N, P], R: Eq[P]): Eq[N]...

Weird, is it possible to set sbt with debugging on BSP ?

It seems to be supported by bazel-bsp though https://github.com/JetBrains/bazel-bsp/blob/master/server/src/main/java/org/jetbrains/bsp/bazel/server/bsp/BspServerApi.java#L158

Nice going! I like it that mill already supports this, but I guess also IDE devs would encouter this issue of not being able to resolve these depenencies? I wonder...