A B C D E F H I K L M N O P R S T U V

A

ApiException - Exception in kafka.common.errors
Any API exception that is part of the public protocol and should be a subclass of this class and be part of this package.
ApiException(String, Throwable) - Constructor for exception kafka.common.errors.ApiException
 
ApiException(String) - Constructor for exception kafka.common.errors.ApiException
 
ApiException(Throwable) - Constructor for exception kafka.common.errors.ApiException
 
ApiException() - Constructor for exception kafka.common.errors.ApiException
 

B

BLOCK_ON_BUFFER_FULL - Static variable in class kafka.clients.producer.ProducerConfig
When our memory buffer is exhausted we must either stop accepting new records (block) or throw errors.
bootstrap(List<InetSocketAddress>) - Static method in class kafka.common.Cluster
Create a "bootstrap" cluster using the given list of host/ports
BROKER_LIST_CONFIG - Static variable in class kafka.clients.producer.ProducerConfig
A list of URLs to use for establishing the initial connection to the cluster.
BufferExhaustedException - Exception in kafka.clients.producer
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 enough for the alloted buffer to be exhausted.
BufferExhaustedException(String) - Constructor for exception kafka.clients.producer.BufferExhaustedException
 

C

Callback - Interface in kafka.clients.producer
A callback interface that the user can implement to allow code to execute when the request is complete.
clear() - Method in class kafka.clients.producer.MockProducer
Clear the stored history of sent records
CLIENT_ID_CONFIG - Static variable in class kafka.clients.producer.ProducerConfig
The id string to pass to the server when making requests.
close() - Method in class kafka.clients.producer.KafkaProducer
Close this producer.
close() - Method in class kafka.clients.producer.MockProducer
 
close() - Method in interface kafka.clients.producer.Producer
Close this producer
Cluster - Class in kafka.common
A representation of a subset of the nodes, topics, and partitions in the Kafka cluster.
Cluster(Collection<Node>, Collection<PartitionInfo>) - Constructor for class kafka.common.Cluster
Create a new cluster with the given nodes and partitions
completeNext() - Method in class kafka.clients.producer.MockProducer
Complete the earliest uncompleted call successfully.
Configurable - Interface in kafka.common
A Mix-in style interface for classes that are instantiated by reflection and need to take configuration parameters
configure(Map<String, ?>) - Method in interface kafka.common.Configurable
Configure this class with the given key-value pairs
CorruptRecordException - Exception in kafka.common.errors
 
CorruptRecordException() - Constructor for exception kafka.common.errors.CorruptRecordException
 
CorruptRecordException(String) - Constructor for exception kafka.common.errors.CorruptRecordException
 
CorruptRecordException(Throwable) - Constructor for exception kafka.common.errors.CorruptRecordException
 
CorruptRecordException(String, Throwable) - Constructor for exception kafka.common.errors.CorruptRecordException
 

D

description() - Method in interface kafka.common.Metric
A description of what is measured...this will be "" if no description was given

E

empty() - Static method in class kafka.common.Cluster
Create an empty cluster instance with no nodes and no topic-partitions.
ENABLE_JMX - Static variable in class kafka.clients.producer.ProducerConfig
 
equals(Object) - Method in class kafka.common.Node
 
equals(Object) - Method in class kafka.common.TopicPartition
 
errorNext(RuntimeException) - Method in class kafka.clients.producer.MockProducer
Complete the earliest uncompleted call with the given error.

F

fillInStackTrace() - Method in exception kafka.common.errors.ApiException
 

H

hashCode() - Method in class kafka.common.Node
 
hashCode() - Method in class kafka.common.TopicPartition
 
history() - Method in class kafka.clients.producer.MockProducer
Get the list of sent records since the last call to MockProducer.clear()
host() - Method in class kafka.common.Node
The host name for this node

I

id() - Method in class kafka.common.Node
The node id of this node
inSyncReplicas() - Method in class kafka.common.PartitionInfo
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

K

kafka.clients.producer - package kafka.clients.producer
 
kafka.common - package kafka.common
 
kafka.common.errors - package kafka.common.errors
 
KafkaException - Exception in kafka.common
The base class of all other Kafka exceptions
KafkaException(String, Throwable) - Constructor for exception kafka.common.KafkaException
 
KafkaException(String) - Constructor for exception kafka.common.KafkaException
 
KafkaException(Throwable) - Constructor for exception kafka.common.KafkaException
 
KafkaException() - Constructor for exception kafka.common.KafkaException
 
KafkaProducer - Class in kafka.clients.producer
A Kafka client that publishes records to the Kafka cluster.
KafkaProducer(Map<String, Object>) - Constructor for class kafka.clients.producer.KafkaProducer
A producer is instantiated by providing a set of key-value pairs as configuration.
KafkaProducer(Properties) - Constructor for class kafka.clients.producer.KafkaProducer
A producer is instantiated by providing a set of key-value pairs as configuration.
key() - Method in class kafka.clients.producer.ProducerRecord
The key (or null if no key is specified)

L

leader() - Method in class kafka.common.PartitionInfo
The node id of the node currently acting as a leader for this partition or -1 if there is no leader
leaderFor(TopicPartition) - Method in class kafka.common.Cluster
Get the current leader for the given topic-partition
LeaderNotAvailableException - Exception in kafka.common.errors
 
LeaderNotAvailableException(String, Throwable) - Constructor for exception kafka.common.errors.LeaderNotAvailableException
 
LeaderNotAvailableException(String) - Constructor for exception kafka.common.errors.LeaderNotAvailableException
 
LeaderNotAvailableException(Throwable) - Constructor for exception kafka.common.errors.LeaderNotAvailableException
 
LINGER_MS_CONFIG - Static variable in class kafka.clients.producer.ProducerConfig
The producer groups together any records that arrive in between request sends.

M

MAX_PARTITION_SIZE_CONFIG - Static variable in class kafka.clients.producer.ProducerConfig
The buffer size allocated for a partition.
MAX_REQUEST_SIZE_CONFIG - Static variable in class kafka.clients.producer.ProducerConfig
The maximum size of a request.
METADATA_FETCH_TIMEOUT_CONFIG - Static variable in class kafka.clients.producer.ProducerConfig
The amount of time to block waiting to fetch metadata about a topic the first time a record is sent to that topic.
METADATA_REFRESH_MS_CONFIG - Static variable in class kafka.clients.producer.ProducerConfig
Force a refresh of the cluster metadata after this period of time.
Metric - Interface in kafka.common
A numerical metric tracked for monitoring purposes
metrics() - Method in class kafka.clients.producer.KafkaProducer
 
metrics() - Method in class kafka.clients.producer.MockProducer
 
metrics() - Method in interface kafka.clients.producer.Producer
Return a map of metrics maintained by the producer
MockProducer - Class in kafka.clients.producer
A mock of the producer interface you can use for testing code that uses Kafka.
MockProducer(Cluster, boolean) - Constructor for class kafka.clients.producer.MockProducer
Create a mock producer
MockProducer(boolean) - Constructor for class kafka.clients.producer.MockProducer
Create a new mock producer with invented metadata the given autoComplete setting.
MockProducer() - Constructor for class kafka.clients.producer.MockProducer
Create a new auto completing mock producer Equivalent to new MockProducer(true)

N

name() - Method in interface kafka.common.Metric
A unique name for this metric
NetworkException - Exception in kafka.common.errors
 
NetworkException() - Constructor for exception kafka.common.errors.NetworkException
 
NetworkException(String, Throwable) - Constructor for exception kafka.common.errors.NetworkException
 
NetworkException(String) - Constructor for exception kafka.common.errors.NetworkException
 
NetworkException(Throwable) - Constructor for exception kafka.common.errors.NetworkException
 
nextNode() - Method in class kafka.common.Cluster
Round-robin over the nodes in this cluster
Node - Class in kafka.common
Information about a Kafka node
Node(int, String, int) - Constructor for class kafka.common.Node
 
nodes() - Method in class kafka.common.Cluster
 
NotLeaderForPartitionException - Exception in kafka.common.errors
 
NotLeaderForPartitionException() - Constructor for exception kafka.common.errors.NotLeaderForPartitionException
 
NotLeaderForPartitionException(String) - Constructor for exception kafka.common.errors.NotLeaderForPartitionException
 
NotLeaderForPartitionException(Throwable) - Constructor for exception kafka.common.errors.NotLeaderForPartitionException
 
NotLeaderForPartitionException(String, Throwable) - Constructor for exception kafka.common.errors.NotLeaderForPartitionException
 

O

offset() - Method in class kafka.clients.producer.RecordMetadata
The offset of the record in the topic/partition.
OffsetMetadataTooLarge - Exception in kafka.common.errors
 
OffsetMetadataTooLarge() - Constructor for exception kafka.common.errors.OffsetMetadataTooLarge
 
OffsetMetadataTooLarge(String) - Constructor for exception kafka.common.errors.OffsetMetadataTooLarge
 
OffsetMetadataTooLarge(Throwable) - Constructor for exception kafka.common.errors.OffsetMetadataTooLarge
 
OffsetMetadataTooLarge(String, Throwable) - Constructor for exception kafka.common.errors.OffsetMetadataTooLarge
 
OffsetOutOfRangeException - Exception in kafka.common.errors
 
OffsetOutOfRangeException() - Constructor for exception kafka.common.errors.OffsetOutOfRangeException
 
OffsetOutOfRangeException(String) - Constructor for exception kafka.common.errors.OffsetOutOfRangeException
 
OffsetOutOfRangeException(Throwable) - Constructor for exception kafka.common.errors.OffsetOutOfRangeException
 
OffsetOutOfRangeException(String, Throwable) - Constructor for exception kafka.common.errors.OffsetOutOfRangeException
 
onCompletion(RecordMetadata, Exception) - Method in interface kafka.clients.producer.Callback
A callback method the user can implement to provide asynchronous handling of request completion.

P

partition() - Method in class kafka.clients.producer.ProducerRecord
The partition to which the record will be sent (or null if no partition was specified)
partition() - Method in class kafka.clients.producer.RecordMetadata
The partition the record was sent to
partition(TopicPartition) - Method in class kafka.common.Cluster
Get the metadata for the specified partition
partition() - Method in class kafka.common.PartitionInfo
The partition id
partition() - Method in class kafka.common.TopicPartition
 
PartitionInfo - Class in kafka.common
Information about a topic-partition.
PartitionInfo(String, int, Node, Node[], Node[]) - Constructor for class kafka.common.PartitionInfo
 
partitionsFor(String) - Method in class kafka.clients.producer.KafkaProducer
 
partitionsFor(String) - Method in class kafka.clients.producer.MockProducer
 
partitionsFor(String) - Method in interface kafka.clients.producer.Producer
Get a list of partitions for the given topic for custom partition assignment.
partitionsFor(String) - Method in class kafka.common.Cluster
Get the list of partitions for this topic
port() - Method in class kafka.common.Node
The port for this node
Producer - Interface in kafka.clients.producer
The interface for the KafkaProducer
ProducerConfig - Class in kafka.clients.producer
The producer configuration keys
ProducerRecord - Class in kafka.clients.producer
A key/value pair to be sent to Kafka.
ProducerRecord(String, Integer, byte[], byte[]) - Constructor for class kafka.clients.producer.ProducerRecord
Creates a record to be sent to a specified topic and partition
ProducerRecord(String, byte[], byte[]) - Constructor for class kafka.clients.producer.ProducerRecord
Create a record to be sent to Kafka
ProducerRecord(String, byte[]) - Constructor for class kafka.clients.producer.ProducerRecord
Create a record with no key

R

RECONNECT_BACKOFF_MS_CONFIG - Static variable in class kafka.clients.producer.ProducerConfig
The amount of time to wait before attempting to reconnect to a given host.
RecordMetadata - Class in kafka.clients.producer
The metadata for a record that has been acknowledged by the server
RecordMetadata(TopicPartition, long) - Constructor for class kafka.clients.producer.RecordMetadata
 
RecordTooLargeException - Exception in kafka.common.errors
 
RecordTooLargeException() - Constructor for exception kafka.common.errors.RecordTooLargeException
 
RecordTooLargeException(String, Throwable) - Constructor for exception kafka.common.errors.RecordTooLargeException
 
RecordTooLargeException(String) - Constructor for exception kafka.common.errors.RecordTooLargeException
 
RecordTooLargeException(Throwable) - Constructor for exception kafka.common.errors.RecordTooLargeException
 
replicas() - Method in class kafka.common.PartitionInfo
The complete set of replicas for this partition regardless of whether they are alive or up-to-date
REQUEST_TIMEOUT_CONFIG - Static variable in class kafka.clients.producer.ProducerConfig
The maximum amount of time the server will wait for acknowledgments from followers to meet the acknowledgment requirements the producer has specified.
REQUIRED_ACKS_CONFIG - Static variable in class kafka.clients.producer.ProducerConfig
The number of acknowledgments the producer requires from the server before considering a request complete.
RetryableException - Exception in kafka.common.errors
A retryable exception is an exception that is safe to retry.
RetryableException(String, Throwable) - Constructor for exception kafka.common.errors.RetryableException
 
RetryableException(String) - Constructor for exception kafka.common.errors.RetryableException
 
RetryableException(Throwable) - Constructor for exception kafka.common.errors.RetryableException
 
RetryableException() - Constructor for exception kafka.common.errors.RetryableException
 

S

send(ProducerRecord) - Method in class kafka.clients.producer.KafkaProducer
Asynchronously send a record to a topic.
send(ProducerRecord, Callback) - Method in class kafka.clients.producer.KafkaProducer
Asynchronously send a record to a topic and invoke the provided callback when the send has been acknowledged.
send(ProducerRecord) - Method in class kafka.clients.producer.MockProducer
Adds the record to the list of sent records.
send(ProducerRecord, Callback) - Method in class kafka.clients.producer.MockProducer
Adds the record to the list of sent records.
send(ProducerRecord) - Method in interface kafka.clients.producer.Producer
Send the given record asynchronously and return a future which will eventually contain the response information.
send(ProducerRecord, Callback) - Method in interface kafka.clients.producer.Producer
Send a record and invoke the given callback when the record has been acknowledged by the server
SEND_BUFFER_CONFIG - Static variable in class kafka.clients.producer.ProducerConfig
The size of the TCP send buffer to use when sending data

T

TimeoutException - Exception in kafka.common.errors
 
TimeoutException() - Constructor for exception kafka.common.errors.TimeoutException
 
TimeoutException(String, Throwable) - Constructor for exception kafka.common.errors.TimeoutException
 
TimeoutException(String) - Constructor for exception kafka.common.errors.TimeoutException
 
TimeoutException(Throwable) - Constructor for exception kafka.common.errors.TimeoutException
 
topic() - Method in class kafka.clients.producer.ProducerRecord
The topic this record is being sent to
topic() - Method in class kafka.clients.producer.RecordMetadata
The topic the record was appended to
topic() - Method in class kafka.common.PartitionInfo
The topic name
topic() - Method in class kafka.common.TopicPartition
 
TopicPartition - Class in kafka.common
A topic name and partition number
TopicPartition(String, int) - Constructor for class kafka.common.TopicPartition
 
toString() - Method in class kafka.common.Node
 
toString() - Method in class kafka.common.TopicPartition
 
TOTAL_BUFFER_MEMORY_CONFIG - Static variable in class kafka.clients.producer.ProducerConfig
The total memory used by the producer to buffer records waiting to be sent to the server.

U

UnknownServerException - Exception in kafka.common.errors
 
UnknownServerException() - Constructor for exception kafka.common.errors.UnknownServerException
 
UnknownServerException(String) - Constructor for exception kafka.common.errors.UnknownServerException
 
UnknownServerException(Throwable) - Constructor for exception kafka.common.errors.UnknownServerException
 
UnknownServerException(String, Throwable) - Constructor for exception kafka.common.errors.UnknownServerException
 
UnknownTopicOrPartitionException - Exception in kafka.common.errors
 
UnknownTopicOrPartitionException() - Constructor for exception kafka.common.errors.UnknownTopicOrPartitionException
 
UnknownTopicOrPartitionException(String) - Constructor for exception kafka.common.errors.UnknownTopicOrPartitionException
 
UnknownTopicOrPartitionException(Throwable) - Constructor for exception kafka.common.errors.UnknownTopicOrPartitionException
 
UnknownTopicOrPartitionException(String, Throwable) - Constructor for exception kafka.common.errors.UnknownTopicOrPartitionException
 

V

value() - Method in class kafka.clients.producer.ProducerRecord
 
value() - Method in interface kafka.common.Metric
The value of the metric

A B C D E F H I K L M N O P R S T U V