helpers

Mar 3, 2020

Changes in this version

+ func MustCreateTopic(client *testlib.Client, clusterName string, clusterNamespace string, ...)

+ func MustPublishKafkaMessage(client *testlib.Client, bootstrapServer string, topic string, key string, ...)