topics

package
v1.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 13, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Cmd = &cobra.Command{
	Use:   "topics",
	Short: "Describe topics",
	RunE: func(cmd *cobra.Command, args []string) error {
		if generate {
			err := printTopicsToMoveJSONFile(topics)
			if err != nil {
				return fmt.Errorf("problem generating topics-to-move json file: %w", err)
			}
			return nil
		}

		client := &kafka.Client{Addr: kafka.TCP(vars.BootstrapServer)}
		err := printDescribeTopics(client, topics)
		if err != nil {
			return fmt.Errorf("problem describing topics: %w", err)
		}

		return nil
	},
}

Functions

This section is empty.

Types

This section is empty.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL