impl

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

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

type Options struct {
	Limit                       uint64
	MaxWaitingTimeForNewMessage *time.Duration
}

type ParquetMessage struct {
	Value         string `parquet:"name=value, type=BYTE_ARRAY, convertedtype=UTF8, encoding=PLAIN"`
	Topic         string `parquet:"name=topic, type=BYTE_ARRAY, convertedtype=UTF8, encoding=PLAIN"`
	Partition     int32  `parquet:"name=partition, type=INT32, convertedtype=INT_32"`
	Offset        string `parquet:"name=offset, type=BYTE_ARRAY, convertedtype=UTF8, encoding=PLAIN"`
	Key           string `parquet:"name=key, type=BYTE_ARRAY, convertedtype=UTF8, encoding=PLAIN"`
	Headers       string `parquet:"name=headers, type=BYTE_ARRAY, convertedtype=UTF8, encoding=PLAIN"`
	Timestamp     string `parquet:"name=timestamp, type=BYTE_ARRAY, convertedtype=UTF8, encoding=PLAIN"`
	TimestampType string `parquet:"name=timestamptype, type=BYTE_ARRAY, convertedtype=UTF8, encoding=PLAIN"`
}

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

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

type Reader interface {
	Read() chan kafka.Message
}

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

type StreamerOptions struct {
	MaxWaitingTimeForNewMessage *time.Duration
}

type Writer interface {
	Write(msg kafka.Message) error
	Flush() error
}