MCPcopy
hub / github.com/segmentio/kafka-go / makeTopic

Function makeTopic

compress/compress_test.go:448–450  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

446}
447
448func makeTopic() string {
449 return fmt.Sprintf("kafka-go-%016x", rand.Int63())
450}
451
452func newLocalClientAndTopic() (*kafka.Client, string, func()) {
453 topic := makeTopic()

Callers 1

newLocalClientAndTopicFunction · 0.70

Calls

no outgoing calls

Tested by

no test coverage detected