KafkaAsyncExecutor : Be able to support different Kafka providers #5
Description
Currently, the only Kafka method in KafkaAsyncExecutor for creating Topics is by using AdminClient
While it's probably going to cover 100% of Kafka provider, the same cannot be said regarding ACL or user creation:
- ACL could be managed multiple ways
- using AdminClient (probably most use cases)
- using Confluent RBAC (because why not)
- SCRAM Users can be created :
- With ZK as of now
- With Admin Client for on prem instances starting Kafka 2.7.0
- With API calls on Confluent API for Confluent Cloud
- With <other_method> call on <other_provider>
All of this points to adding a new layer of abstraction in order to be able to manage different resource creation/updation methods depending on provider/on-prem
Discussion is required in order to find the best way to rewrite this.