-
Notifications
You must be signed in to change notification settings - Fork 62
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
New Kafka .9 consumer #49
Comments
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:/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.
The text was updated successfully, but these errors were encountered: