type ConsumerSerializer = Serializer<OutgoingResponse, any>;