Create A New Kafka AdminClient Of Specified Type - Using Credentials From Kafka Secret(s) In Specified K8S Namespace The K8S Namespace parameter indicates the Kubernetes Namespace in which the Kafka Credentials secret(s) will be found.

Create A New Azure EventHub AdminClient Based On Kafka Secrets In The Specified K8S Namespace.

Create A New Kafka (Confluent, etc...) AdminClient Based On The Kafka Secret In The Specified K8S Namespace.

EventHub NewCache Wrapper To Facilitate Unit Testing.

New EventHub AdminClient Wrapper To Facilitate Unit Testing.

New Kafka AdminClient Wrapper To Facilitate Unit Testing.

EventHub AdminClient Definition.

Kafka AdminClient Definition.

Confluent Client Doesn't Code To Interfaces Or Provide Mocks So We're Wrapping Our Usage Of The AdminClient For Testing Also Introduced Additional Functionality To Get The Kafka Secret For A Topic.

Confluent AdminClient Interface - Adding Our Own Wrapping Interface To Facilitate Testing.

AdminClient Type Enumeration.