producer

type MetaMessageType byte

type ProduceResponse struct {
	Partition int32 `json:"partition"`
	Offset    int64 `json:"offset"`
}

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

type ReplicatedMessage struct {
	BatchId       string
	MetaMessage   *ReplicationMetaMessage
	SrcDatacenter string
	DstDatacenter string // Used by airbus
	MsgID         string

	Topic           string
	Key             []byte // Q: Why using []byte instead of string ?
	Value           []byte // A: string when marshaled is required to be UTF-8, but []byte supports binary
	Partition       int32
	PartitionMethod string
}

type ReplicationMetaMessage struct {
	CheckSum string // md5, checksum of all messages between meta START message and STOP message
	Total    int    // batch size
	Type     MetaMessageType
}

type Replicator interface {
	Setup(producer *Producer)
	Close()
	Replicate(msg *ReplicatedMessage) error
	Allow(topic string) bool
}