Compresses buffered data, optionally computes an XXHash32 checksum, and writes the result to the underlying {@link OutputStream}. @throws IOException

Write these records to the given channel @param channel The channel to write to @return The number of bytes written @throws IOException If the write f

Write this struct to a buffer

Add a MetricReporter

The attributes stored with this record

The base offset for the request (the first offset in the record set)

Create a "bootstrap" cluster using the given list of host/ports @param addresses The addresses @return A cluster for these hosts/ports

We can retry a send if the error is transient and the number of attempts taken is fewer than the maximum allowed

Check if we have violated our quota for any metric that has a configured quota @param timeMs

Choose a number of random available ports

Clear the results from the prior poll

Clear out all the in-flight requests for the given node and return them @param node The node @return All the in-flight requests for that node that ha

Close this batch for no more appends

Close this selector and all associated connections

Close this producer. This method blocks until all in-flight requests complete.

Are we done receiving data?

Complete the last request that was sent to a particular node. @param node The node the request was sent to @return The request

Get the oldest request (the one that that will be completed next) for the given node

Complete the earliest uncompleted call successfully. @return true if there was an uncompleted call to complete

Configure this class with the given key-value pairs

Enter the connecting state for the given node. @param node The id of the node we are connecting to @param now The current time.

Validate that the response corresponds to the request we expect or else explode

Create a job configuration

Create a list of MessageStreams of type T for each topic. @param topicCountMap a map of (topic, #streams) pair @param keyDecoder a decoder that de

Transfer the record batches into a list of produce requests on a per-node basis

@param topic topic associated with the data @param data serialized bytes @return deserialized object

Mark this request as complete and unblock any threads waiting on its completion. @param topicPartition The topic and partition to which this record se

A simple state check to ensure the stream is still open.

Throw an InvalidRecordException if isValid is false for this record

Validate that the record size isn't too large

Get all the fields in this schema