prototube

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

type Producer interface {
	Stop() error
	Emit(msg proto.Message) error
	EmitWithStringKey(key string, msg proto.Message) error
	EmitWithBytesKey(key []byte, msg proto.Message) error
	EmitWithPartition(partition int32, msg proto.Message) error
}

type ProducerConfig struct {
	Topic  string
	IsSync bool
	Config *sarama.Config
}

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