kafka

common

package common

Visibility
  1. Public
  2. All

Type Members

  1. class ConsumerRebalanceFailedException extends RuntimeException

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

  2. class InvalidConfigException extends RuntimeException

    Indicates that the given config parameter has invalid value

  3. class InvalidMessageSizeException extends RuntimeException

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

  4. class InvalidPartitionException extends RuntimeException

    Indicates that the partition id is not between 0 and numPartitions-1

  5. class InvalidTopicException extends RuntimeException

  6. class MessageSizeTooLargeException extends RuntimeException

  7. class NoBrokersForPartitionException extends RuntimeException

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

  8. class OffsetOutOfRangeException extends RuntimeException

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

  9. class UnavailableProducerException extends RuntimeException

    Indicates a producer pool initialization problem

  10. class UnknownCodecException extends RuntimeException

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

  11. class UnknownException extends RuntimeException

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

  12. class UnknownMagicByteException extends RuntimeException

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

Value Members

  1. object ErrorMapping extends AnyRef

    A bi-directional mapping between error codes and exceptions x