The complete serialized size of this record in bytes (including crc, header attributes, etc)

Register a compound statistic with this sensor with no config override

Get a field by its slot in the record array @param slot The slot at which this field sits @return The field

Append the given record and offset to the buffer

The current time in milliseconds

Set the given field to the specified value @param field The field @param value The value

Close the client and disconnect from all nodes

Allocate a buffer of the given size. This method blocks if there is not enough memory and the buffer pool is configured with blocking mode. @param si

Sleep for the given number of milliseconds

The node id of this node

Get the value for the field directly by the field index with no lookup needed (faster!) @param field The field to look up @return The value for that

Record the given value @param config The configuration to use for this metric @param value The value to record @param timeMs The POSIX time in millise

Read the given byte buffer into a byte array

Create a struct for the schema of a container type (struct or array). Note that for array type, this method assumes that the type is an array of schem

Returns the fetch position of the <i>next message</i> for the specified topic partition to be used on the next {@link #poll(long) poll()} @param parti

Get or create a sensor with the given unique name and no parent sensors. @param name The sensor name @return The sensor

Add the topic to maintain in the metadata

Initiate the sending of the given requests and return any completed responses. Requests can only be sent on ready connections. @param requests The req

Put the given Properties into the Props. @param properties The properties to put

group data by topic @param data Data to be partitioned @param <T> Partition data type @return partitioned data

Record an occurrence, this is just short-hand for {@link #record(double) record(1.0)}

Return the capacity of the buffer

Check that the parameter t is not null @param t The object to check @return t if it isn't null @throws NullPointerException if t is null.

The number of bytes remaining to send

The value of the metric

Define a new configuration @param name The name of the config parameter @param type The type of the config @param defaultValue The default value to us

The numeric id for the destination of this send

Get the sensor with the given name if it exists @param name The name of the sensor @return Return the sensor or null if no such sensor exists

Get the metadata for the specified partition @param topicPartition The topic and partition to fetch info for @return The metadata about the given topi

Get the current cluster info without blocking

Add a record to the accumulator, return the append result <p> The append result will contain the future metadata, and flag for whether the appended ba

The number of currently in-flight requests for which we have not yet returned a response

Get the list of partitions for this topic @param topic The topic name @return A list of partitions

Request an update of the current cluster metadata info, return the current version before the update

Await the completion of this request

Retrieve the previously computed CRC for this record

Begin establishing a socket connection to the given address identified by the given address @param id The id for this connection @param address The ad

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

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

Instantiate the class

Parse and validate configs against this configuration definition. The input is a map of configs. It is expected that the keys of the map are strings,

Get a list of nodes whose partitions are ready to be sent, and the earliest time at which any non-sendable partition will be ready; Also return the fl

The topic name

The topic this record is being sent to

Add the given request to the queue for the node it was directed to

Compute the checksum of the record from the record contents

Return buffers to the pool. If they are of the poolable size add them to the free list, otherwise just mark the memory as free. @param buffer The buf