(key, version int16)
| 123 | } |
| 124 | |
| 125 | func allocateBody(key, version int16) protocolBody { |
| 126 | switch key { |
| 127 | case apiKeyProduce: |
| 128 | return &ProduceRequest{Version: version} |
| 129 | case apiKeyFetch: |
| 130 | return &FetchRequest{Version: version} |
| 131 | case apiKeyListOffsets: |
| 132 | return &OffsetRequest{Version: version} |
| 133 | case apiKeyMetadata: |
| 134 | return &MetadataRequest{Version: version} |
| 135 | // 4: LeaderAndIsrRequest |
| 136 | // 5: StopReplicaRequest |
| 137 | // 6: UpdateMetadataRequest |
| 138 | // 7: ControlledShutdownRequest |
| 139 | case apiKeyOffsetCommit: |
| 140 | return &OffsetCommitRequest{Version: version} |
| 141 | case apiKeyOffsetFetch: |
| 142 | return &OffsetFetchRequest{Version: version} |
| 143 | case apiKeyFindCoordinator: |
| 144 | return &FindCoordinatorRequest{Version: version} |
| 145 | case apiKeyJoinGroup: |
| 146 | return &JoinGroupRequest{Version: version} |
| 147 | case apiKeyHeartbeat: |
| 148 | return &HeartbeatRequest{Version: version} |
| 149 | case apiKeyLeaveGroup: |
| 150 | return &LeaveGroupRequest{Version: version} |
| 151 | case apiKeySyncGroup: |
| 152 | return &SyncGroupRequest{Version: version} |
| 153 | case apiKeyDescribeGroups: |
| 154 | return &DescribeGroupsRequest{Version: version} |
| 155 | case apiKeyListGroups: |
| 156 | return &ListGroupsRequest{Version: version} |
| 157 | case apiKeySaslHandshake: |
| 158 | return &SaslHandshakeRequest{Version: version} |
| 159 | case apiKeyApiVersions: |
| 160 | return &ApiVersionsRequest{Version: version} |
| 161 | case apiKeyCreateTopics: |
| 162 | return &CreateTopicsRequest{Version: version} |
| 163 | case apiKeyDeleteTopics: |
| 164 | return &DeleteTopicsRequest{Version: version} |
| 165 | case apiKeyDeleteRecords: |
| 166 | return &DeleteRecordsRequest{Version: version} |
| 167 | case apiKeyInitProducerId: |
| 168 | return &InitProducerIDRequest{Version: version} |
| 169 | // 23: OffsetForLeaderEpochRequest |
| 170 | case apiKeyAddPartitionsToTxn: |
| 171 | return &AddPartitionsToTxnRequest{Version: version} |
| 172 | case apiKeyAddOffsetsToTxn: |
| 173 | return &AddOffsetsToTxnRequest{Version: version} |
| 174 | case apiKeyEndTxn: |
| 175 | return &EndTxnRequest{Version: version} |
| 176 | // 27: WriteTxnMarkersRequest |
| 177 | case apiKeyTxnOffsetCommit: |
| 178 | return &TxnOffsetCommitRequest{Version: version} |
| 179 | case apiKeyDescribeAcls: |
| 180 | return &DescribeAclsRequest{Version: int(version)} |
| 181 | case apiKeyCreateAcls: |
| 182 | return &CreateAclsRequest{Version: version} |
no outgoing calls