func()

in internal/output/kafka/kafka.go [48:54]

• 6 lines of code
• 2 McCabe index (conditional complexity)

func (o *Output) DialContext(_ context.Context) error {
	if err := o.createTopic(); err != nil {
		return err
	}

	return nil
}