kafka

Documentation

Index

• Variables
• func NewClient(addresses []string) (sarama.Client, error)
• type Metadata

Variables

var Addresses = flag.String("kafkaaddrs", "localhost:9092", "kafka's comma-separated addresses")

Addresses is the flag for kafka's comma-separated addresses

var Topic = flag.String("kafkatopic", filepath.Base(os.Args[0]), "kafka's topic")

Topic is the flag for kafka's topic

Functions

func NewClient

func NewClient(addresses []string) (sarama.Client, error)

NewClient returns a Kafka client

Types

type Metadata

type Metadata struct {
	StartTime   time.Time
	NumMessages int
}

Metadata is used to store metadata for the sarama.ProducerMessages