-
Notifications
You must be signed in to change notification settings - Fork 21
feat: Implement Fs2KafkaModule #246
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
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What I don't like about it is a fact that it won't allow you configure parts of the kafka client that are not expected by this code. Imagine a new kafka client is released and it adds a new config option. SST needs to be updated before you'll actually be able to configure that. I think there should be some sort of escape hatch ie using Map[String,String]
. Or did I miss something?
It allows you to "escape" using |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It might be a good idea to include link to upstream documentation of configuration options.
Also, it should be reviewed by someone who plans to use this soon, which I'm not.
I'm planning to use it ;) Thanks, I will add a link to the docs. |
This PR implements subproject for FS2 Kafka.
Closes #67