kafka

type Broker interface {
	CreateTopics(request *sarama.CreateTopicsRequest) (*sarama.CreateTopicsResponse, error)
	DeleteTopics(request *sarama.DeleteTopicsRequest) (*sarama.DeleteTopicsResponse, error)
	DescribeConfigs(request *sarama.DescribeConfigsRequest) (*sarama.DescribeConfigsResponse, error)
	GetMetadata(request *sarama.MetadataRequest) (*sarama.MetadataResponse, error)
	Open(conf *sarama.Config) error
	Close() error
}

type FlowKafka interface {
	CreateTopic(topic string, numPartitions int, replicationFactor int, retentionMs string) error
	DeleteTopic(topic string) error
	DescribeTopic(topic ...string) ([]*pkg.Topic, error)
	GetMetadata() (*pkg.Metadata, error)
	Produce(topic string, msg []byte) error
}

type ServiceConfig struct {
	BootstrapBroker string
	// contains filtered or unexported fields
}