Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaDataReader ¶
type KafkaDataReader struct {
// contains filtered or unexported fields
}
func NewKafkaDataReader ¶
func NewKafkaDataReader(client *base.KafkaClient, config base.BaseConfig, writer base.DataWriter, checkpoint base.Checkpointer) *KafkaDataReader
NewKafaDataReader FIXME support more config options
func (*KafkaDataReader) IndexData ¶
func (reader *KafkaDataReader) IndexData() error
func (*KafkaDataReader) ReadData ¶
func (reader *KafkaDataReader) ReadData() ([]byte, error)
func (*KafkaDataReader) Start ¶
func (reader *KafkaDataReader) Start()
func (*KafkaDataReader) Stop ¶
func (reader *KafkaDataReader) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.