RecordSerde
with ApiMessageAndVersion
but implementors need to implement
AbstractApiMessageSerde.apiMessageFor(short)
to return a ApiMessage
instance for the given apiKey
.brokerId
ApiMessage
instance for the given apiKey
.ApiMessage
instance for the given apiKey
.ApiMessageAndVersion
to bytes and vice versa..T
into a string and vice versa.Metrics.defaultRegistry()
AlterReplicaExclusionOp
operations match the currently-active replica exclusions (e.g as in the case of duplicate requests)Readable
input.Runnable
to run when handling a fault.