kafkacopy

Documentation

Index

• func Main(args []string)
• func Run(ctx context.Context, config Config) error
• type Config

Functions

func Main

func Main(args []string)

Main handles the command line and runs the copy tool

func Run

func Run(ctx context.Context, config Config) error

Run copies data from one Kafka instance to another

Types

type Config

type Config struct {
	From, To api.Client
	Topics   []string
	Rename   string
}

Config describes the copy tool configuration