I've setup a Kafka cluster with SASL SCRAM security, and it's working fine.
Per the documentation, I have used the command kafka-configs.sh to create a username and password and grant that user access to a topic.
That also works great.
However, the kafka-configs.sh command doesn't require any kind of authentication itself, so it occurs to me that ANYONE could run that command and create their own user in Kafka and grant their own permissions.
Perhaps I need to enable SASL security on Zookeeper? But I can't find any consistent or working documentation on how to do that. Adding properties to zookeeper.config like requireclientauthscheme=sasl doesn't seem to do anything. Or at least it doesn't stop kafka-configs.sh from creating new users in zookeeper without any sort of authentication.
Am I even going down a viable path here? Or do I need to back up and do something different?
For reference, I'm using Kafka 1.0.0 and Zookeper 3.4.11. But I'm flexible on versions if some other version works better.
Any help appreciated! :)
Thanks!