登录注册

Jar文件详情内容

kafka-clients-0.10.0.0-sources.jar

所在目录：/org/apache/kafka/kafka-clients/0.10.0.0 查看kafka-clients所有版本文件

组织ID:	org.apache.kafka
项目ID:	kafka-clients
版本:	0.10.0.0
最后修改时间:	2018-07-26 09:18:18
包类型:	java-source (源码)
大小:	541.92KB

Maven引入代码:	`<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.10.0.0</version> <classifier>sources</classifier> <type>java-source</type> </dependency>`
Gradle引入代码:	`org.apache.kafka:kafka-clients:0.10.0.0`
下载Jar包:	kafka-clients-0.10.0.0-sources.jar
Jar包内容:	展开复制 META-INF/MANIFEST.MF LICENSE NOTICE org/apache/kafka/clients/ClientRequest.java org/apache/kafka/clients/ClientResponse.java org/apache/kafka/clients/ClientUtils.java org/apache/kafka/clients/ClusterConnectionStates.java org/apache/kafka/clients/CommonClientConfigs.java org/apache/kafka/clients/ConnectionState.java org/apache/kafka/clients/consumer/CommitFailedException.java org/apache/kafka/clients/consumer/Consumer.java org/apache/kafka/clients/consumer/ConsumerConfig.java org/apache/kafka/clients/consumer/ConsumerInterceptor.java org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java org/apache/kafka/clients/consumer/ConsumerRecord.java org/apache/kafka/clients/consumer/ConsumerRecords.java org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor.java org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java org/apache/kafka/clients/consumer/internals/ConsumerInterceptors.java org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java org/apache/kafka/clients/consumer/internals/DelayedTask.java org/apache/kafka/clients/consumer/internals/DelayedTaskQueue.java org/apache/kafka/clients/consumer/internals/Fetcher.java org/apache/kafka/clients/consumer/internals/Heartbeat.java org/apache/kafka/clients/consumer/internals/NoAvailableBrokersException.java org/apache/kafka/clients/consumer/internals/NoOpConsumerRebalanceListener.java org/apache/kafka/clients/consumer/internals/PartitionAssignor.java org/apache/kafka/clients/consumer/internals/RequestFuture.java org/apache/kafka/clients/consumer/internals/RequestFutureAdapter.java org/apache/kafka/clients/consumer/internals/RequestFutureListener.java org/apache/kafka/clients/consumer/internals/StaleMetadataException.java org/apache/kafka/clients/consumer/internals/SubscriptionState.java org/apache/kafka/clients/consumer/InvalidOffsetException.java org/apache/kafka/clients/consumer/KafkaConsumer.java org/apache/kafka/clients/consumer/MockConsumer.java org/apache/kafka/clients/consumer/NoOffsetForPartitionException.java org/apache/kafka/clients/consumer/OffsetAndMetadata.java org/apache/kafka/clients/consumer/OffsetCommitCallback.java org/apache/kafka/clients/consumer/OffsetOutOfRangeException.java org/apache/kafka/clients/consumer/OffsetResetStrategy.java org/apache/kafka/clients/consumer/RangeAssignor.java org/apache/kafka/clients/consumer/RetriableCommitFailedException.java org/apache/kafka/clients/consumer/RoundRobinAssignor.java org/apache/kafka/clients/InFlightRequests.java org/apache/kafka/clients/KafkaClient.java org/apache/kafka/clients/ManualMetadataUpdater.java org/apache/kafka/clients/Metadata.java org/apache/kafka/clients/MetadataUpdater.java org/apache/kafka/clients/NetworkClient.java org/apache/kafka/clients/producer/BufferExhaustedException.java org/apache/kafka/clients/producer/Callback.java org/apache/kafka/clients/producer/internals/BufferPool.java org/apache/kafka/clients/producer/internals/DefaultPartitioner.java org/apache/kafka/clients/producer/internals/ErrorLoggingCallback.java org/apache/kafka/clients/producer/internals/FutureRecordMetadata.java org/apache/kafka/clients/producer/internals/ProduceRequestResult.java org/apache/kafka/clients/producer/internals/ProducerInterceptors.java org/apache/kafka/clients/producer/internals/RecordAccumulator.java org/apache/kafka/clients/producer/internals/RecordBatch.java org/apache/kafka/clients/producer/internals/Sender.java org/apache/kafka/clients/producer/KafkaProducer.java org/apache/kafka/clients/producer/MockProducer.java org/apache/kafka/clients/producer/Partitioner.java org/apache/kafka/clients/producer/Producer.java org/apache/kafka/clients/producer/ProducerConfig.java org/apache/kafka/clients/producer/ProducerInterceptor.java org/apache/kafka/clients/producer/ProducerRecord.java org/apache/kafka/clients/producer/RecordMetadata.java org/apache/kafka/clients/RequestCompletionHandler.java org/apache/kafka/common/annotation/InterfaceStability.java org/apache/kafka/common/cache/Cache.java org/apache/kafka/common/cache/LRUCache.java org/apache/kafka/common/cache/SynchronizedCache.java org/apache/kafka/common/Cluster.java org/apache/kafka/common/config/AbstractConfig.java org/apache/kafka/common/config/Config.java org/apache/kafka/common/config/ConfigDef.java org/apache/kafka/common/config/ConfigException.java org/apache/kafka/common/config/ConfigValue.java org/apache/kafka/common/config/SaslConfigs.java org/apache/kafka/common/config/SslConfigs.java org/apache/kafka/common/config/types/Password.java org/apache/kafka/common/Configurable.java org/apache/kafka/common/errors/ApiException.java org/apache/kafka/common/errors/AuthenticationException.java org/apache/kafka/common/errors/AuthorizationException.java org/apache/kafka/common/errors/BrokerNotAvailableException.java org/apache/kafka/common/errors/ClusterAuthorizationException.java org/apache/kafka/common/errors/ControllerMovedException.java org/apache/kafka/common/errors/CorruptRecordException.java org/apache/kafka/common/errors/DisconnectException.java org/apache/kafka/common/errors/GroupAuthorizationException.java org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.java org/apache/kafka/common/errors/GroupLoadInProgressException.java org/apache/kafka/common/errors/IllegalGenerationException.java org/apache/kafka/common/errors/IllegalSaslStateException.java org/apache/kafka/common/errors/InconsistentGroupProtocolException.java org/apache/kafka/common/errors/InterruptException.java org/apache/kafka/common/errors/InvalidCommitOffsetSizeException.java org/apache/kafka/common/errors/InvalidFetchSizeException.java org/apache/kafka/common/errors/InvalidGroupIdException.java org/apache/kafka/common/errors/InvalidMetadataException.java org/apache/kafka/common/errors/InvalidOffsetException.java org/apache/kafka/common/errors/InvalidRequiredAcksException.java org/apache/kafka/common/errors/InvalidSessionTimeoutException.java org/apache/kafka/common/errors/InvalidTimestampException.java org/apache/kafka/common/errors/InvalidTopicException.java org/apache/kafka/common/errors/LeaderNotAvailableException.java org/apache/kafka/common/errors/NetworkException.java org/apache/kafka/common/errors/NotCoordinatorForGroupException.java org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.java org/apache/kafka/common/errors/NotEnoughReplicasException.java org/apache/kafka/common/errors/NotLeaderForPartitionException.java org/apache/kafka/common/errors/OffsetMetadataTooLarge.java org/apache/kafka/common/errors/OffsetOutOfRangeException.java org/apache/kafka/common/errors/RebalanceInProgressException.java org/apache/kafka/common/errors/RecordBatchTooLargeException.java org/apache/kafka/common/errors/RecordTooLargeException.java org/apache/kafka/common/errors/ReplicaNotAvailableException.java org/apache/kafka/common/errors/RetriableException.java org/apache/kafka/common/errors/SerializationException.java org/apache/kafka/common/errors/TimeoutException.java org/apache/kafka/common/errors/TopicAuthorizationException.java org/apache/kafka/common/errors/UnknownMemberIdException.java org/apache/kafka/common/errors/UnknownServerException.java org/apache/kafka/common/errors/UnknownTopicOrPartitionException.java org/apache/kafka/common/errors/UnsupportedSaslMechanismException.java org/apache/kafka/common/errors/UnsupportedVersionException.java org/apache/kafka/common/errors/WakeupException.java org/apache/kafka/common/internals/TopicConstants.java org/apache/kafka/common/KafkaException.java org/apache/kafka/common/Metric.java org/apache/kafka/common/MetricName.java org/apache/kafka/common/metrics/CompoundStat.java org/apache/kafka/common/metrics/JmxReporter.java org/apache/kafka/common/metrics/KafkaMetric.java org/apache/kafka/common/metrics/Measurable.java org/apache/kafka/common/metrics/MeasurableStat.java org/apache/kafka/common/metrics/MetricConfig.java org/apache/kafka/common/metrics/Metrics.java org/apache/kafka/common/metrics/MetricsReporter.java org/apache/kafka/common/metrics/Quota.java org/apache/kafka/common/metrics/QuotaViolationException.java org/apache/kafka/common/metrics/Sensor.java org/apache/kafka/common/metrics/Stat.java org/apache/kafka/common/metrics/stats/Avg.java org/apache/kafka/common/metrics/stats/Count.java org/apache/kafka/common/metrics/stats/Histogram.java org/apache/kafka/common/metrics/stats/Max.java org/apache/kafka/common/metrics/stats/Min.java org/apache/kafka/common/metrics/stats/Percentile.java org/apache/kafka/common/metrics/stats/Percentiles.java org/apache/kafka/common/metrics/stats/Rate.java org/apache/kafka/common/metrics/stats/SampledStat.java org/apache/kafka/common/metrics/stats/Total.java org/apache/kafka/common/network/Authenticator.java org/apache/kafka/common/network/ByteBufferReceive.java org/apache/kafka/common/network/ByteBufferSend.java org/apache/kafka/common/network/ChannelBuilder.java org/apache/kafka/common/network/ChannelBuilders.java org/apache/kafka/common/network/DefaultAuthenticator.java org/apache/kafka/common/network/InvalidReceiveException.java org/apache/kafka/common/network/KafkaChannel.java org/apache/kafka/common/network/LoginType.java org/apache/kafka/common/network/Mode.java org/apache/kafka/common/network/MultiSend.java org/apache/kafka/common/network/NetworkReceive.java org/apache/kafka/common/network/NetworkSend.java org/apache/kafka/common/network/PlaintextChannelBuilder.java org/apache/kafka/common/network/PlaintextTransportLayer.java org/apache/kafka/common/network/Receive.java org/apache/kafka/common/network/SaslChannelBuilder.java org/apache/kafka/common/network/Selectable.java org/apache/kafka/common/network/Selector.java org/apache/kafka/common/network/Send.java org/apache/kafka/common/network/SslChannelBuilder.java org/apache/kafka/common/network/SslTransportLayer.java org/apache/kafka/common/network/TransportLayer.java org/apache/kafka/common/Node.java org/apache/kafka/common/PartitionInfo.java org/apache/kafka/common/protocol/ApiKeys.java org/apache/kafka/common/protocol/Errors.java org/apache/kafka/common/protocol/Protocol.java org/apache/kafka/common/protocol/ProtoUtils.java org/apache/kafka/common/protocol/SecurityProtocol.java org/apache/kafka/common/protocol/types/ArrayOf.java org/apache/kafka/common/protocol/types/Field.java org/apache/kafka/common/protocol/types/Schema.java org/apache/kafka/common/protocol/types/SchemaException.java org/apache/kafka/common/protocol/types/Struct.java org/apache/kafka/common/protocol/types/Type.java org/apache/kafka/common/record/ByteBufferInputStream.java org/apache/kafka/common/record/ByteBufferOutputStream.java org/apache/kafka/common/record/CompressionType.java org/apache/kafka/common/record/Compressor.java org/apache/kafka/common/record/InvalidRecordException.java org/apache/kafka/common/record/KafkaLZ4BlockInputStream.java org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java org/apache/kafka/common/record/LogEntry.java org/apache/kafka/common/record/MemoryRecords.java org/apache/kafka/common/record/Record.java org/apache/kafka/common/record/Records.java org/apache/kafka/common/record/TimestampType.java org/apache/kafka/common/requests/AbstractRequest.java org/apache/kafka/common/requests/AbstractRequestResponse.java org/apache/kafka/common/requests/ApiVersionsRequest.java org/apache/kafka/common/requests/ApiVersionsResponse.java org/apache/kafka/common/requests/ControlledShutdownRequest.java org/apache/kafka/common/requests/ControlledShutdownResponse.java org/apache/kafka/common/requests/DescribeGroupsRequest.java org/apache/kafka/common/requests/DescribeGroupsResponse.java org/apache/kafka/common/requests/FetchRequest.java org/apache/kafka/common/requests/FetchResponse.java org/apache/kafka/common/requests/GroupCoordinatorRequest.java org/apache/kafka/common/requests/GroupCoordinatorResponse.java org/apache/kafka/common/requests/HeartbeatRequest.java org/apache/kafka/common/requests/HeartbeatResponse.java org/apache/kafka/common/requests/JoinGroupRequest.java org/apache/kafka/common/requests/JoinGroupResponse.java org/apache/kafka/common/requests/LeaderAndIsrRequest.java org/apache/kafka/common/requests/LeaderAndIsrResponse.java org/apache/kafka/common/requests/LeaveGroupRequest.java org/apache/kafka/common/requests/LeaveGroupResponse.java org/apache/kafka/common/requests/ListGroupsRequest.java org/apache/kafka/common/requests/ListGroupsResponse.java org/apache/kafka/common/requests/ListOffsetRequest.java org/apache/kafka/common/requests/ListOffsetResponse.java org/apache/kafka/common/requests/MetadataRequest.java org/apache/kafka/common/requests/MetadataResponse.java org/apache/kafka/common/requests/OffsetCommitRequest.java org/apache/kafka/common/requests/OffsetCommitResponse.java org/apache/kafka/common/requests/OffsetFetchRequest.java org/apache/kafka/common/requests/OffsetFetchResponse.java org/apache/kafka/common/requests/ProduceRequest.java org/apache/kafka/common/requests/ProduceResponse.java org/apache/kafka/common/requests/RequestHeader.java org/apache/kafka/common/requests/RequestSend.java org/apache/kafka/common/requests/ResponseHeader.java org/apache/kafka/common/requests/ResponseSend.java org/apache/kafka/common/requests/SaslHandshakeRequest.java org/apache/kafka/common/requests/SaslHandshakeResponse.java org/apache/kafka/common/requests/StopReplicaRequest.java org/apache/kafka/common/requests/StopReplicaResponse.java #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	无