consumer

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

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

type ConsumedMessage struct {
	Partition int32
	Offset    int64
	Key       []byte
	Value     []byte
	Timestamp *time.Time
}

type DefaultMessageDeserializer struct {
}

type Flags struct {
	PrintKeys        bool
	PrintTimestamps  bool
	PrintAvroSchema  bool
	PrintHeaders     bool
	OutputFormat     string
	Separator        string
	Partitions       []int
	Offsets          []string
	FromBeginning    bool
	Tail             int
	Exit             bool
	EncodeValue      string
	EncodeKey        string
	ProtoFiles       []string
	ProtoImportPaths []string
	ProtosetFiles    []string
	KeyProtoType     string
	ValueProtoType   string
}

type MessageDeserializer interface {
	CanDeserialize(topic string) (bool, error)
	Deserialize(msg *sarama.ConsumerMessage, flags Flags) error
}

type MessageDeserializerChain []MessageDeserializer

type Operation struct {
}

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