common

Type Members

1. class AdminCommandFailedException extends RuntimeException

2. class BrokerNotAvailableException extends RuntimeException

3. case class ClientIdAllBrokers(clientId: String) extends ClientIdBroker with Product with Serializable

4. case class ClientIdAllTopics(clientId: String) extends ClientIdTopic with Product with Serializable

5. case class ClientIdAndBroker(clientId: String, brokerHost: String, brokerPort: Int) extends ClientIdBroker with Product with Serializable

6. case class ClientIdAndTopic(clientId: String, topic: String) extends ClientIdTopic with Product with Serializable

7. trait ClientIdBroker extends AnyRef

   Convenience case class since (clientId, brokerInfo) pairs are used to create SyncProducer Request Stats and SimpleConsumer Request and Response Stats.

8. trait ClientIdTopic extends AnyRef

   Convenience case class since (clientId, topic) pairs are used in the creation of many Stats objects.

9. trait Config extends Logging

10. class ConsumerCoordinatorNotAvailableException extends RuntimeException

11. class ConsumerRebalanceFailedException extends RuntimeException

    Thrown when a request is made for broker but no brokers with that topic exist.

12. class ControllerMovedException extends RuntimeException

13. class FailedToSendMessageException extends RuntimeException

    Indicates a producer pool initialization problem

14. class InvalidConfigException extends RuntimeException

    Indicates that the given config parameter has invalid value

15. class InvalidMessageSizeException extends RuntimeException

    Indicates the client has requested a range no longer available on the server

16. class InvalidOffsetException extends RuntimeException

17. class InvalidTopicException extends RuntimeException

18. class KafkaException extends RuntimeException

    Generic Kafka exception

19. class KafkaStorageException extends RuntimeException

    Kafka exception caused by real IOs.

20. class LeaderElectionNotNeededException extends RuntimeException

    This exception is thrown when new leader election is not necessary.

21. class LeaderNotAvailableException extends RuntimeException

    Thrown when a request is made for partition, but no leader exists for that partition

22. class LogCleaningAbortedException extends RuntimeException

    Thrown when a log cleaning task is requested to be aborted.

23. class MessageSetSizeTooLargeException extends RuntimeException

24. class MessageSizeTooLargeException extends RuntimeException

25. class MessageStreamsExistException extends RuntimeException

    Indicates a createMessageStreams can't be called more thane once

26. class NoBrokersForPartitionException extends RuntimeException

    Thrown when a request is made for broker but no brokers with that topic exist.

27. class NoEpochForPartitionException extends RuntimeException

    Thrown when a get epoch request is made for partition, but no epoch exists for that partition

28. class NoReplicaOnlineException extends RuntimeException

    This exception is thrown by the leader elector in the controller when leader election fails for a partition since all the leader candidate replicas for a partition are offline; the set of candidates may or may not be limited to just the in sync replicas depending upon whether unclean leader election is allowed to occur.

29. class NotAssignedReplicaException extends RuntimeException

30. class NotCoordinatorForConsumerException extends RuntimeException

31. class NotEnoughReplicasAfterAppendException extends RuntimeException

    Number of insync replicas for the partition is lower than min.

32. class NotEnoughReplicasException extends RuntimeException

    Message was rejected because number of insync replicas for the partition is lower than min.

33. class NotLeaderForPartitionException extends RuntimeException

    Thrown when a request is made for partition on a broker that is NOT a leader for that partition

34. case class OffsetAndMetadata(offset: Long, metadata: String = OffsetAndMetadata.NoMetadata, timestamp: Long = -1L) extends Product with Serializable

35. case class OffsetMetadataAndError(offset: Long, metadata: String = OffsetAndMetadata.NoMetadata, error: Short = ErrorMapping.NoError) extends Product with Serializable

36. class OffsetMetadataTooLargeException extends RuntimeException

    Indicates the client has specified offset metadata that exceeds the configured maximum size in bytes

37. class OffsetOutOfRangeException extends RuntimeException

    Indicates the client has requested a range no longer available on the server

38. class OffsetsLoadInProgressException extends RuntimeException

    Indicates that offsets are currently being loaded from disk into the cache so offset fetch requests cannot be satisfied.

39. class QueueFullException extends RuntimeException

40. class ReplicaNotAvailableException extends RuntimeException

    Thrown when a request is made for partition, but no leader exists for that partition

41. class RequestTimedOutException extends RuntimeException

    Thrown when a produce request times out - i.

42. class StateChangeFailedException extends RuntimeException

43. class ThreadShutdownException extends RuntimeException

    An exception that indicates a thread is being shut down normally.

44. case class TopicAndPartition(topic: String, partition: Int) extends Product with Serializable

    Convenience case class since (topic, partition) pairs are ubiquitous.

45. class TopicExistsException extends RuntimeException

46. class UnavailableProducerException extends RuntimeException

    Indicates a producer pool initialization problem

47. class UnknownCodecException extends RuntimeException

    Indicates the client has requested a range no longer available on the server

48. class UnknownException extends RuntimeException

    If we don't know what else it is, call it this

49. class UnknownMagicByteException extends RuntimeException

    Indicates the client has requested a range no longer available on the server

50. class UnknownTopicOrPartitionException extends RuntimeException

    Indicates an unknown topic or a partition id not between 0 and numPartitions-1