Return true iff we can currently initiate a new connection to the given node. This will be the case if we are not connected and haven't been connected

Can we send more requests to this node? @param node Node in question @return true iff we have no requests still being sent to the given node

Get the socket channel associated with this selection key

Choose an available port

Close this consumer

Complete or retry the given batch of records. @param batch The record batch @param error The error (or null if none) @param baseOffset The base offset

Is this send complete?

The compression type used with this record

Configure this class. @param configs configs in key/value pairs @param isKey whether is for key or value

Returns the number of milliseconds to wait, based on the connection state, before attempting to send data. When disconnected, this respects the reconn

Deallocate the record batch

Complete the earliest uncompleted call with the given error. @return true if there was an uncompleted call to complete

Throw the exception if there is one

Get a configured instance of the give class specified by the given configuration key. If the object implements Configurable configure it using the con

get all property names @return set of property names

This is called when the reporter is first registered to initially register all existing metrics @param metrics All currently existing metrics

Initiate a connection to the given node

Are we connected and ready and able to send more requests to the given node? @param node The node

The key (or null if no key is specified)

Log warnings for any unused configurations

The magic version of this record

A name for this metric

The name this sensor is registered with. This name will be unique among all registered sensors.

Get the next offset for this topic/partition

Get the state of our connection to the given state @param node The id of the node @return The state of our connection

Parse a value according to its expected type. @param name The config name @param value The config value @param type The expected type @return The pars

The partition to which the record will be sent (or null if no partition was specified)

The number of threads blocked waiting on memory

Decompresses (if necessary) buffered data, optionally computes and validates a XXHash32 checksum, and writes the result to a buffer. @throws IOExcept

Read an unsigned integer stored in little-endian format from the {@link InputStream}. @param in The stream to read from @return The integer read (MUS

Adds the record to the list of sent records. The {@link RecordMetadata} returned will be immediately satisfied. @see #history()

@param topic topic associated with data @param data typed data @return serialized bytes

The size of these records in bytes

Get the serialized size of this object

Read a size-delimited byte buffer starting at the given offset

The total memory managed by this pool

Get the transmissions for the given connection

Update the cluster metadata

Update the CRC32 given an integer

Turn the given UTF8 byte array into a string @param bytes The byte array @return The string

A ByteBuffer containing the value of this record

The position where the value size is stored

Wait for cluster metadata including partitions for the given topic to be available. @param topic The topic we want metadata for @param maxWaitMs The m