Sign in
apache
/
kafka
/
0.8.2
/
.
/
core
/
src
/
main
/
scala
/
kafka
/
common
tree: f13c91038019c4247ddb85b092c328465cdcd3c0 [
path history
]
[
tgz
]
AdminCommandFailedException.scala
AppInfo.scala
BrokerNotAvailableException.scala
ClientIdAndBroker.scala
ClientIdAndTopic.scala
Config.scala
ConsumerCoordinatorNotAvailableException.scala
ConsumerReblanceFailedException.scala
ControllerMovedException.scala
ErrorMapping.scala
FailedToSendMessageException.scala
InvalidConfigException.scala
InvalidMessageSizeException.scala
InvalidOffsetException.scala
InvalidTopicException.scala
KafkaException.scala
KafkaStorageException.scala
LeaderElectionNotNeededException.scala
LeaderNotAvailableException.scala
LogCleaningAbortedException.scala
MessageSetSizeTooLargeException.scala
MessageSizeTooLargeException.scala
MessageStreamsExistException.scala
NoBrokersForPartitionException.scala
NoEpochForPartitionException.scala
NoReplicaOnlineException.scala
NotAssignedReplicaException.scala
NotCoordinatorForConsumerException.scala
NotEnoughReplicasAfterAppendException.scala
NotEnoughReplicasException.scala
NotLeaderForPartitionException.scala
OffsetMetadataAndError.scala
OffsetMetadataTooLargeException.scala
OffsetOutOfRangeException.scala
OffsetsLoadInProgressException.scala
QueueFullException.scala
ReplicaNotAvailableException.scala
RequestTimedOutException.scala
StateChangeFailedException.scala
ThreadShutdownException.scala
Topic.scala
TopicAndPartition.scala
TopicExistsException.scala
UnavailableProducerException.scala
UnknownCodecException.scala
UnknownException.scala
UnknownMagicByteException.scala
UnknownTopicOrPartitionException.scala