lib_gc_kafka_client

type KafkaClientFactory_I interface {
	GetNewClient() (KafkaClient_I, error)
}

type KafkaClient_I interface {
	Close() error
	IsClosed() bool
	StartAsyncProducer(topic string) (chan<- []byte, <-chan *error, error)
	StartSyncProducer(topic string) (chan<- []byte, <-chan *error, error)
	StartConsumer(message_processor MessageProcessor, topic string, partition int32, offset int64) (<-chan *error, error)
	GetPartitionsFromATopic(string) ([]int32, error)
	GetOldestOffset(topic string, partiionID int32) (int64, error)
	GetNewestOffset(topic string, partiionID int32) (int64, error)
	GetOffsetByPartition(topic string) (map[int32]int64, map[int32]int64, error)
}

type MessageProcessor interface {
	ProcessMessage(message []byte, partition int32, offset int64) error
}