api_versions_request.go 426 B

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