登录注册

Jar文件详情内容

kafka-clients-0.10.2.2-sources.jar

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

组织ID:	org.apache.kafka
项目ID:	kafka-clients
版本:	0.10.2.2
最后修改时间:	2018-08-03 10:33:45
包类型:	java-source (源码)
大小:	654.08KB

Maven引入代码:	`<dependency> <groupId>org.apache.kafka</groupId> <artifactId>kafka-clients</artifactId> <version>0.10.2.2</version> <classifier>sources</classifier> <type>java-source</type> </dependency>`
Gradle引入代码:	`org.apache.kafka:kafka-clients:0.10.2.2`
下载Jar包:	kafka-clients-0.10.2.2-sources.jar
Jar包内容:	展开复制 META-INF/MANIFEST.MF LICENSE NOTICE org/apache/kafka/clients/RequestCompletionHandler.java org/apache/kafka/clients/producer/BufferExhaustedException.java org/apache/kafka/clients/producer/RecordMetadata.java org/apache/kafka/clients/producer/ProducerInterceptor.java org/apache/kafka/clients/producer/MockProducer.java org/apache/kafka/clients/producer/internals/ProduceRequestResult.java org/apache/kafka/clients/producer/internals/DefaultPartitioner.java org/apache/kafka/clients/producer/internals/RecordBatch.java org/apache/kafka/clients/producer/internals/BufferPool.java org/apache/kafka/clients/producer/internals/Sender.java org/apache/kafka/clients/producer/internals/RecordAccumulator.java org/apache/kafka/clients/producer/internals/FutureRecordMetadata.java org/apache/kafka/clients/producer/internals/ErrorLoggingCallback.java org/apache/kafka/clients/producer/internals/ProducerInterceptors.java org/apache/kafka/clients/producer/Callback.java org/apache/kafka/clients/producer/Producer.java org/apache/kafka/clients/producer/ProducerRecord.java org/apache/kafka/clients/producer/Partitioner.java org/apache/kafka/clients/producer/KafkaProducer.java org/apache/kafka/clients/producer/ProducerConfig.java org/apache/kafka/clients/InFlightRequests.java org/apache/kafka/clients/ClientUtils.java org/apache/kafka/clients/CommonClientConfigs.java org/apache/kafka/clients/ClientRequest.java org/apache/kafka/clients/NodeApiVersions.java org/apache/kafka/clients/ClusterConnectionStates.java org/apache/kafka/clients/ManualMetadataUpdater.java org/apache/kafka/clients/MetadataUpdater.java org/apache/kafka/clients/Metadata.java org/apache/kafka/clients/ConnectionState.java org/apache/kafka/clients/NetworkClient.java org/apache/kafka/clients/consumer/OffsetAndTimestamp.java org/apache/kafka/clients/consumer/ConsumerInterceptor.java org/apache/kafka/clients/consumer/RangeAssignor.java org/apache/kafka/clients/consumer/RoundRobinAssignor.java org/apache/kafka/clients/consumer/MockConsumer.java org/apache/kafka/clients/consumer/ConsumerRecords.java org/apache/kafka/clients/consumer/Consumer.java org/apache/kafka/clients/consumer/internals/AbstractPartitionAssignor.java org/apache/kafka/clients/consumer/internals/ConsumerProtocol.java org/apache/kafka/clients/consumer/internals/NoAvailableBrokersException.java org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java org/apache/kafka/clients/consumer/internals/NoOpConsumerRebalanceListener.java org/apache/kafka/clients/consumer/internals/SubscriptionState.java org/apache/kafka/clients/consumer/internals/RequestFutureAdapter.java org/apache/kafka/clients/consumer/internals/StaleMetadataException.java org/apache/kafka/clients/consumer/internals/Fetcher.java org/apache/kafka/clients/consumer/internals/Heartbeat.java org/apache/kafka/clients/consumer/internals/AbstractCoordinator.java org/apache/kafka/clients/consumer/internals/RequestFuture.java org/apache/kafka/clients/consumer/internals/RequestFutureListener.java org/apache/kafka/clients/consumer/internals/ConsumerNetworkClient.java org/apache/kafka/clients/consumer/internals/PartitionAssignor.java org/apache/kafka/clients/consumer/internals/ConsumerInterceptors.java org/apache/kafka/clients/consumer/ConsumerRecord.java org/apache/kafka/clients/consumer/RetriableCommitFailedException.java org/apache/kafka/clients/consumer/OffsetCommitCallback.java org/apache/kafka/clients/consumer/NoOffsetForPartitionException.java org/apache/kafka/clients/consumer/OffsetResetStrategy.java org/apache/kafka/clients/consumer/OffsetOutOfRangeException.java org/apache/kafka/clients/consumer/OffsetAndMetadata.java org/apache/kafka/clients/consumer/InvalidOffsetException.java org/apache/kafka/clients/consumer/KafkaConsumer.java org/apache/kafka/clients/consumer/CommitFailedException.java org/apache/kafka/clients/consumer/ConsumerRebalanceListener.java org/apache/kafka/clients/consumer/ConsumerConfig.java org/apache/kafka/clients/KafkaClient.java org/apache/kafka/clients/ClientResponse.java org/apache/kafka/server/policy/CreateTopicPolicy.java org/apache/kafka/common/metrics/MeasurableStat.java org/apache/kafka/common/metrics/MetricsReporter.java org/apache/kafka/common/metrics/QuotaViolationException.java org/apache/kafka/common/metrics/MetricConfig.java org/apache/kafka/common/metrics/Stat.java org/apache/kafka/common/metrics/KafkaMetric.java org/apache/kafka/common/metrics/JmxReporter.java org/apache/kafka/common/metrics/Measurable.java org/apache/kafka/common/metrics/CompoundStat.java org/apache/kafka/common/metrics/stats/Percentiles.java org/apache/kafka/common/metrics/stats/Percentile.java org/apache/kafka/common/metrics/stats/Avg.java org/apache/kafka/common/metrics/stats/Count.java org/apache/kafka/common/metrics/stats/SimpleRate.java org/apache/kafka/common/metrics/stats/Max.java org/apache/kafka/common/metrics/stats/Min.java org/apache/kafka/common/metrics/stats/Rate.java org/apache/kafka/common/metrics/stats/SampledStat.java org/apache/kafka/common/metrics/stats/Value.java org/apache/kafka/common/metrics/stats/Histogram.java org/apache/kafka/common/metrics/stats/Total.java org/apache/kafka/common/metrics/Quota.java org/apache/kafka/common/metrics/Sensor.java org/apache/kafka/common/metrics/Metrics.java org/apache/kafka/common/PartitionInfo.java org/apache/kafka/common/Node.java org/apache/kafka/common/MetricName.java org/apache/kafka/common/ClusterResource.java org/apache/kafka/common/record/ByteBufferOutputStream.java org/apache/kafka/common/record/AbstractRecords.java org/apache/kafka/common/record/MemoryRecordsBuilder.java org/apache/kafka/common/record/FileLogInputStream.java org/apache/kafka/common/record/KafkaLZ4BlockInputStream.java org/apache/kafka/common/record/Records.java org/apache/kafka/common/record/RecordsIterator.java org/apache/kafka/common/record/InvalidRecordException.java org/apache/kafka/common/record/KafkaLZ4BlockOutputStream.java org/apache/kafka/common/record/LogEntry.java org/apache/kafka/common/record/ByteBufferLogInputStream.java org/apache/kafka/common/record/CompressionType.java org/apache/kafka/common/record/TimestampType.java org/apache/kafka/common/record/LogInputStream.java org/apache/kafka/common/record/FileRecords.java org/apache/kafka/common/record/MemoryRecords.java org/apache/kafka/common/record/Record.java org/apache/kafka/common/record/ByteBufferInputStream.java org/apache/kafka/common/record/BufferSupplier.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/config/SaslConfigs.java org/apache/kafka/common/config/types/Password.java org/apache/kafka/common/config/ConfigDef.java org/apache/kafka/common/config/ConfigValue.java org/apache/kafka/common/config/SslConfigs.java org/apache/kafka/common/config/ConfigException.java org/apache/kafka/common/config/Config.java org/apache/kafka/common/config/AbstractConfig.java org/apache/kafka/common/security/kerberos/KerberosShortNamer.java org/apache/kafka/common/security/kerberos/NoMatchingRule.java org/apache/kafka/common/security/kerberos/KerberosLogin.java org/apache/kafka/common/security/kerberos/BadFormatString.java org/apache/kafka/common/security/kerberos/KerberosName.java org/apache/kafka/common/security/kerberos/KerberosRule.java org/apache/kafka/common/security/ssl/SslFactory.java org/apache/kafka/common/security/JaasConfig.java org/apache/kafka/common/security/auth/KafkaPrincipal.java org/apache/kafka/common/security/auth/PrincipalBuilder.java org/apache/kafka/common/security/auth/Login.java org/apache/kafka/common/security/auth/DefaultPrincipalBuilder.java org/apache/kafka/common/security/auth/AuthCallbackHandler.java org/apache/kafka/common/security/plain/PlainSaslServer.java org/apache/kafka/common/security/plain/PlainLoginModule.java org/apache/kafka/common/security/plain/PlainSaslServerProvider.java org/apache/kafka/common/security/JaasUtils.java org/apache/kafka/common/security/scram/ScramCredentialCallback.java org/apache/kafka/common/security/scram/ScramMessages.java org/apache/kafka/common/security/scram/ScramSaslServer.java org/apache/kafka/common/security/scram/ScramLoginModule.java org/apache/kafka/common/security/scram/ScramCredential.java org/apache/kafka/common/security/scram/ScramCredentialUtils.java org/apache/kafka/common/security/scram/ScramFormatter.java org/apache/kafka/common/security/scram/ScramMechanism.java org/apache/kafka/common/security/scram/ScramServerCallbackHandler.java org/apache/kafka/common/security/scram/ScramSaslServerProvider.java org/apache/kafka/common/security/scram/ScramSaslClientProvider.java org/apache/kafka/common/security/scram/ScramSaslClient.java org/apache/kafka/common/security/authenticator/SaslServerAuthenticator.java org/apache/kafka/common/security/authenticator/DefaultLogin.java org/apache/kafka/common/security/authenticator/SaslClientCallbackHandler.java org/apache/kafka/common/security/authenticator/SaslClientAuthenticator.java org/apache/kafka/common/security/authenticator/LoginManager.java org/apache/kafka/common/security/authenticator/SaslServerCallbackHandler.java org/apache/kafka/common/security/authenticator/AbstractLogin.java org/apache/kafka/common/security/authenticator/CredentialCache.java org/apache/kafka/common/serialization/ByteArraySerializer.java org/apache/kafka/common/serialization/BytesDeserializer.java org/apache/kafka/common/serialization/Deserializer.java org/apache/kafka/common/serialization/Serde.java org/apache/kafka/common/serialization/DoubleDeserializer.java org/apache/kafka/common/serialization/ByteBufferSerializer.java org/apache/kafka/common/serialization/ByteBufferDeserializer.java org/apache/kafka/common/serialization/LongSerializer.java org/apache/kafka/common/serialization/StringDeserializer.java org/apache/kafka/common/serialization/IntegerDeserializer.java org/apache/kafka/common/serialization/StringSerializer.java org/apache/kafka/common/serialization/Serdes.java org/apache/kafka/common/serialization/LongDeserializer.java org/apache/kafka/common/serialization/ByteArrayDeserializer.java org/apache/kafka/common/serialization/IntegerSerializer.java org/apache/kafka/common/serialization/DoubleSerializer.java org/apache/kafka/common/serialization/BytesSerializer.java org/apache/kafka/common/serialization/Serializer.java org/apache/kafka/common/Metric.java org/apache/kafka/common/network/MultiSend.java org/apache/kafka/common/network/ChannelBuilders.java org/apache/kafka/common/network/SaslChannelBuilder.java org/apache/kafka/common/network/NetworkReceive.java org/apache/kafka/common/network/Mode.java org/apache/kafka/common/network/TransportLayers.java org/apache/kafka/common/network/DefaultAuthenticator.java org/apache/kafka/common/network/Selectable.java org/apache/kafka/common/network/Send.java org/apache/kafka/common/network/NetworkSend.java org/apache/kafka/common/network/KafkaChannel.java org/apache/kafka/common/network/TransportLayer.java org/apache/kafka/common/network/Receive.java org/apache/kafka/common/network/ByteBufferSend.java org/apache/kafka/common/network/Authenticator.java org/apache/kafka/common/network/Selector.java org/apache/kafka/common/network/ListenerName.java org/apache/kafka/common/network/SslChannelBuilder.java org/apache/kafka/common/network/PlaintextChannelBuilder.java org/apache/kafka/common/network/InvalidReceiveException.java org/apache/kafka/common/network/PlaintextTransportLayer.java org/apache/kafka/common/network/SslTransportLayer.java org/apache/kafka/common/network/ByteBufferReceive.java org/apache/kafka/common/network/ChannelBuilder.java org/apache/kafka/common/network/LoginType.java org/apache/kafka/common/Configurable.java org/apache/kafka/common/TopicPartition.java org/apache/kafka/common/Cluster.java org/apache/kafka/common/annotation/InterfaceStability.java org/apache/kafka/common/utils/SystemTime.java org/apache/kafka/common/utils/KafkaThread.java org/apache/kafka/common/utils/Bytes.java org/apache/kafka/common/utils/CollectionUtils.java org/apache/kafka/common/utils/Shell.java org/apache/kafka/common/utils/Utils.java org/apache/kafka/common/utils/Time.java org/apache/kafka/common/utils/AppInfoParser.java org/apache/kafka/common/utils/AbstractIterator.java org/apache/kafka/common/utils/Crc32.java org/apache/kafka/common/utils/CircularIterator.java org/apache/kafka/common/utils/CopyOnWriteMap.java org/apache/kafka/common/protocol/types/Type.java org/apache/kafka/common/protocol/types/Schema.java org/apache/kafka/common/protocol/types/SchemaException.java org/apache/kafka/common/protocol/types/ArrayOf.java org/apache/kafka/common/protocol/types/Field.java org/apache/kafka/common/protocol/types/Struct.java org/apache/kafka/common/protocol/Protocol.java org/apache/kafka/common/protocol/ApiKeys.java org/apache/kafka/common/protocol/ProtoUtils.java org/apache/kafka/common/protocol/Errors.java org/apache/kafka/common/protocol/SecurityProtocol.java org/apache/kafka/common/requests/GroupCoordinatorResponse.java org/apache/kafka/common/requests/OffsetCommitResponse.java org/apache/kafka/common/requests/ControlledShutdownRequest.java org/apache/kafka/common/requests/DescribeGroupsRequest.java org/apache/kafka/common/requests/OffsetCommitRequest.java org/apache/kafka/common/requests/LeaderAndIsrRequest.java org/apache/kafka/common/requests/CreateTopicsResponse.java org/apache/kafka/common/requests/ListGroupsResponse.java org/apache/kafka/common/requests/ProduceResponse.java org/apache/kafka/common/requests/RequestHeader.java org/apache/kafka/common/requests/CreateTopicsRequest.java org/apache/kafka/common/requests/StopReplicaResponse.java org/apache/kafka/common/requests/SyncGroupRequest.java org/apache/kafka/common/requests/DeleteTopicsResponse.java org/apache/kafka/common/requests/OffsetFetchRequest.java org/apache/kafka/common/requests/JoinGroupResponse.java org/apache/kafka/common/requests/AbstractResponse.java org/apache/kafka/common/requests/JoinGroupRequest.java org/apache/kafka/common/requests/ListOffsetRequest.java org/apache/kafka/common/requests/SaslHandshakeResponse.java org/apache/kafka/common/requests/RecordsSend.java org/apache/kafka/common/requests/ListOffsetResponse.java org/apache/kafka/common/requests/ApiVersionsRequest.java org/apache/kafka/common/requests/DeleteTopicsRequest.java org/apache/kafka/common/requests/ControlledShutdownResponse.java org/apache/kafka/common/requests/LeaveGroupRequest.java org/apache/kafka/common/requests/MetadataResponse.java org/apache/kafka/common/requests/HeartbeatRequest.java org/apache/kafka/common/requests/ListGroupsRequest.java org/apache/kafka/common/requests/PartitionState.java org/apache/kafka/common/requests/FetchResponse.java org/apache/kafka/common/requests/UpdateMetadataResponse.java org/apache/kafka/common/requests/OffsetFetchResponse.java org/apache/kafka/common/requests/SyncGroupResponse.java org/apache/kafka/common/requests/LeaderAndIsrResponse.java org/apache/kafka/common/requests/ApiVersionsResponse.java org/apache/kafka/common/requests/ResponseHeader.java org/apache/kafka/common/requests/FetchRequest.java org/apache/kafka/common/requests/AbstractRequest.java org/apache/kafka/common/requests/SaslHandshakeRequest.java org/apache/kafka/common/requests/AbstractRequestResponse.java org/apache/kafka/common/requests/GroupCoordinatorRequest.java org/apache/kafka/common/requests/LeaveGroupResponse.java org/apache/kafka/common/requests/DescribeGroupsResponse.java org/apache/kafka/common/requests/UpdateMetadataRequest.java #内容未全部加载，请点击展开加载全部代码(NowJava.com)
依赖Jar:	无