list_groups_request.go 484 B

12345678910111213141516171819202122232425262728
  1. package sarama
  2. type ListGroupsRequest struct {
  3. }
  4. func (r *ListGroupsRequest) encode(pe packetEncoder) error {
  5. return nil
  6. }
  7. func (r *ListGroupsRequest) decode(pd packetDecoder, version int16) (err error) {
  8. return nil
  9. }
  10. func (r *ListGroupsRequest) key() int16 {
  11. return 16
  12. }
  13. func (r *ListGroupsRequest) version() int16 {
  14. return 0
  15. }
  16. func (r *ListGroupsRequest) headerVersion() int16 {
  17. return 1
  18. }
  19. func (r *ListGroupsRequest) requiredVersion() KafkaVersion {
  20. return V0_9_0_0
  21. }