Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( BrokerList = []string{"localhost:9092"} Topic = "jhd-test" GroupID = "test" )
Functions ¶
func ConsumeAtomicCommit ¶
func ConsumeAtomicCommit()
ConsumeAtomicCommit 同步消费(消费消息都是同步的) 自动位移提交(间隔为1s)
func ConsumeByGroup ¶
func ConsumeByGroup()
Types ¶
type GroupHandler ¶
type GroupHandler struct {
// contains filtered or unexported fields
}
func (GroupHandler) Cleanup ¶
func (GroupHandler) Cleanup(session sarama.ConsumerGroupSession) error
func (GroupHandler) ConsumeClaim ¶
func (GroupHandler) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error
func (GroupHandler) Setup ¶
func (GroupHandler) Setup(session sarama.ConsumerGroupSession) error
Click to show internal directories.
Click to hide internal directories.