Documentation
¶
Overview ¶
*
- @api post kafka. *
- User: yunshengzhu
- Date: 2022/3/16
- Time: 下午10:09
*
- @api post kafka. *
- User: yunshengzhu
- Date: 2021/8/6
- Time: 上午10:22
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ToJsonStringIndent ¶ added in v0.0.44
func ToJsonStringIndent(i interface{}) string
Types ¶
type ConsumeGroup ¶ added in v0.0.44
type ConsumeGroup struct {
// contains filtered or unexported fields
}
func NewConsumeGroup ¶ added in v0.0.44
func NewConsumeGroup(kafkaAddress []string) (*ConsumeGroup, error)
func (*ConsumeGroup) Close ¶ added in v0.0.44
func (c *ConsumeGroup) Close() error
func (*ConsumeGroup) Consume ¶ added in v0.0.44
func (c *ConsumeGroup) Consume(groupId string, topics []string, fn func(msg *sarama.ConsumerMessage) error) error
type KafkaPusher ¶ added in v0.0.44
type KafkaPusher struct {
// contains filtered or unexported fields
}
func NewKafkaPusher ¶ added in v0.0.44
func NewKafkaPusher(address []string) (*KafkaPusher, error)
func (*KafkaPusher) GetPullLog ¶ added in v0.0.53
func (s *KafkaPusher) GetPullLog() bool
func (*KafkaPusher) GetPushLog ¶ added in v0.0.53
func (s *KafkaPusher) GetPushLog() bool
func (*KafkaPusher) KafkaSend ¶ added in v0.0.44
func (s *KafkaPusher) KafkaSend(topic string, message interface{}) error
func (*KafkaPusher) SetPullLog ¶ added in v0.0.53
func (s *KafkaPusher) SetPullLog(status bool)
func (*KafkaPusher) SetPushLog ¶ added in v0.0.53
func (s *KafkaPusher) SetPushLog(status bool)
func (*KafkaPusher) Stop ¶ added in v0.0.44
func (s *KafkaPusher) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.