A convenient base class for configurations to extend. <p> This class holds both the original configuration that was provided as well as the parsed

A base class that simplifies implementing an iterator @param <T> The type of thing we are iterating over

Any API exception that is part of the public protocol and should be a subclass of this class and be part of this package.

Identifiers for all the Kafka APIs

Represents a type for an array of a particular type

A {@link SampledStat} that maintains a simple average over its samples.

This exception is thrown if the producer is in non-blocking mode and the rate of data production exceeds the rate at which data can be sent for long e

A pool of ByteBuffers kept under a given memory limit. This class is fairly specific to the needs of the producer. In particular it has the following

A byte buffer backed input outputStream

A byte buffer backed output outputStream

A receive backed by an array of ByteBuffers

A send backed by an array of byte buffers

A callback interface that the user can implement to allow code to execute when the request is complete. This callback will generally execute in the ba

This class delegates (child then parent) for the findClass method for a URLClassLoader. We need this because findClass is protected in URLClassLoader

A request being sent to the server. This holds both the network send as well as the client-level metadata.

A response from the server. Contains both the body of the response as well as the correlated request that was originally sent.

A representation of a subset of the nodes, topics, and partitions in the Kafka cluster.

The state of our connection to each node in the cluster.

A compound stat is a stat where a single measurement and associated data structure feeds many metrics. This is the example for a histogram which has m

The compression type to use

This class is used for specifying the set of expected configurations, their type, their defaults, their documentation, and any special validation logi

Thrown if the user supplies an invalid configuration

A Mix-in style interface for classes that are instantiated by reflection and need to take configuration parameters

The states of a node connection

@see KafkaConsumer @see MockConsumer

The consumer configuration keys

TODO: Clean this after the consumer implementation is complete. Until then, it is useful to write some sample test code using the new APIs

A callback interface that the user can implement to manage customized offsets on the start and end of every rebalance operation. This callback will ex

A key/value pair to be received from Kafka. This consists of a topic name and a partition number, from which the record is being received and an offse

A container that holds the list {@link ConsumerRecord} per partition for a particular topic. There is one for every topic returned by a {@link Consume

A simple read-optimized map implementation that synchronizes only writes and does a full copy on each modification

This exception indicates a record has failed it's internal CRC check, this generally indicates network or disk corruption.

A {@link SampledStat} that maintains a simple count of what it has seen.

This class was taken from Hadoop org.apache.hadoop.util.PureJavaCrc32 A pure-java implementation of the CRC32 checksum that uses the same polynomial

This class was taken from Hadoop org.apache.hadoop.util.PureJavaCrc32 A pure-java implementation of the CRC32 checksum that uses the same polynomial

Use this class to produce test events to Kafka server. Each event contains a random timestamp in text format.

@param <T> Type to be deserialized into. A class that implements this interface is expected to have a constructor with no parameter.

A simple server that takes size delimited byte arrays and just echos them back to the sender.

This class contains all the client-server errors--those errors that must be sent from the server to the client. These are thus part of the protocol. T

A field in a schema

This class allows me to call findClass on a class loader

The future result of a record send

The set of requests which have been sent or are being sent but haven't yet received a response

An exception that may indicate the client's metadata is out of date

The client has attempted to perform an operation on an invalid topic.

Register metrics in JMX as dynamic mbeans based on the metric names

The interface for {@link NetworkClient}

A Kafka client that consumes records from a Kafka cluster. <P> The consumer is <i>thread safe</i> and should generally be shared among all threads for