-
Notifications
You must be signed in to change notification settings - Fork 46
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
kafka_users module implementation #134
kafka_users module implementation #134
Conversation
@ryarnyah @StephenSorriaux I am still working on it, but if you have any suggestion to handle properly updates of existing users let me know. |
Maybe trying open a simple KafkaClient will do the trick? |
10ea4e5
to
66a5df2
Compare
2963f60
to
71625b1
Compare
@ryarnyah Any update about the review? |
Sorry, I will review it next week, i don't have much time now Edit: if you are adding a molecule scenario you need to add it to our github actions to be running. We might prefer using only default scenario to parallelize tests efficiently and to not duplicate test helpers, what do you think @StephenSorriaux ? |
Yes, but I don't want editing github actions before the codereview
I see the current guideline, however I found easier writing test in this way: I don't need to write additional python code and using the real role in the converge playbook covers not only the module_utils but the library as well. Moreover is also an additional example. To avoid duplications, the infra tests and playbooks ( i.e. converge.yaml, verify.yaml ) might be moved in a common folder. see sharing across scenarios Notice however that kafka_user module currently works only with kafka >= 2.7.0. We might extends the support using the AlterConfigs kafka api, maybe after the implementation of #87 |
f3cbfae
to
a632fc9
Compare
We are also check Python compatibility with workers in python 2 to 3.10 with https://github.com/StephenSorriaux/ansible-kafka-admin/blob/master/molecule/default/molecule.yml#L13 That's why we are targetting "executors" in the tests (example https://github.com/StephenSorriaux/ansible-kafka-admin/blob/master/molecule/default/tests/test_acl_default.py#L19) |
Hi, @ryarnyah I actually did something testing workers in python 2 to 3.10. I changed the gitactions as you suggested, adding the scenario's name into the matrix. In the last checks' run you can see the scram-kafka-270 as well. |
Can you add some testinfra test to ensure that user password is usable to kafka client? |
8af8e80
to
0e10613
Compare
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.
LGTM
- AlterUserScramCredentialsRequest_v0 - AlterUserScramCredentialsResponse_v0 - DescribeUserScramCredentialsRequest_v0 - DescribeUserScramCredentialsResponse_v0
- add kafka_user - add kafka_users - add user resource to kafka_info
0e10613
to
5162104
Compare
@ryarnyah With the previous push flake8, that had no version specified in requirements.txt, was upgraded to 5.0.4 and several issues came up. I resolved the issues and fix the version to avoid this behaviour in the future. When do you plan the 0.17 release? |
* add new kafka api request/response - AlterUserScramCredentialsRequest_v0 - AlterUserScramCredentialsResponse_v0 - DescribeUserScramCredentialsRequest_v0 - DescribeUserScramCredentialsResponse_v0 * add kafka_scram module * add kafka_users modules - add kafka_user - add kafka_users - add user resource to kafka_info * add kafka_users examples * add kafka_users molecule's scenario * update readme.md * add molecule scenario in gihub maxtrix * kafka_user: handler kafka manager errors * kafka_user: inspect kafka advertised.listener in converge.yaml * kafka_user: review changes * kafka_user: use infratest to verify message write/read * fix flake8 version and resolve v5 issues
Fixes #109
Proposed Changes
Discussion point