api_versions_request.go 517 B

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