kafka

Sep 14, 2019

Changes in this version

+ type Broker interface

+ Close func() error

+ CreateTopics func(request *sarama.CreateTopicsRequest) (*sarama.CreateTopicsResponse, error)

+ DeleteTopics func(request *sarama.DeleteTopicsRequest) (*sarama.DeleteTopicsResponse, error)

+ DescribeConfigs func(request *sarama.DescribeConfigsRequest) (*sarama.DescribeConfigsResponse, error)

+ GetMetadata func(request *sarama.MetadataRequest) (*sarama.MetadataResponse, error)

+ Open func(conf *sarama.Config) error

+ type FlowKafka interface

+ CreateTopic func(topic string, numPartitions int, replicationFactor int, retentionMs string) error

+ DeleteTopic func(topic string) error

+ DescribeTopic func(topic ...string) ([]*pkg.Topic, error)

+ GetMetadata func() (*pkg.Metadata, error)

+ Produce func(topic string, msg []byte) error

+ func NewFlowKafka(c *ServiceConfig) FlowKafka

+ type ServiceConfig struct

+ BootstrapBroker string