http://git-wip-us.apache.org/repos/asf/kafka-site/blob/ba6c994c/090/javadoc/index-all.html ---------------------------------------------------------------------- diff --git a/090/javadoc/index-all.html b/090/javadoc/index-all.html new file mode 100644 index 0000000..deea6a6 --- /dev/null +++ b/090/javadoc/index-all.html @@ -0,0 +1,1315 @@ + + + + + +Index (clients 0.8.3-SNAPSHOT API) + + + + + + + +
+ + + + + +
+ + +
A B C D E F G H I K L M N O P R S T U V  + + +

A

+
+
ACKS_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
acks
+
+
addRecord(ConsumerRecord<K, V>) - Method in class org.apache.kafka.clients.consumer.MockConsumer
+
 
+
ApiException - Exception in org.apache.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 org.apache.kafka.common.errors.ApiException
+
 
+
ApiException(String) - Constructor for exception org.apache.kafka.common.errors.ApiException
+
 
+
ApiException(Throwable) - Constructor for exception org.apache.kafka.common.errors.ApiException
+
 
+
ApiException() - Constructor for exception org.apache.kafka.common.errors.ApiException
+
 
+
AUTO_COMMIT_INTERVAL_MS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
auto.commit.interval.ms
+
+
AUTO_OFFSET_RESET_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
auto.offset.reset
+
+
+ + + +

B

+
+
BATCH_SIZE_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
batch.size
+
+
BLOCK_ON_BUFFER_FULL_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
block.on.buffer.full
+
+
bootstrap(List<InetSocketAddress>) - Static method in class org.apache.kafka.common.Cluster
+
+
Create a "bootstrap" cluster using the given list of host/ports
+
+
BOOTSTRAP_SERVERS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
bootstrap.servers
+
+
BOOTSTRAP_SERVERS_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
bootstrap.servers
+
+
BUFFER_MEMORY_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
buffer.memory
+
+
BufferExhaustedException - Exception in org.apache.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 org.apache.kafka.clients.producer.BufferExhaustedException
+
 
+
ByteArrayDeserializer - Class in org.apache.kafka.common.serialization
+
 
+
ByteArrayDeserializer() - Constructor for class org.apache.kafka.common.serialization.ByteArrayDeserializer
+
 
+
ByteArraySerializer - Class in org.apache.kafka.common.serialization
+
 
+
ByteArraySerializer() - Constructor for class org.apache.kafka.common.serialization.ByteArraySerializer
+
 
+
+ + + +

C

+
+
Callback - Interface in org.apache.kafka.clients.producer
+
+
A callback interface that the user can implement to allow code to execute when the request is complete.
+
+
CHECK_CRCS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
check.crcs
+
+
clear() - Method in class org.apache.kafka.clients.producer.MockProducer
+
+
Clear the stored history of sent records
+
+
CLIENT_ID_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
client.id
+
+
CLIENT_ID_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
client.id
+
+
close() - Method in interface org.apache.kafka.clients.consumer.Consumer
+
 
+
close() - Method in class org.apache.kafka.clients.consumer.KafkaConsumer
+
 
+
close() - Method in class org.apache.kafka.clients.consumer.MockConsumer
+
 
+
close() - Method in class org.apache.kafka.clients.producer.KafkaProducer
+
+
Close this producer.
+
+
close() - Method in class org.apache.kafka.clients.producer.MockProducer
+
 
+
close() - Method in interface org.apache.kafka.clients.producer.Producer
+
+
Close this producer
+
+
close() - Method in class org.apache.kafka.common.serialization.ByteArrayDeserializer
+
 
+
close() - Method in class org.apache.kafka.common.serialization.ByteArraySerializer
+
 
+
close() - Method in interface org.apache.kafka.common.serialization.Deserializer
+
+
Close this deserializer
+
+
close() - Method in interface org.apache.kafka.common.serialization.Serializer
+
+
Close this serializer
+
+
close() - Method in class org.apache.kafka.common.serialization.StringDeserializer
+
 
+
close() - Method in class org.apache.kafka.common.serialization.StringSerializer
+
 
+
Cluster - Class in org.apache.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 org.apache.kafka.common.Cluster
+
+
Create a new cluster with the given nodes and partitions
+
+
commit(CommitType) - Method in interface org.apache.kafka.clients.consumer.Consumer
+
 
+
commit(Map<TopicPartition, Long>, CommitType) - Method in interface org.apache.kafka.clients.consumer.Consumer
+
 
+
commit(Map<TopicPartition, Long>, CommitType) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer
+
+
Commits the specified offsets for the specified list of topics and partitions to Kafka.
+
+
commit(CommitType) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer
+
+
Commits offsets returned on the last poll() for the subscribed list of topics and partitions.
+
+
commit(Map<TopicPartition, Long>, CommitType) - Method in class org.apache.kafka.clients.consumer.MockConsumer
+
 
+
commit(CommitType) - Method in class org.apache.kafka.clients.consumer.MockConsumer
+
 
+
committed(TopicPartition) - Method in interface org.apache.kafka.clients.consumer.Consumer
+
 
+
committed(TopicPartition) - Method in class org.apache.kafka.clients.consumer.KafkaConsumer
+
+
Fetches the last committed offset for the given partition (whether the commit happened by this process or + another).
+
+
committed(TopicPartition) - Method in class org.apache.kafka.clients.consumer.MockConsumer
+
 
+
CommitType - Enum in org.apache.kafka.clients.consumer
+
 
+
completeNext() - Method in class org.apache.kafka.clients.producer.MockProducer
+
+
Complete the earliest uncompleted call successfully.
+
+
COMPRESSION_TYPE_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
compression.type
+
+
Configurable - Interface in org.apache.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 org.apache.kafka.common.Configurable
+
+
Configure this class with the given key-value pairs
+
+
configure(Map<String, ?>, boolean) - Method in class org.apache.kafka.common.serialization.ByteArrayDeserializer
+
 
+
configure(Map<String, ?>, boolean) - Method in class org.apache.kafka.common.serialization.ByteArraySerializer
+
 
+
configure(Map<String, ?>, boolean) - Method in interface org.apache.kafka.common.serialization.Deserializer
+
+
Configure this class.
+
+
configure(Map<String, ?>, boolean) - Method in interface org.apache.kafka.common.serialization.Serializer
+
+
Configure this class.
+
+
configure(Map<String, ?>, boolean) - Method in class org.apache.kafka.common.serialization.StringDeserializer
+
 
+
configure(Map<String, ?>, boolean) - Method in class org.apache.kafka.common.serialization.StringSerializer
+
 
+
Consumer<K,V> - Interface in org.apache.kafka.clients.consumer
+
 
+
CONSUMER_REBALANCE_CALLBACK_CLASS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
rebalance.callback.class
+
+
ConsumerConfig - Class in org.apache.kafka.clients.consumer
+
+
The consumer configuration keys
+
+
ConsumerRebalanceCallback - Interface in org.apache.kafka.clients.consumer
+
+
A callback interface that the user can implement to trigger custom actions when the set of partitions assigned to the + consumer changes.
+
+
ConsumerRecord<K,V> - Class in org.apache.kafka.clients.consumer
+
+
A key/value pair to be received from Kafka.
+
+
ConsumerRecord(String, int, long, K, V) - Constructor for class org.apache.kafka.clients.consumer.ConsumerRecord
+
+
Create a record with no key
+
+
ConsumerRecords<K,V> - Class in org.apache.kafka.clients.consumer
+
+
A container that holds the list ConsumerRecord per partition for a + particular topic.
+
+
ConsumerRecords(Map<TopicPartition, List<ConsumerRecord<K, V>>>) - Constructor for class org.apache.kafka.clients.consumer.ConsumerRecords
+
 
+
CorruptRecordException - Exception in org.apache.kafka.common.errors
+
+
This exception indicates a record has failed it's internal CRC check, this generally indicates network or disk + corruption.
+
+
CorruptRecordException() - Constructor for exception org.apache.kafka.common.errors.CorruptRecordException
+
 
+
CorruptRecordException(String) - Constructor for exception org.apache.kafka.common.errors.CorruptRecordException
+
 
+
CorruptRecordException(Throwable) - Constructor for exception org.apache.kafka.common.errors.CorruptRecordException
+
 
+
CorruptRecordException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.CorruptRecordException
+
 
+
count() - Method in class org.apache.kafka.clients.consumer.ConsumerRecords
+
+
The number of records for all topics
+
+
+ + + +

D

+
+
description() - Method in class org.apache.kafka.common.MetricName
+
 
+
deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.ByteArrayDeserializer
+
 
+
deserialize(String, byte[]) - Method in interface org.apache.kafka.common.serialization.Deserializer
+
 
+
deserialize(String, byte[]) - Method in class org.apache.kafka.common.serialization.StringDeserializer
+
 
+
Deserializer<T> - Interface in org.apache.kafka.common.serialization
+
 
+
+ + + +

E

+
+
empty() - Static method in class org.apache.kafka.common.Cluster
+
+
Create an empty cluster instance with no nodes and no topic-partitions.
+
+
ENABLE_AUTO_COMMIT_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
enable.auto.commit
+
+
equals(Object) - Method in class org.apache.kafka.common.MetricName
+
 
+
equals(Object) - Method in class org.apache.kafka.common.Node
+
 
+
equals(Object) - Method in class org.apache.kafka.common.TopicPartition
+
 
+
errorNext(RuntimeException) - Method in class org.apache.kafka.clients.producer.MockProducer
+
+
Complete the earliest uncompleted call with the given error.
+
+
+ + + +

F

+
+
FETCH_MAX_WAIT_MS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
fetch.max.wait.ms
+
+
FETCH_MIN_BYTES_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
fetch.min.bytes
+
+
fillInStackTrace() - Method in exception org.apache.kafka.common.errors.ApiException
+
 
+
fillInStackTrace() - Method in exception org.apache.kafka.common.errors.SerializationException
+
 
+
+ + + +

G

+
+
group() - Method in class org.apache.kafka.common.MetricName
+
 
+
GROUP_ID_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
group.id
+
+
+ + + +

H

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

I

+
+
id() - Method in class org.apache.kafka.common.Node
+
+
The node id of this node
+
+
inSyncReplicas() - Method in class org.apache.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
+
+
InvalidMetadataException - Exception in org.apache.kafka.common.errors
+
+
An exception that may indicate the client's metadata is out of date
+
+
InvalidMetadataException() - Constructor for exception org.apache.kafka.common.errors.InvalidMetadataException
+
 
+
InvalidMetadataException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidMetadataException
+
 
+
InvalidMetadataException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidMetadataException
+
 
+
InvalidMetadataException(Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidMetadataException
+
 
+
InvalidTopicException - Exception in org.apache.kafka.common.errors
+
+
The client has attempted to perform an operation on an invalid topic.
+
+
InvalidTopicException() - Constructor for exception org.apache.kafka.common.errors.InvalidTopicException
+
 
+
InvalidTopicException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidTopicException
+
 
+
InvalidTopicException(String) - Constructor for exception org.apache.kafka.common.errors.InvalidTopicException
+
 
+
InvalidTopicException(Throwable) - Constructor for exception org.apache.kafka.common.errors.InvalidTopicException
+
 
+
iterator() - Method in class org.apache.kafka.clients.consumer.ConsumerRecords
+
 
+
+ + + +

K

+
+
KafkaConsumer<K,V> - Class in org.apache.kafka.clients.consumer
+
+
A Kafka client that consumes records from a Kafka cluster.
+
+
KafkaConsumer(Map<String, Object>) - Constructor for class org.apache.kafka.clients.consumer.KafkaConsumer
+
+
A consumer is instantiated by providing a set of key-value pairs as configuration.
+
+
KafkaConsumer(Map<String, Object>, ConsumerRebalanceCallback, Deserializer<K>, Deserializer<V>) - Constructor for class org.apache.kafka.clients.consumer.KafkaConsumer
+
+
A consumer is instantiated by providing a set of key-value pairs as configuration, a + ConsumerRebalanceCallback implementation, a key and a value Deserializer.
+
+
KafkaConsumer(Properties) - Constructor for class org.apache.kafka.clients.consumer.KafkaConsumer
+
+
A consumer is instantiated by providing a Properties object as configuration.
+
+
KafkaConsumer(Properties, ConsumerRebalanceCallback, Deserializer<K>, Deserializer<V>) - Constructor for class org.apache.kafka.clients.consumer.KafkaConsumer
+
+
A consumer is instantiated by providing a Properties object as configuration and a + ConsumerRebalanceCallback implementation, a key and a value Deserializer.
+
+
KafkaException - Exception in org.apache.kafka.common
+
+
The base class of all other Kafka exceptions
+
+
KafkaException(String, Throwable) - Constructor for exception org.apache.kafka.common.KafkaException
+
 
+
KafkaException(String) - Constructor for exception org.apache.kafka.common.KafkaException
+
 
+
KafkaException(Throwable) - Constructor for exception org.apache.kafka.common.KafkaException
+
 
+
KafkaException() - Constructor for exception org.apache.kafka.common.KafkaException
+
 
+
KafkaProducer<K,V> - Class in org.apache.kafka.clients.producer
+
+
A Kafka client that publishes records to the Kafka cluster.
+
+
KafkaProducer(Map<String, Object>) - Constructor for class org.apache.kafka.clients.producer.KafkaProducer
+
+
A producer is instantiated by providing a set of key-value pairs as configuration.
+
+
KafkaProducer(Map<String, Object>, Serializer<K>, Serializer<V>) - Constructor for class org.apache.kafka.clients.producer.KafkaProducer
+
+
A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value Serializer.
+
+
KafkaProducer(Properties) - Constructor for class org.apache.kafka.clients.producer.KafkaProducer
+
+
A producer is instantiated by providing a set of key-value pairs as configuration.
+
+
KafkaProducer(Properties, Serializer<K>, Serializer<V>) - Constructor for class org.apache.kafka.clients.producer.KafkaProducer
+
+
A producer is instantiated by providing a set of key-value pairs as configuration, a key and a value Serializer.
+
+
key() - Method in class org.apache.kafka.clients.consumer.ConsumerRecord
+
+
The key (or null if no key is specified)
+
+
key() - Method in class org.apache.kafka.clients.producer.ProducerRecord
+
+
The key (or null if no key is specified)
+
+
KEY_DESERIALIZER_CLASS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
key.deserializer
+
+
KEY_SERIALIZER_CLASS_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
key.serializer
+
+
+ + + +

L

+
+
leader() - Method in class org.apache.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 org.apache.kafka.common.Cluster
+
+
Get the current leader for the given topic-partition
+
+
LeaderNotAvailableException - Exception in org.apache.kafka.common.errors
+
+
There is no currently available leader for the given partition (either because a leadership election is in progress + or because all replicas are down).
+
+
LeaderNotAvailableException(String) - Constructor for exception org.apache.kafka.common.errors.LeaderNotAvailableException
+
 
+
LINGER_MS_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
linger.ms
+
+
+ + + +

M

+
+
main(String[]) - Static method in class org.apache.kafka.clients.consumer.ConsumerConfig
+
 
+
main(String[]) - Static method in class org.apache.kafka.clients.producer.ProducerConfig
+
 
+
MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
max.in.flight.requests.per.connection
+
+
MAX_PARTITION_FETCH_BYTES_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
max.partition.fetch.bytes
+
+
MAX_REQUEST_SIZE_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
max.request.size
+
+
METADATA_FETCH_TIMEOUT_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
metadata.fetch.timeout.ms
+
+
METADATA_MAX_AGE_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
metadata.max.age.ms
+
+
METADATA_MAX_AGE_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
metadata.max.age.ms
+
+
Metric - Interface in org.apache.kafka.common
+
+
A numerical metric tracked for monitoring purposes
+
+
METRIC_REPORTER_CLASSES_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
metric.reporters
+
+
METRIC_REPORTER_CLASSES_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
metric.reporters
+
+
metricName() - Method in interface org.apache.kafka.common.Metric
+
+
A name for this metric
+
+
MetricName - Class in org.apache.kafka.common
+
+
The MetricName class encapsulates a metric's name, logical group and its related attributes
+
+
MetricName(String, String, String, Map<String, String>) - Constructor for class org.apache.kafka.common.MetricName
+
 
+
MetricName(String, String, String, String...) - Constructor for class org.apache.kafka.common.MetricName
+
 
+
MetricName(String, String, Map<String, String>) - Constructor for class org.apache.kafka.common.MetricName
+
 
+
MetricName(String, String, String) - Constructor for class org.apache.kafka.common.MetricName
+
 
+
MetricName(String, String) - Constructor for class org.apache.kafka.common.MetricName
+
 
+
metrics() - Method in interface org.apache.kafka.clients.consumer.Consumer
+
 
+
metrics() - Method in class org.apache.kafka.clients.consumer.KafkaConsumer
+
+
Get the metrics kept by the consumer
+
+
metrics() - Method in class org.apache.kafka.clients.consumer.MockConsumer
+
 
+
metrics() - Method in class org.apache.kafka.clients.producer.KafkaProducer
+
 
+
metrics() - Method in class org.apache.kafka.clients.producer.MockProducer
+
 
+
metrics() - Method in interface org.apache.kafka.clients.producer.Producer
+
+
Return a map of metrics maintained by the producer
+
+
METRICS_NUM_SAMPLES_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
metrics.num.samples
+
+
METRICS_NUM_SAMPLES_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
metrics.num.samples
+
+
METRICS_SAMPLE_WINDOW_MS_CONFIG - Static variable in class org.apache.kafka.clients.consumer.ConsumerConfig
+
+
metrics.sample.window.ms
+
+
METRICS_SAMPLE_WINDOW_MS_CONFIG - Static variable in class org.apache.kafka.clients.producer.ProducerConfig
+
+
metrics.sample.window.ms
+
+
MockConsumer<K,V> - Class in org.apache.kafka.clients.consumer
+
+
A mock of the Consumer interface you can use for testing code that uses Kafka.
+
+
MockConsumer() - Constructor for class org.apache.kafka.clients.consumer.MockConsumer
+
 
+
MockProducer - Class in org.apache.kafka.clients.producer
+
+
A mock of the producer interface you can use for testing code that uses Kafka.
+
+
MockProducer(Cluster, boolean) - Constructor for class org.apache.kafka.clients.producer.MockProducer
+
+
Create a mock producer
+
+
MockProducer(boolean) - Constructor for class org.apache.kafka.clients.producer.MockProducer
+
+
Create a new mock producer with invented metadata the given autoComplete setting.
+
+
MockProducer() - Constructor for class org.apache.kafka.clients.producer.MockProducer
+
+
Create a new auto completing mock producer + + Equivalent to new MockProducer(true)
+
+
+ + + +

N

+
+
name() - Method in class org.apache.kafka.common.MetricName
+
 
+
NetworkException - Exception in org.apache.kafka.common.errors
+
+
A misc.
+
+
NetworkException() - Constructor for exception org.apache.kafka.common.errors.NetworkException
+
 
+
NetworkException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.NetworkException
+
 
+
NetworkException(String) - Constructor for exception org.apache.kafka.common.errors.NetworkException
+
 
+
NetworkException(Throwable) - Constructor for exception org.apache.kafka.common.errors.NetworkException
+
 
+
Node - Class in org.apache.kafka.common
+
+
Information about a Kafka node
+
+
Node(int, String, int) - Constructor for class org.apache.kafka.common.Node
+
 
+
nodeById(int) - Method in class org.apache.kafka.common.Cluster
+
+
Get the node by the node id (or null if no such node exists)
+
+
nodes() - Method in class org.apache.kafka.common.Cluster
+
 
+
NoOffsetForPartitionException - Exception in org.apache.kafka.clients.consumer
+
+
Indicates that there is no stored offset and no defined offset reset policy
+
+
NoOffsetForPartitionException(String) - Constructor for exception org.apache.kafka.clients.consumer.NoOffsetForPartitionException
+
 
+
NotEnoughReplicasAfterAppendException - Exception in org.apache.kafka.common.errors
+
+
Number of insync replicas for the partition is lower than min.insync.replicas This exception is raised when the low + ISR size is discovered *after* the message was already appended to the log.
+
+
NotEnoughReplicasAfterAppendException() - Constructor for exception org.apache.kafka.common.errors.NotEnoughReplicasAfterAppendException
+
 
+
NotEnoughReplicasAfterAppendException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.NotEnoughReplicasAfterAppendException
+
 
+
NotEnoughReplicasAfterAppendException(String) - Constructor for exception org.apache.kafka.common.errors.NotEnoughReplicasAfterAppendException
+
 
+
NotEnoughReplicasAfterAppendException(Throwable) - Constructor for exception org.apache.kafka.common.errors.NotEnoughReplicasAfterAppendException
+
 
+
NotEnoughReplicasException - Exception in org.apache.kafka.common.errors
+
+
Number of insync replicas for the partition is lower than min.insync.replicas
+
+
NotEnoughReplicasException() - Constructor for exception org.apache.kafka.common.errors.NotEnoughReplicasException
+
 
+
NotEnoughReplicasException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.NotEnoughReplicasException
+
 
+
NotEnoughReplicasException(String) - Constructor for exception org.apache.kafka.common.errors.NotEnoughReplicasException
+
 
+
NotEnoughReplicasException(Throwable) - Constructor for exception org.apache.kafka.common.errors.NotEnoughReplicasException
+
 
+
NotLeaderForPartitionException - Exception in org.apache.kafka.common.errors
+
+
This server is not the leader for the given partition
+
+
NotLeaderForPartitionException() - Constructor for exception org.apache.kafka.common.errors.NotLeaderForPartitionException
+
 
+
NotLeaderForPartitionException(String) - Constructor for exception org.apache.kafka.common.errors.NotLeaderForPartitionException
+
 
+
NotLeaderForPartitionException(Throwable) - Constructor for exception org.apache.kafka.common.errors.NotLeaderForPartitionException
+
 
+
NotLeaderForPartitionException(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.NotLeaderForPartitionException
+
 
+
+ + + +

O

+
+
offset() - Method in class org.apache.kafka.clients.consumer.ConsumerRecord
+
+
The position of this record in the corresponding Kafka partition.
+
+
offset() - Method in class org.apache.kafka.clients.producer.RecordMetadata
+
+
The offset of the record in the topic/partition.
+
+
OffsetMetadataTooLarge - Exception in org.apache.kafka.common.errors
+
+
The client has tried to save its offset with associated metadata larger than the maximum size allowed by the server.
+
+
OffsetMetadataTooLarge() - Constructor for exception org.apache.kafka.common.errors.OffsetMetadataTooLarge
+
 
+
OffsetMetadataTooLarge(String) - Constructor for exception org.apache.kafka.common.errors.OffsetMetadataTooLarge
+
 
+
OffsetMetadataTooLarge(Throwable) - Constructor for exception org.apache.kafka.common.errors.OffsetMetadataTooLarge
+
 
+
OffsetMetadataTooLarge(String, Throwable) - Constructor for exception org.apache.kafka.common.errors.OffsetMetadataTooLarge
+
 
+
OffsetOutOfRangeException - Exception in org.apache.kafka.common.errors
+
+
This offset is either larger or smaller than the range of offsets the server has for the given partition.
+
+
OffsetOutOfRangeException() - Constructor for exception org.apache.kafka.common.errors.OffsetOutOfRangeException
+
 
+
OffsetOutOfRangeException(String) - Constructor for exception org.apache.kafka.common.errors.