首页
•
知识库
•
资源下载
•
在线工具
•
索引
•
Jar
•
Java
•
关键词
•
常用命令
•
口令服务
A
B
C
D
E
F
G
H
I
J
K
L
M
N
O
P
Q
R
S
T
U
V
W
X
Y
Z
>
kafka_2.9.1-0.8.2-beta-scaladoc.jar
标签:kafka_2.9.1-0.8.2-beta-scaladoc.jar,kafka_2.9.1,0.8.2,beta,scaladoc,jar包下载,依赖包
云盘下载
Group
Artifact
Version
Download
>> Package Explorer
>>> Java Explorer
<2.6.8>
Repositories
index
index-a.html
index-b.html
index-c.html
index-d.html
index-e.html
index-f.html
index-g.html
index-h.html
index-i.html
index-j.html
index-k.html
index-l.html
index-m.html
index-n.html
index-o.html
index-p.html
index-q.html
index-r.html
index-s.html
index-t.html
index-u.html
index-v.html
index-w.html
index-z.html
index.html
index.js
kafka
admin
AdminOperationException.html
AdminUtils$.html
package.html
PreferredReplicaLeaderElectionCommand$.html
PreferredReplicaLeaderElectionCommand.html
ReassignmentCompleted$.html
ReassignmentFailed$.html
ReassignmentInProgress$.html
ReassignmentStatus.html
ReassignPartitionsCommand$$ReassignPartitionsCommandOptions.html
ReassignPartitionsCommand$.html
ReassignPartitionsCommand.html
TopicCommand$$TopicCommandOptions.html
TopicCommand$.html
api
ApiUtils$.html
ConsumerMetadataRequest$.html
ConsumerMetadataRequest.html
ConsumerMetadataResponse$.html
ConsumerMetadataResponse.html
ControlledShutdownRequest$.html
ControlledShutdownRequest.html
ControlledShutdownResponse$.html
ControlledShutdownResponse.html
FetchRequest$.html
FetchRequest.html
FetchRequestBuilder.html
FetchResponse$.html
FetchResponse.html
FetchResponsePartitionData$.html
FetchResponsePartitionData.html
FetchResponseSend.html
HeartbeatRequestAndHeader$.html
HeartbeatRequestAndHeader.html
HeartbeatResponseAndHeader$.html
HeartbeatResponseAndHeader.html
JoinGroupRequestAndHeader$.html
JoinGroupRequestAndHeader.html
JoinGroupResponseAndHeader$.html
JoinGroupResponseAndHeader.html
LeaderAndIsr$.html
LeaderAndIsr.html
LeaderAndIsrRequest$.html
LeaderAndIsrRequest.html
LeaderAndIsrResponse$.html
LeaderAndIsrResponse.html
OffsetCommitRequest$.html
OffsetCommitRequest.html
OffsetCommitResponse$.html
OffsetCommitResponse.html
OffsetFetchRequest$.html
OffsetFetchRequest.html
OffsetFetchResponse$.html
OffsetFetchResponse.html
OffsetRequest$.html
OffsetRequest.html
OffsetResponse$.html
OffsetResponse.html
package.html
PartitionDataSend.html
PartitionFetchInfo.html
PartitionMetadata$.html
PartitionMetadata.html
PartitionOffsetRequestInfo.html
PartitionOffsetsResponse.html
PartitionStateInfo$.html
PartitionStateInfo.html
ProducerRequest$.html
ProducerRequest.html
ProducerResponse$.html
ProducerResponse.html
ProducerResponseStatus.html
Request$.html
RequestKeys$.html
RequestOrResponse.html
StopReplicaRequest$.html
StopReplicaRequest.html
StopReplicaResponse$.html
StopReplicaResponse.html
TopicData$.html
TopicData.html
TopicDataSend.html
TopicMetadata$.html
TopicMetadata.html
TopicMetadataRequest$.html
TopicMetadataRequest.html
TopicMetadataResponse$.html
TopicMetadataResponse.html
UpdateMetadataRequest$.html
UpdateMetadataRequest.html
UpdateMetadataResponse$.html
UpdateMetadataResponse.html
client
ClientUtils$.html
package.html
cluster
Broker$.html
Broker.html
package.html
Partition.html
Replica.html
common
AdminCommandFailedException.html
BrokerNotAvailableException.html
ClientIdAndBroker.html
ClientIdAndTopic.html
Config.html
ConsumerCoordinatorNotAvailableException.html
ConsumerRebalanceFailedException.html
ControllerMovedException.html
ErrorMapping$.html
FailedToSendMessageException.html
InvalidConfigException.html
InvalidMessageSizeException.html
InvalidOffsetException.html
InvalidTopicException.html
KafkaException.html
KafkaStorageException.html
LeaderElectionNotNeededException.html
LeaderNotAvailableException.html
LogCleaningAbortedException.html
MessageSetSizeTooLargeException.html
MessageSizeTooLargeException.html
MessageStreamsExistException.html
NoBrokersForPartitionException.html
NoEpochForPartitionException.html
NoReplicaOnlineException.html
NotAssignedReplicaException.html
NotCoordinatorForConsumerException.html
NotEnoughReplicasAfterAppendException.html
NotEnoughReplicasException.html
NotLeaderForPartitionException.html
OffsetAndMetadata$.html
OffsetAndMetadata.html
OffsetMetadataAndError$.html
OffsetMetadataAndError.html
OffsetMetadataTooLargeException.html
OffsetOutOfRangeException.html
OffsetsLoadInProgressException.html
package.html
QueueFullException.html
ReplicaNotAvailableException.html
RequestTimedOutException.html
StateChangeFailedException.html
ThreadShutdownException.html
Topic$.html
TopicAndPartition.html
TopicExistsException.html
UnavailableProducerException.html
UnknownCodecException.html
UnknownException.html
UnknownMagicByteException.html
UnknownTopicOrPartitionException.html
consumer
AssignmentContext.html
Blacklist.html
Consumer$.html
ConsumerConfig$.html
ConsumerConfig.html
ConsumerConnector.html
ConsumerFetcherManager.html
ConsumerFetcherThread.html
ConsumerIterator.html
ConsumerThreadId.html
ConsumerTimeoutException.html
ConsumerTopicMetrics.html
ConsumerTopicStats.html
ConsumerTopicStatsRegistry$.html
FetchedDataChunk.html
FetchRequestAndResponseMetrics.html
FetchRequestAndResponseStats.html
FetchRequestAndResponseStatsRegistry$.html
KafkaStream.html
package.html
PartitionAssignor$.html
PartitionAssignor.html
PartitionTopicInfo$.html
PartitionTopicInfo.html
RangeAssignor.html
RoundRobinAssignor.html
SimpleConsumer.html
TopicEventHandler.html
TopicFilter.html
Whitelist.html
ZookeeperTopicEventWatcher$ZkSessionExpireListener.html
ZookeeperTopicEventWatcher$ZkTopicEventListener.html
ZookeeperTopicEventWatcher.html
controller
Callbacks$$CallbackBuilder.html
Callbacks$.html
Callbacks.html
ControlledShutdownLeaderSelector.html
ControllerBrokerRequestBatch.html
ControllerBrokerStateInfo.html
ControllerChannelManager.html
ControllerContext.html
ControllerStats$.html
KafkaController$$StateChangeLogger.html
KafkaController$.html
KafkaController$SessionExpirationListener.html
KafkaController.html
LeaderIsrAndControllerEpoch.html
NewPartition$.html
NewReplica$.html
NonExistentPartition$.html
NonExistentReplica$.html
NoOpLeaderSelector.html
OfflinePartition$.html
OfflinePartitionLeaderSelector.html
OfflineReplica$.html
OnlinePartition$.html
OnlineReplica$.html
package.html
PartitionAndReplica.html
PartitionLeaderSelector.html
PartitionsReassignedListener.html
PartitionState.html
PartitionStateMachine$AddPartitionsListener.html
PartitionStateMachine$DeleteTopicsListener.html
PartitionStateMachine$TopicChangeListener.html
PartitionStateMachine.html
PreferredReplicaElectionListener.html
PreferredReplicaPartitionLeaderSelector.html
ReassignedPartitionLeaderSelector.html
ReassignedPartitionsContext.html
ReassignedPartitionsIsrChangeListener.html
ReplicaDeletionIneligible$.html
ReplicaDeletionStarted$.html
ReplicaDeletionSuccessful$.html
ReplicaState.html
ReplicaStateMachine$BrokerChangeListener.html
ReplicaStateMachine.html
RequestSendThread.html
StopReplicaRequestInfo.html
TopicDeletionManager$DeleteTopicsThread.html
TopicDeletionManager.html
javaapi
consumer
ConsumerConnector.html
package.html
SimpleConsumer.html
ConsumerMetadataResponse.html
FetchRequest.html
FetchResponse.html
message
ByteBufferMessageSet.html
MessageSet.html
package.html
OffsetCommitRequest.html
OffsetCommitResponse.html
OffsetFetchRequest.html
OffsetFetchResponse.html
OffsetRequest.html
OffsetResponse.html
package.html
PartitionMetadata.html
producer
package.html
Producer.html
TopicMetadata.html
TopicMetadataRequest.html
TopicMetadataResponse.html
Kafka$.html
log
CleanerConfig.html
Defaults$.html
FileMessageSet.html
Log$.html
Log$LogAppendInfo.html
Log.html
LogCleaner.html
LogConfig$.html
LogConfig.html
LogFlushStats$.html
LogManager.html
LogSegment.html
OffsetIndex.html
OffsetMap.html
OffsetPosition.html
package.html
SkimpyOffsetMap.html
message
ByteBufferBackedInputStream.html
ByteBufferMessageSet$.html
ByteBufferMessageSet.html
CompressionCodec$.html
CompressionCodec.html
CompressionFactory$.html
DefaultCompressionCodec$.html
GZIPCompressionCodec$.html
InvalidMessageException.html
LZ4CompressionCodec$.html
Message$.html
Message.html
MessageAndMetadata.html
MessageAndOffset.html
MessageLengthException.html
MessageSet$.html
MessageSet.html
NoCompressionCodec$.html
package.html
SnappyCompressionCodec$.html
metrics
KafkaMetricsConfig.html
KafkaMetricsGroup$.html
KafkaMetricsGroup.html
KafkaMetricsReporter$.html
KafkaMetricsReporter.html
KafkaMetricsReporterMBean.html
KafkaTimer.html
package.html
network
BlockingChannel$.html
BlockingChannel.html
ConnectionConfig.html
ConnectionQuotas.html
InvalidRequestException.html
MultiSend.html
package.html
Receive.html
RequestChannel$$CloseConnectionAction$.html
RequestChannel$$NoOpAction$.html
RequestChannel$$Request.html
RequestChannel$$Response.html
RequestChannel$$ResponseAction.html
RequestChannel$$SendAction$.html
RequestChannel$.html
RequestChannel.html
RequestMetrics$.html
RequestMetrics.html
Send.html
SocketServer.html
TooManyConnectionsException.html
package.html
producer
async
AsyncProducerConfig.html
DefaultEventHandler.html
EventHandler.html
IllegalQueueStateException.html
MissingConfigException.html
package.html
ProducerSendThread.html
BaseProducer.html
BrokerPartitionInfo.html
ByteArrayPartitioner.html
DefaultPartitioner.html
KafkaLog4jAppender.html
KeyedMessage.html
NewShinyProducer.html
OldProducer.html
package.html
PartitionAndLeader.html
Partitioner.html
Producer.html
ProducerClosedException.html
ProducerConfig$.html
ProducerConfig.html
ProducerPool$.html
ProducerPool.html
ProducerRequestMetrics.html
ProducerRequestStats.html
ProducerRequestStatsRegistry$.html
ProducerStats.html
ProducerStatsRegistry$.html
ProducerTopicMetrics.html
ProducerTopicStats.html
ProducerTopicStatsRegistry$.html
SyncProducer$.html
SyncProducer.html
SyncProducerConfig$.html
SyncProducerConfig.html
SyncProducerConfigShared.html
serializer
Decoder.html
DefaultDecoder.html
DefaultEncoder.html
Encoder.html
NullEncoder.html
package.html
StringDecoder.html
StringEncoder.html
server
AbstractFetcherManager.html
AbstractFetcherThread.html
BrokerAndFetcherId.html
BrokerAndInitialOffset.html
BrokerShuttingDown$.html
BrokerState.html
BrokerStates.html
BrokerTopicMetrics.html
BrokerTopicStats$.html
ClientIdBrokerTopicPartition.html
DelayedFetch.html
DelayedProduce.html
DelayedProduceResponseStatus.html
DelayedRequest.html
DelayedRequestKey$.html
DelayedRequestKey.html
FetchDataInfo.html
FetcherLagMetrics.html
FetcherLagStats.html
FetcherStats.html
FetchRequestPurgatory.html
GroupTopicPartition.html
KafkaApis$ProduceResult.html
KafkaApis.html
KafkaConfig.html
KafkaHealthcheck$SessionExpireListener.html
KafkaHealthcheck.html
KafkaRequestHandler.html
KafkaRequestHandlerPool.html
KafkaServer.html
KafkaServerStartable.html
LeaderElector.html
LogOffsetMetadata$$OffsetOrdering.html
LogOffsetMetadata$.html
LogOffsetMetadata.html
NotRunning$.html
OffsetCheckpoint.html
OffsetManager$$OffsetsMessageFormatter.html
OffsetManager$.html
OffsetManager.html
OffsetManagerConfig$.html
OffsetManagerConfig.html
package.html
PartitionDataAndOffset.html
PendingControlledShutdown$.html
ProducerRequestPurgatory.html
RecoveringFromUncleanShutdown$.html
ReplicaFetcherManager.html
ReplicaFetcherThread.html
ReplicaManager$.html
ReplicaManager.html
RequestPurgatory.html
RunningAsBroker$.html
RunningAsController$.html
Starting$.html
TopicConfigManager$ConfigChangeListener$.html
TopicConfigManager.html
TopicPartitionRequestKey.html
ZookeeperLeaderElector$LeaderChangeListener.html
ZookeeperLeaderElector.html
tools
ChecksumMessageFormatter.html
ConsoleConsumer$.html
ConsoleProducer$$LineMessageReader.html
ConsoleProducer$$MessageReader.html
ConsoleProducer$$ProducerConfig.html
ConsoleProducer$.html
ConsumerOffsetChecker$.html
ConsumerPerformance$$ConsumerPerfConfig.html
ConsumerPerformance$$ConsumerPerfThread.html
ConsumerPerformance$.html
DefaultMessageFormatter.html
DumpLogSegments$.html
ExportZkOffsets$.html
GetOffsetShell$.html
ImportZkOffsets$.html
JmxTool$.html
KafkaMigrationTool$.html
KafkaMigrationTool.html
MessageFormatter.html
MirrorMaker$$ConsumerThread.html
MirrorMaker$$DataChannel.html
MirrorMaker$$ProducerThread.html
MirrorMaker$.html
NoOpMessageFormatter.html
package.html
PerfConfig.html
ProducerPerformance$$ProducerPerfConfig.html
ProducerPerformance$$ProducerThread.html
ProducerPerformance$.html
ReplayLogProducer$$Config.html
ReplayLogProducer$$ZKConsumerThread.html
ReplayLogProducer$.html
ReplicaVerificationTool$.html
SimpleConsumerPerformance$$ConsumerPerfConfig.html
SimpleConsumerPerformance$.html
SimpleConsumerShell$.html
StateChangeLogMerger$$dateBasedOrdering$.html
StateChangeLogMerger$$LineIterator.html
StateChangeLogMerger$.html
TestEndToEndLatency$.html
TestLogCleaning$.html
TestRecord.html
UpdateOffsetsInZK$.html
VerifyConsumerRebalance$.html
ZooKeeperMainWrapper$.html
ZooKeeperMainWrapper.html
utils
CommandLineUtils$.html
Crc32.html
DelayedItem.html
DONE$.html
FAILED$.html
FileLock.html
immutable.html
IteratorTemplate.html
Json$.html
KafkaScheduler.html
Log4jController$.html
Logging.html
Mx4jLoader$.html
nonthreadsafe.html
NOT_READY$.html
Os$.html
package.html
Pool.html
READY$.html
ReplicationUtils$.html
Scheduler.html
ShutdownableThread.html
State.html
SystemTime$.html
threadsafe.html
Throttler$.html
Throttler.html
Time$.html
Time.html
ToolsUtils$.html
Utils$.html
VerifiableProperties.html
ZKConfig.html
ZKGroupDirs.html
ZKGroupTopicDirs.html
ZKStringSerializer$.html
ZkUtils$.html
lib
arrow-down.png
arrow-right.png
class.png
class_big.png
class_diagram.png
class_to_object_big.png
constructorsbg.gif
conversionbg.gif
defbg-blue.gif
defbg-green.gif
diagrams.css
diagrams.js
filterbg.gif
filterboxbarbg.gif
filterboxbarbg.png
filterboxbg.gif
filter_box_left.png
filter_box_left2.gif
filter_box_right.png
fullcommenttopbg.gif
index.css
index.js
jquery-ui.js
jquery.js
jquery.layout.js
modernizr.custom.js
navigation-li-a.png
navigation-li.png
object.png
object_big.png
object_diagram.png
object_to_class_big.png
object_to_trait_big.png
object_to_type_big.png
ownderbg2.gif
ownerbg.gif
ownerbg2.gif
package.png
packagesbg.gif
package_big.png
permalink.png
ref-index.css
remove.png
rootdoc.txt
scheduler.js
selected-implicits.png
selected-right-implicits.png
selected-right.png
selected.png
selected2-right.png
selected2.png
signaturebg.gif
signaturebg2.gif
template.css
template.js
tools.tooltip.js
trait.png
trait_big.png
trait_diagram.png
trait_to_object_big.png
type.png
typebg.gif
type_big.png
type_diagram.png
type_to_object_big.png
unselected.png
valuemembersbg.gif
LICENSE
META-INF
MANIFEST.MF
NOTICE
package.html