topics

Documentation

Overview

Package topics is an experimental package that provides additional tooling around Kafka Topics. This package does not make any promises around backwards compatibility.

Index

• func List(ctx context.Context, client *kafka.Client) (topics []kafka.Topic, err error)
• func ListRe(ctx context.Context, cli *kafka.Client, re *regexp.Regexp) (topics []kafka.Topic, err error)

Functions

func List

func List(ctx context.Context, client *kafka.Client) (topics []kafka.Topic, err error)

List returns a slice of all the Topics.

func ListRe

func ListRe(ctx context.Context, cli *kafka.Client, re *regexp.Regexp) (topics []kafka.Topic, err error)

ListRe returns a slice of Topics that match a regex.