sparrow/pkg/queue/queue_producer.go

package queue

import "sparrow/pkg/protocol"

type QueueProducer interface {
	Init() error
	GetDefaultTopic() string
	Send(info *TopicPartitionInfo, msg protocol.Payload, callback Callback) error
	Stop() error
}