New Kafka .9 consumer

[dtboctor]

Is there any plan to make this work with the .9 consumer? I know the architecture of that consumer is much different.

[sclasen]

So, since this library was written before both kafka 0.9 and akka-streams 1.0 it looks the way it does.

If I were going to re-write an akka-kafka client these days, I would certianly want to use 0.9 and also akka-streams which has a much more advanced backpressure mechanism, as well as more type safety.

Im not sure there is a way to make akka-kafka support .9 without breaking .8 support? Do you know if both versions are 'classpath compatible' or would we need seperate modules for 0.8 and 0.9?

[sclasen]

Maybe this is already there? https://github.com/akka/reactive-kafka

[dtboctor]

Yeah, I was actually looking at this now.