Share

Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



# Classes and Interfaces in #Apache Kafka - 75 results found.
NameDescriptionTypePackageFrameworkJavaDoc
LongDeserializerClassorg.apache.kafka.common.serializationApache Kafkajavadoc
LeaderNotAvailableExceptionThere is no currently available leader for the given partition (either because a leadership election is in progress or because all replicas are down).Classorg.apache.kafka.common.errorsApache Kafkajavadoc
KafkaProducerA Kafka client that publishes records to the Kafka cluster.Classorg.apache.kafka.clients.producerApache Kafkajavadoc
Check Code Snippets / Samples for org.apache.kafka.clients.producer.KafkaProducer
KafkaExceptionThe base class of all other Kafka exceptionsSee Also:Serialized FormClassorg.apache.kafka.commonApache Kafkajavadoc
KafkaConsumerA Kafka client that consumes records from a Kafka cluster.Classorg.apache.kafka.clients.consumerApache Kafkajavadoc
Check Code Snippets / Samples for org.apache.kafka.clients.consumer.KafkaConsumer
InvalidTopicExceptionThe client has attempted to perform an operation on an invalid topic.Classorg.apache.kafka.common.errorsApache Kafkajavadoc
InvalidRequiredAcksExceptionClassorg.apache.kafka.common.errorsApache Kafkajavadoc
InvalidOffsetExceptionThrown when the offset for a set of partitions is invalid (either undefined or out of range), and no reset policy has been configured.Classorg.apache.kafka.clients.consumerApache Kafkajavadoc
InvalidMetadataExceptionAn exception that may indicate the client's metadata is out of dateSee Also:Serialized FormClassorg.apache.kafka.common.errorsApache Kafkajavadoc
InterruptExceptionAn unchecked wrapper for InterruptedExceptionSee Also:Serialized FormClassorg.apache.kafka.common.errorsApache Kafkajavadoc
IntegerSerializerClassorg.apache.kafka.common.serializationApache Kafkajavadoc
IntegerDeserializerClassorg.apache.kafka.common.serializationApache Kafkajavadoc
IllegalGenerationExceptionClassorg.apache.kafka.common.errorsApache Kafkajavadoc
GroupLoadInProgressExceptionThe 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.Classorg.apache.kafka.common.errorsApache Kafkajavadoc
GroupCoordinatorNotAvailableExceptionThe broker returns this error code for consumer metadata requests or offset commit requests if the offsets topic has not yet been created.Classorg.apache.kafka.common.errorsApache Kafkajavadoc
GroupAuthorizationExceptionClassorg.apache.kafka.common.errorsApache Kafkajavadoc
DeserializerInterfaceorg.apache.kafka.common.serializationApache Kafkajavadoc
DisconnectExceptionServer disconnected before a request could be completed.Classorg.apache.kafka.common.errorsApache Kafkajavadoc
CorruptRecordExceptionThis exception indicates a record has failed its internal CRC check, this generally indicates network or diskSee Also:Serialized FormClassorg.apache.kafka.common.errorsApache Kafkajavadoc
ControllerMovedExceptionClassorg.apache.kafka.common.errorsApache Kafkajavadoc
ConsumerRecordsA container that holds the list ConsumerRecord per partition for a particular topic.Classorg.apache.kafka.clients.consumerApache Kafkajavadoc
Check Code Snippets / Samples for org.apache.kafka.clients.consumer.ConsumerRecords
ConsumerRecordA key/value pair to be received from Kafka.Classorg.apache.kafka.clients.consumerApache Kafkajavadoc
Check Code Snippets / Samples for org.apache.kafka.clients.consumer.ConsumerRecord
ConsumerRebalanceListenerA 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.Interfaceorg.apache.kafka.clients.consumerApache Kafkajavadoc
ConsumerConfigClassorg.apache.kafka.clients.consumerApache Kafkajavadoc
Check Code Snippets / Samples for org.apache.kafka.clients.consumer.ConsumerConfig

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

ConsumerInterfaceorg.apache.kafka.clients.consumerApache Kafkajavadoc
Check Code Snippets / Samples for org.apache.kafka.clients.consumer.Consumer
ConfigurableInterfaceorg.apache.kafka.commonApache Kafkajavadoc
CommitFailedExceptionThis exception is raised when an offset commit with KafkaConsumer.Classorg.apache.kafka.clients.consumerApache Kafkajavadoc
ClusterA representation of a subset of the nodes, topics, and partitions in the Kafka cluster.Classorg.apache.kafka.commonApache Kafkajavadoc
CallbackA callback interface that the user can implement to allow code to execute when the request is complete.Interfaceorg.apache.kafka.clients.producerApache Kafkajavadoc
Check Code Snippets / Samples for org.apache.kafka.clients.producer.Callback
ByteArraySerializerClassorg.apache.kafka.common.serializationApache Kafkajavadoc
ByteArrayDeserializerClassorg.apache.kafka.common.serializationApache Kafkajavadoc
BufferExhaustedExceptionThis 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.Classorg.apache.kafka.clients.producerApache Kafkajavadoc
BrokerNotAvailableExceptionClassorg.apache.kafka.common.errorsApache Kafkajavadoc
ApiExceptionAny API exception that is part of the public protocol and should be a subclass of this class and be part of thisSee Also:Serialized FormClassorg.apache.kafka.common.errorsApache Kafkajavadoc
AuthorizationExceptionClassorg.apache.kafka.common.errorsApache Kafkajavadoc
LongSerializerClassorg.apache.kafka.common.serializationApache Kafkajavadoc
MetricInterfaceorg.apache.kafka.commonApache Kafkajavadoc
MetricNameThe MetricName class encapsulates a metric's name, logical group and its related attributes This class captures the following parametersClassorg.apache.kafka.commonApache Kafkajavadoc
MockConsumerA mock of the Consumer interface you can use for testing code that uses Kafka.Classorg.apache.kafka.clients.consumerApache Kafkajavadoc
MockProducerA mock of the producer interface you can use for testing code that uses Kafka.Classorg.apache.kafka.clients.producerApache Kafkajavadoc
NetworkExceptionA misc.Classorg.apache.kafka.common.errorsApache Kafkajavadoc
NodeClassorg.apache.kafka.commonApache Kafkajavadoc
NoOffsetForPartitionExceptionIndicates that there is no stored offset for a partition and no defined offsetSee Also:Serialized FormClassorg.apache.kafka.clients.consumerApache Kafkajavadoc
NotCoordinatorForGroupExceptionThe 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.Classorg.apache.kafka.common.errorsApache Kafkajavadoc
NotEnoughReplicasAfterAppendExceptionNumber of insync replicas for the partition is lower than min.Classorg.apache.kafka.common.errorsApache Kafkajavadoc
NotEnoughReplicasExceptionNumber of insync replicas for the partition is lower than min.Classorg.apache.kafka.common.errorsApache Kafkajavadoc
NotLeaderForPartitionExceptionThis server is not the leader for the given partitionSee Also:Serialized FormClassorg.apache.kafka.common.errorsApache Kafkajavadoc
OffsetAndMetadataThe Kafka offset commit API allows users to provide additional metadata (in the form of a string) when an offset is committed.Classorg.apache.kafka.clients.consumerApache Kafkajavadoc
OffsetCommitCallbackA callback interface that the user can implement to trigger custom actions when a commit request completes.Interfaceorg.apache.kafka.clients.consumerApache Kafkajavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

OffsetMetadataTooLargeThe client has tried to save its offset with associated metadata larger than the maximum size allowed by the server.Classorg.apache.kafka.common.errorsApache Kafkajavadoc
OffsetOutOfRangeExceptionNo 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.Classorg.apache.kafka.clients.consumerApache Kafkajavadoc
OffsetResetStrategyenum OffsetResetStrategyEnum Constant SummaryClassorg.apache.kafka.clients.consumerApache Kafkajavadoc
PartitionerInterfaceorg.apache.kafka.clients.producerApache Kafkajavadoc
PartitionInfoInformation about a topic-partition.Classorg.apache.kafka.commonApache Kafkajavadoc
ProducerThe interface for the KafkaProducerSee Also:KafkaProducer, Interfaceorg.apache.kafka.clients.producerApache Kafkajavadoc
Check Code Snippets / Samples for org.apache.kafka.clients.producer.Producer
ProducerConfigConfiguration for the Kafka Producer.Classorg.apache.kafka.clients.producerApache Kafkajavadoc
ProducerRecordA key/value pair to be sent to Kafka.Classorg.apache.kafka.clients.producerApache Kafkajavadoc
Check Code Snippets / Samples for org.apache.kafka.clients.producer.ProducerRecord
RangeAssignorThe range assignor works on a per-topic basis.Classorg.apache.kafka.clients.consumerApache Kafkajavadoc
RebalanceInProgressExceptionClassorg.apache.kafka.common.errorsApache Kafkajavadoc
RecordBatchTooLargeExceptionThis record batch is larger than the maximum allowable sizeSee Also:Serialized FormClassorg.apache.kafka.common.errorsApache Kafkajavadoc
RecordMetadataClassorg.apache.kafka.clients.producerApache Kafkajavadoc
Check Code Snippets / Samples for org.apache.kafka.clients.producer.RecordMetadata
RecordTooLargeExceptionThis record is larger than the maximum allowable sizeSee Also:Serialized FormClassorg.apache.kafka.common.errorsApache Kafkajavadoc
RetriableExceptionA retryable exception is a transient exception that if retried may succeed.Classorg.apache.kafka.common.errorsApache Kafkajavadoc
RoundRobinAssignorThe roundrobin assignor lays out all the available partitions and all the available consumers.Classorg.apache.kafka.clients.consumerApache Kafkajavadoc
SerializationExceptionAny exception during serialization in the producerSee Also:Serialized FormClassorg.apache.kafka.common.errorsApache Kafkajavadoc
SerializerInterfaceorg.apache.kafka.common.serializationApache Kafkajavadoc
StringDeserializerString encoding defaults to UTF8 and can be customized by setting the property key.Classorg.apache.kafka.common.serializationApache Kafkajavadoc
StringSerializerString encoding defaults to UTF8 and can be customized by setting the property key.Classorg.apache.kafka.common.serializationApache Kafkajavadoc
TimeoutExceptionIndicates that a request timed out.Classorg.apache.kafka.common.errorsApache Kafkajavadoc
TopicAuthorizationExceptionClassorg.apache.kafka.common.errorsApache Kafkajavadoc
TopicPartitionA topic name and partition numberSee Also:Serialized FormClassorg.apache.kafka.commonApache Kafkajavadoc
UnknownMemberIdExceptionClassorg.apache.kafka.common.errorsApache Kafkajavadoc
UnknownServerExceptionAn error occurred on the server for which the client doesn't have a corresponding error code.Classorg.apache.kafka.common.errorsApache Kafkajavadoc
UnknownTopicOrPartitionExceptionThis topic/partition doesn't existSee Also:Serialized FormClassorg.apache.kafka.common.errorsApache Kafkajavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

WakeupExceptionException used to indicate preemption of a blocking operation by an external thread.Classorg.apache.kafka.common.errorsApache Kafkajavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner



comments powered by Disqus