Search Java Classes and Packages
#Org.apache.kafka.common Classes and Interfaces - 50 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 |
| KafkaException | The base class of all other Kafka exceptionsSee Also:Serialized Form | Class | org.apache.kafka.common | 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 | |
| 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 | |
| Configurable | Interface | org.apache.kafka.common | 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 |
| ByteArraySerializer | Class | org.apache.kafka.common.serialization | Apache Kafka | |
| ByteArrayDeserializer | Class | org.apache.kafka.common.serialization | 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 |
| NetworkException | A misc. | Class | org.apache.kafka.common.errors | Apache Kafka |
| Node | Class | org.apache.kafka.common | 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 |
| 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 |
| PartitionInfo | Information about a topic-partition. | Class | org.apache.kafka.common | 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 |
| 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 |
| 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 |