Overview
Package
Class
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
All Classes
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
Overview
Package
Class
Tree
Deprecated
Index
Help
PREV NEXT
FRAMES
NO FRAMES
All Classes
All Classes