func (c *Consumer) leaveGroup() error {
	broker, err := c.client.Coordinator(c.groupID)
	if err != nil {
		c.closeCoordinator(broker, err)
		return err
	}

	memberID, _ := c.membership()
	if _, err = broker.LeaveGroup(&sarama.LeaveGroupRequest{
		GroupId:  c.groupID,
		MemberId: memberID,
	}); err != nil {
		c.closeCoordinator(broker, err)
	}
	return err
}
func (c *Consumer) leaveGroup() error {
	broker, err := c.client.Coordinator(c.groupID)
	if err != nil {
		c.closeCoordinator(broker, err)
		return err
	}

	memberID, _ := c.membership()
	if _, err = broker.LeaveGroup(&sarama.LeaveGroupRequest{
		GroupId:  c.groupID,
		MemberId: memberID,
	}); err != nil {
		c.closeCoordinator(broker, err)
	}
	return err
}
func ( c * Consumer ) leaveGroup ( ) error { broker , err := c . client . Coordinator ( c . groupID ) if err != nil { c . closeCoordinator ( broker , err ) return err } memberID , _ := c . membership ( ) if _ , err = broker . LeaveGroup ( & sarama . LeaveGroupRequest { GroupId : c . groupID , MemberId : memberID , } ) ; err != nil { c . closeCoordinator ( broker , err ) } return err }
// Send a request to the broker to leave the group on failes rebalance() and on Close()
Send a request to the broker to leave the group on failes rebalance () and on Close ()