consume

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

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

type Consumer interface {
	Start(ctx context.Context, flags Flags, messages chan<- *sarama.ConsumerMessage, stopConsumers <-chan bool) error
	Wait() error
	Close() error
}

type DefaultMessageDeserializer struct {
}

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

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

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

type MessageDeserializerChain []MessageDeserializer

type Operation struct {
}

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

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