Method headerVersion

request.go:15–15 · view source on GitHub ↗

()

Source from the content-addressed store, hash-verified

13	version() int16
14	setVersion(int16)
15	headerVersion() int16
16	isValidVersion() bool
17	requiredVersion() KafkaVersion
18	}

responseReceiverMethod · 0.65

handleRequestsMethod · 0.65

encodeMethod · 0.65

decodeMethod · 0.65

testRequestEncodeFunction · 0.65

AlterConfigsRequestalter_configs_request.go

ConsumerMetadataResponseconsumer_metadata_response.go

InitProducerIDResponseinit_producer_id_response.go

DeleteAclsResponseacl_delete_response.go

OffsetCommitRequestoffset_commit_request.go

DeleteAclsRequestacl_delete_request.go

LeaveGroupRequestleave_group_request.go

DescribeLogDirsRequestdescribe_log_dirs_request.go

OffsetFetchResponseoffset_fetch_response.go

FindCoordinatorResponsefind_coordinator_response.go

UpdateFeaturesResponseupdate_features_response.go

ApiVersionsResponseapi_versions_response.go

no outgoing calls

testRequestEncodeFunction · 0.52