src/main/java/com/uber/rss/clients/MultiServerAsyncWriteClient.java [111:119]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        this.metrics = new WriteClientMetrics(new WriteClientMetricsKey(
            this.getClass().getSimpleName(), user));
        metrics.getNumClients().inc(1);

        if (partitionFanout > this.servers.size()) {
            throw new RssInvalidDataException(String.format(
                "Too many servers (%s) per partition, larger than max number of servers (%s)",
                partitionFanout,
                this.servers.size()));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/uber/rss/clients/MultiServerSyncWriteClient.java [81:89]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        this.metrics = new WriteClientMetrics(new WriteClientMetricsKey(
            this.getClass().getSimpleName(), user));
        metrics.getNumClients().inc(1);

        if (partitionFanout > this.servers.size()) {
            throw new RssInvalidDataException(String.format(
                "Too many servers (%s) per partition, larger than max number of servers (%s)",
                partitionFanout,
                this.servers.size()));
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -