// The number of compression rounds.
  private final int c;
  // The number of finalization rounds.
  private final int d;
  // Two 64-bit keys (represent a single 128-bit key).
  private final long k0;
  private final long k1;

  /**
   * @param c the number of compression rounds (must be positive)
   * @param d the number of finalization rounds (must be positive)

        return this;
    }

    /**
     * Gets the number of fragments.
     *
     * @return the maximum number of highlighted fragments
     */
    public int getNumOfFragments() {
        return numOfFragments;
    }

    /**
     * Sets the number of fragments with fluent interface.
     *
     * @param numOfFragments the maximum number of highlighted fragments

			Description: "specify compression level of the Kafka cluster",
			Optional:    true,
			Type:        "number",
		},
		config.HelpKV{
			Key:         target.KafkaBatchSize,
			Description: "batch size of the events; used only when queue_dir is set",
			Optional:    true,
			Type:        "number",
		},
		config.HelpKV{
			Key:         target.KafkaBatchCommitTimeout,

    public void setServer(final String server) {
        this.server = server;
    }

    /**
     * Returns the port number.
     * @return The port number.
     */
    public int getPort() {
        return port;
    }

    /**
     * Sets the port number.
     * @param port The port number.
     */
    public void setPort(final int port) {
        this.port = port;
    }

    /**

                                    </Expiration>`,
			expectedErr: nil,
		},
		{ // Expiration with a valid number of days
			inputXML: `<Expiration>
                                    <Days>3</Days>
                                    </Expiration>`,
			expectedErr: nil,
		},
		{ // Expiration with neither number of days nor a date
			inputXML: `<Expiration>
                                    </Expiration>`,

    private int pad;
    private int pad1;
    private boolean parametersDone, dataDone;

    /** Total number of parameter bytes the server is returning */
    protected int totalParameterCount;
    /** Total number of data bytes the server is returning */
    protected int totalDataCount;
    /** Number of parameter bytes in this response */
    protected int parameterCount;

        return returnCode == 0;
    }

    /**
     * Gets the sequence number.
     *
     * @return the sequence number
     */
    public long getSequenceNumber() {
        return sequenceNumber;
    }

    /**
     * Sets the sequence number.
     *
     * @param sequenceNumber the sequence number
     */
    public void setSequenceNumber(long sequenceNumber) {

        return activeThreadCountLock;
    }

    /**
     * Returns the number of threads.
     * @return The number of threads.
     */
    public int getNumOfThread() {
        return numOfThread;
    }

    /**
     * Sets the number of threads.
     * @param numOfThread The number of threads.
     */
    public void setNumOfThread(final int numOfThread) {

        if (o == null) {
            return null;
        } else if (o instanceof Float) {
            return (Float) o;
        } else if (o instanceof Number) {
            return Float.valueOf(((Number) o).floatValue());
        } else if (o instanceof String) {
            return toFloat((String) o);
        } else if (o instanceof java.util.Date) {
            if (pattern != null) {

     */
    @Override
    public void close() throws IOException {
        // inputStream.close();
    }

    /**
     * Returns the number of bytes that can be read from this input stream without blocking.
     *
     * @return the number of bytes available
     * @throws IOException if an I/O error occurs
     */
    @Override
    public int available() throws IOException {