Function TestMain

otkafka/setup_test.go:12–17

(m *testing.M)

)

func TestMain(m *testing.M) {
	if os.Getenv("KAFKA_ADDR") != "" {
		setupTopic(os.Getenv("KAFKA_ADDR"))
	}
	os.Exit(m.Run())
}

func setupTopic(addr string) {
	topics := []string{"trace", "test", "example"}