Search Java Classes and Packages
# Classes and Interfaces in #Apache Kafka - 75 results found.
| Name | Description | Type | Package | Framework |
| LongDeserializer | Class | org.apache.kafka.common.serialization | Apache Kafka | |
| LeaderNotAvailableException | There is no currently available leader for the given partition (either because a leadership election is in progress or because all replicas are down). | Class | org.apache.kafka.common.errors | Apache Kafka |
| KafkaProducer | A Kafka client that publishes records to the Kafka cluster. | Class | org.apache.kafka.clients.producer | Apache Kafka |
| KafkaException | The base class of all other Kafka exceptionsSee Also:Serialized Form | Class | org.apache.kafka.common | Apache Kafka |
| KafkaConsumer | A Kafka client that consumes records from a Kafka cluster. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| InvalidTopicException | The client has attempted to perform an operation on an invalid topic. | Class | org.apache.kafka.common.errors | Apache Kafka |
| InvalidRequiredAcksException | Class | org.apache.kafka.common.errors | Apache Kafka | |
| InvalidOffsetException | Thrown when the offset for a set of partitions is invalid (either undefined or out of range), and no reset policy has been configured. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| InvalidMetadataException | An exception that may indicate the client's metadata is out of dateSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
| InterruptException | An unchecked wrapper for InterruptedExceptionSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
| IntegerSerializer | Class | org.apache.kafka.common.serialization | Apache Kafka | |
| IntegerDeserializer | Class | org.apache.kafka.common.serialization | Apache Kafka | |
| IllegalGenerationException | Class | org.apache.kafka.common.errors | Apache Kafka | |
| GroupLoadInProgressException | The broker returns this error code for any coordiantor request if it is still loading the metadata (after a leader change for that offsets topic partition) for this group. | Class | org.apache.kafka.common.errors | Apache Kafka |
| GroupCoordinatorNotAvailableException | The broker returns this error code for consumer metadata requests or offset commit requests if the offsets topic has not yet been created. | Class | org.apache.kafka.common.errors | Apache Kafka |
| GroupAuthorizationException | Class | org.apache.kafka.common.errors | Apache Kafka | |
| Deserializer | Interface | org.apache.kafka.common.serialization | Apache Kafka | |
| DisconnectException | Server disconnected before a request could be completed. | Class | org.apache.kafka.common.errors | Apache Kafka |
| CorruptRecordException | This exception indicates a record has failed its internal CRC check, this generally indicates network or diskSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
| ControllerMovedException | Class | org.apache.kafka.common.errors | Apache Kafka | |
| ConsumerRecords | A container that holds the list ConsumerRecord per partition for a particular topic. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| ConsumerRecord | A key/value pair to be received from Kafka. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| ConsumerRebalanceListener | A callback interface that the user can implement to trigger custom actions when the set of partitions assigned to the This is applicable when the consumer is having Kafka auto-manage group membership. | Interface | org.apache.kafka.clients.consumer | Apache Kafka |
| ConsumerConfig | Class | org.apache.kafka.clients.consumer | Apache Kafka | |
| Consumer | Interface | org.apache.kafka.clients.consumer | Apache Kafka | |
| Configurable | Interface | org.apache.kafka.common | Apache Kafka | |
| CommitFailedException | This exception is raised when an offset commit with KafkaConsumer. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| Cluster | A representation of a subset of the nodes, topics, and partitions in the Kafka cluster. | Class | org.apache.kafka.common | Apache Kafka |
| Callback | A callback interface that the user can implement to allow code to execute when the request is complete. | Interface | org.apache.kafka.clients.producer | Apache Kafka |
| ByteArraySerializer | Class | org.apache.kafka.common.serialization | Apache Kafka | |
| ByteArrayDeserializer | Class | org.apache.kafka.common.serialization | Apache Kafka | |
| BufferExhaustedException | 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. | Class | org.apache.kafka.clients.producer | Apache Kafka |
| BrokerNotAvailableException | Class | org.apache.kafka.common.errors | Apache Kafka | |
| ApiException | Any API exception that is part of the public protocol and should be a subclass of this class and be part of thisSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
| AuthorizationException | Class | org.apache.kafka.common.errors | Apache Kafka | |
| LongSerializer | Class | org.apache.kafka.common.serialization | Apache Kafka | |
| Metric | Interface | org.apache.kafka.common | Apache Kafka | |
| MetricName | The MetricName class encapsulates a metric's name, logical group and its related attributes This class captures the following parameters | Class | org.apache.kafka.common | Apache Kafka |
| MockConsumer | A mock of the Consumer interface you can use for testing code that uses Kafka. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| MockProducer | A mock of the producer interface you can use for testing code that uses Kafka. | Class | org.apache.kafka.clients.producer | Apache Kafka |
| NetworkException | A misc. | Class | org.apache.kafka.common.errors | Apache Kafka |
| Node | Class | org.apache.kafka.common | Apache Kafka | |
| NoOffsetForPartitionException | Indicates that there is no stored offset for a partition and no defined offsetSee Also:Serialized Form | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| NotCoordinatorForGroupException | The broker returns this error code if it receives an offset fetch or commit request for a consumer group that it is not a coordinator for. | Class | org.apache.kafka.common.errors | Apache Kafka |
| NotEnoughReplicasAfterAppendException | Number of insync replicas for the partition is lower than min. | Class | org.apache.kafka.common.errors | Apache Kafka |
| NotEnoughReplicasException | Number of insync replicas for the partition is lower than min. | Class | org.apache.kafka.common.errors | Apache Kafka |
| NotLeaderForPartitionException | This server is not the leader for the given partitionSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
| OffsetAndMetadata | The Kafka offset commit API allows users to provide additional metadata (in the form of a string) when an offset is committed. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| OffsetCommitCallback | A callback interface that the user can implement to trigger custom actions when a commit request completes. | Interface | org.apache.kafka.clients.consumer | Apache Kafka |
| OffsetMetadataTooLarge | The client has tried to save its offset with associated metadata larger than the maximum size allowed by the server. | Class | org.apache.kafka.common.errors | Apache Kafka |
| OffsetOutOfRangeException | No reset policy has been defined, and the offsets for these partitions are either larger or smaller than the range of offsets the server has for the given partition. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| OffsetResetStrategy | enum OffsetResetStrategyEnum Constant Summary | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| Partitioner | Interface | org.apache.kafka.clients.producer | Apache Kafka | |
| PartitionInfo | Information about a topic-partition. | Class | org.apache.kafka.common | Apache Kafka |
| Producer | The interface for the KafkaProducerSee Also:KafkaProducer, | Interface | org.apache.kafka.clients.producer | Apache Kafka |
| ProducerConfig | Configuration for the Kafka Producer. | Class | org.apache.kafka.clients.producer | Apache Kafka |
| ProducerRecord | A key/value pair to be sent to Kafka. | Class | org.apache.kafka.clients.producer | Apache Kafka |
| RangeAssignor | The range assignor works on a per-topic basis. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| RebalanceInProgressException | Class | org.apache.kafka.common.errors | Apache Kafka | |
| RecordBatchTooLargeException | This record batch is larger than the maximum allowable sizeSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
| RecordMetadata | Class | org.apache.kafka.clients.producer | Apache Kafka | |
| RecordTooLargeException | This record is larger than the maximum allowable sizeSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
| RetriableException | A retryable exception is a transient exception that if retried may succeed. | Class | org.apache.kafka.common.errors | Apache Kafka |
| RoundRobinAssignor | The roundrobin assignor lays out all the available partitions and all the available consumers. | Class | org.apache.kafka.clients.consumer | Apache Kafka |
| SerializationException | Any exception during serialization in the producerSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
| Serializer | Interface | org.apache.kafka.common.serialization | Apache Kafka | |
| StringDeserializer | String encoding defaults to UTF8 and can be customized by setting the property key. | Class | org.apache.kafka.common.serialization | Apache Kafka |
| StringSerializer | String encoding defaults to UTF8 and can be customized by setting the property key. | Class | org.apache.kafka.common.serialization | Apache Kafka |
| TimeoutException | Indicates that a request timed out. | Class | org.apache.kafka.common.errors | Apache Kafka |
| TopicAuthorizationException | Class | org.apache.kafka.common.errors | Apache Kafka | |
| TopicPartition | A topic name and partition numberSee Also:Serialized Form | Class | org.apache.kafka.common | Apache Kafka |
| UnknownMemberIdException | Class | org.apache.kafka.common.errors | Apache Kafka | |
| UnknownServerException | An error occurred on the server for which the client doesn't have a corresponding error code. | Class | org.apache.kafka.common.errors | Apache Kafka |
| UnknownTopicOrPartitionException | This topic/partition doesn't existSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
| WakeupException | Exception used to indicate preemption of a blocking operation by an external thread. | Class | org.apache.kafka.common.errors | Apache Kafka |