Open dtboctor opened 8 years ago
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?
Maybe this is already there? https://github.com/akka/reactive-kafka
Yeah, I was actually looking at this now.
Is there any plan to make this work with the .9 consumer? I know the architecture of that consumer is much different.