Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CreateAdminClient ¶
func CreateAdminClient(ctx context.Context, brokers []string, config *sarama.Config, adminClientType types.AdminClientType) (types.AdminClientInterface, error)
Create A New Kafka AdminClient Of Specified Type - Based On Specified Sarama Config
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.