Monitoring

APIs for monitoring WarpStream and Consumers.