Attempt to ensure we have at least the requested number of bytes of memory for allocation by deallocating pooled buffers (if needed)

get boolean value with default value @param key @param defaultValue @return boolean value @throws Exception if value is not of type boolean or string

Return the value of the given pre-validated field, or if the value is missing return the default value. @param field The field for which to get the d

Helper function to initialize a job configuration

@param metricName @return standard JMX MBean name in the following format domainName:type=metricType,key1=val1,key2=val2

Get offset ranges

Handle any completed receives and update the response list with the responses received. @param responses The list of responses to update @param now Th

Handle any completed request send. In particular if no response is expected consider the request complete. @param responses The list of responses to u

Record any newly completed connections

Handle any disconnected connections @param responses The list of responses that completed with the disconnection @param now The current time

Handle a produce response

Check if the struct contains a field. @param name @return Whether a field exists.

Does the record have a key?

Check if we have room for a new record containing the given key/value pair Note that the return value is based on the estimate of the bytes written t

@return Whether there is any unsent record in the accumulator.

Get the list of sent records since the last call to {@link #clear()}

The subset of the replicas that are in sync, that is caught-up to the leader and ready to take over as leader if the leader should fail

Start closing the sender (won't actually complete until all data is sent out)

Return true if we are disconnected from the given node and can't re-establish a connection yet @param node The node to check @param now The current ti

Check if the node with the given id is ready to send more requests. @param node The given node id @param now The current time in ms @return true if th

Get the selection key associated with this numeric id

Get the last request we sent to the given node (but don't remove it from the queue) @param node The node id

The last time metadata was updated.

Get the current leader for the given topic-partition @param topicPartition The topic and partition we want to know the leader for @return The node tha

Choose the node with the fewest outstanding requests which is at least eligible for connection. This method will prefer a node with an existing connec

main(), shut up, pylint

Add a metadata request to the list of sends if we can make one

Create a metadata request for the given topics

This is called whenever a metric is updated or added @param metric

Return a map of metrics maintained by the consumer

Generates 32 bit murmur2 hash from byte array @param data byte array to hash @return 32 bit hash of the given array

Generate a request header for the given API key @param key The api key @return A request header with the appropriate client id and correlation id

The number of fields in this schema

The position of this record in the corresponding Kafka partition. @throws Exception The exception thrown while fetching this record.

The partition id

Compute the partition for the given record. @param record The record being sent @param cluster The current cluster metadata

Get the list of partitions whose leader is this node @param nodeId The node id @return A list of partitions