kafka

type Consumer struct {
	// contains filtered or unexported fields
}

type ConsumerConfig struct {
	Brokers      []string
	Group        string
	Topic        string
	ProtoPath    string
	MessageType  string
	OutputFormat string
	Offset       string
	Count        int
	Follow       bool
	KeyFilter    string
	Verbose      bool
}

type Producer struct {
	// contains filtered or unexported fields
}

type ProducerConfig struct {
	Brokers     []string
	Topic       string
	ProtoPath   string
	MessageType string
	Key         string
	Partition   int32
	Verbose     bool
}