Drain all the data for the given nodes and collate them into a list of batches that will fit within the specified size on a per-node basis. This metho

Extracts the hostname from a "host:port" address string. @param address address string to parse @return hostname or null if the given address is incor

get integer value with default value @param name @param defaultValue @return integer value @throws Exception if value is not of type integer or strin

A ByteBuffer containing the message key

Measure this quantity and return the result as a double @param config The configuration for this metric @param now The POSIX time in milliseconds the

Add a metric to monitor an object that implements measurable. This metric won't be associated with any sensor. This is a way to expose existing values

Close this selector

Close this producer

The error code for the exception

The error thrown (generally on the server) while processing this request

Return true iff we have a connection to the give node @param node The id of the node to check

The node id of the node currently acting as a leader for this partition or -1 if there is no leader

Return a map of metrics maintained by the producer

@return The known set of nodes

The partition from which this record is received

Send the given record asynchronously and return a future which will eventually contain the response information. @param record The record to send @re

The next time to update the cluster info is the maximum of the time the current info will expire and the time the current info can be updated (i.e. ba

The topic this record is received from

Wake up the client if it is currently blocked waiting for I/O

the total free memory both unallocated and in the free list

Get the byte buffer that backs this records instance

Clear the stored history of sent records

Called when the metrics repository is closed.

The list of receives that completed on the last {@link #poll(long, List) poll()} call.

The list of sends that completed on the last {@link #poll(long, List) poll()} call.

The list of connections that completed their connection on the last {@link #poll(long, List) poll()} call.

Get the deque for the given topic-partition, creating it if necessary. Since new topics will only be added rarely we copy-on-write the hashmap

Begin disconnecting the connection identified by the given id

Complete the request @param baseOffset The base offset of the messages assigned by the server @param exception The exception that occurred (or null i

Create an empty cluster instance with no nodes and no topic-partitions.

An instance of the exception

Formats hostname and port number as a "host:port" address string, surrounding IPv6 addresses with braces '[', ']' @param host hostname @param port por

The host name for this node

Returns true if the crc stored with the record matches the crc computed off the record contents

The length of the key in bytes

The current time in nanoseconds

Generate a request header for the next request @param key The API key of the request

A callback method the user can implement to provide asynchronous handling of request completion. This method will be called when the record sent to th

The port for this node

Initiate a connection to the given node (if necessary), and return true if already connected. The readiness of a node will change only when poll is in

Get the request queue for the given node

The numeric id of the source from which we are receiving data.

Ensure the user doesn't try to access fields from the wrong schema

Write some as-yet unwritten bytes from this send to the provided channel. It may take multiple calls for the send to be completely written @param chan

Write an unsigned integer in little-endian format to the {@link OutputStream}. @param out The stream to write to @param value The value to write

Get the absolute value of the given number. If the number is Int.MinValue return 0. This is different from java.lang.Math.abs or scala.math.abs in tha

A numeric range that checks only the lower bound @param min The minimum acceptable value

Wait for metadata update until the current version is larger than the last version we know of

A numeric range that checks both the upper and lower bound