kafkav1

Documentation

Index

• Constants
• type KafkaBrokerV1
  • func (k *KafkaBrokerV1) Connect() error
  • func (k *KafkaBrokerV1) Disconnect() error
  • func (k *KafkaBrokerV1) Marshal() string
  • func (k *KafkaBrokerV1) Publish(topic string, msg *broker.Message, opt ...broker.PublishOption) error
  • func (k *KafkaBrokerV1) String() string
  • func (k *KafkaBrokerV1) Subscribe(topics []string, callBack broker.CallBack, opt ...broker.SubscribeOption) (broker.Subscriber, error)
• type Sarama
• type TLS

Constants

const (
	ConsumerOffsetNewest int64 = -1
	ConsumerOffsetOldest int64 = -2
)

Types

type KafkaBrokerV1

type KafkaBrokerV1 struct {
	sync.Once
	sync2.OnceError
	Logger    log.Logger
	URIs      []string
	TLS       *TLS
	Insecure  bool
	SubSarama *Sarama
	// contains filtered or unexported fields
}

KafkaBrokerV1

func (*KafkaBrokerV1) Connect

func (k *KafkaBrokerV1) Connect() error

func (*KafkaBrokerV1) Disconnect

func (k *KafkaBrokerV1) Disconnect() error

func (*KafkaBrokerV1) Marshal

func (k *KafkaBrokerV1) Marshal() string

func (*KafkaBrokerV1) Publish

func (k *KafkaBrokerV1) Publish(topic string, msg *broker.Message, opt ...broker.PublishOption) error

func (*KafkaBrokerV1) String

func (k *KafkaBrokerV1) String() string

func (*KafkaBrokerV1) Subscribe

func (k *KafkaBrokerV1) Subscribe(topics []string, callBack broker.CallBack, opt ...broker.SubscribeOption) (broker.Subscriber, error)

type Sarama

type Sarama struct {
	ConsumerOffsetsInitial int64
}

type TLS

type TLS struct {
	Insecure   bool
	CertFile   string // 公钥,需要转化为pem
	KeyFile    string // 私钥
	CaCertFile string // ca证书
}