Codebase list golang-github-segmentio-kafka-go / run/9624c5c3-d0d2-4106-80be-893db7280eed/main export_test.go
run/9624c5c3-d0d2-4106-80be-893db7280eed/main

Tree @run/9624c5c3-d0d2-4106-80be-893db7280eed/main (Download .tar.gz)

export_test.go @run/9624c5c3-d0d2-4106-80be-893db7280eed/mainraw · history · blame

1
2
3
4
5
6
7
8
9
package kafka

import "testing"

func CreateTopic(t *testing.T, partitions int) string {
	topic := makeTopic()
	createTopic(t, topic, partitions)
	return topic
}