> kafka-clients-0.8.2-beta.jar
标签:kafka-clients-0.8.2-beta.jar,kafka,clients,0.8.2,beta,jar包下载,依赖包
LICENSE
META-INFMANIFEST.MFNOTICEorgapachekafkaclients
ClientRequest.javaClientResponse.javaClusterConnectionStates.javaConnectionState.javaconsumerConsumer.javaConsumerConfig.javaConsumerRebalanceCallback.javaConsumerRecord.javaConsumerRecords.javaKafkaConsumer.javaMockConsumer.javaOffsetMetadata.javaInFlightRequests.javaKafkaClient.javaNetworkClient.javaNodeConnectionState.javaproducerBufferExhaustedException.javaCallback.javainternalsBufferPool.javaErrorLoggingCallback.javaFutureRecordMetadata.javaMetadata.javaPartitioner.javaProduceRequestResult.javaRecordAccumulator.javaRecordBatch.javaSender.javaKafkaProducer.javaMockProducer.javaProducer.javaProducerConfig.javaProducerRecord.javaRecordMetadata.javatoolsProducerPerformance.javacommonCluster.javaconfigAbstractConfig.javaConfigDef.javaConfigException.javaConfigurable.javaerrorsApiException.javaCorruptRecordException.javaInvalidMetadataException.javaInvalidTopicException.javaLeaderNotAvailableException.javaNetworkException.javaNotEnoughReplicasAfterAppendException.javaNotEnoughReplicasException.javaNotLeaderForPartitionException.javaOffsetMetadataTooLarge.javaOffsetOutOfRangeException.javaRecordBatchTooLargeException.javaRecordTooLargeException.javaRetriableException.javaTimeoutException.javaUnknownServerException.javaUnknownTopicOrPartitionException.javaKafkaException.javamessageKafkaLZ4BlockInputStream.javaKafkaLZ4BlockOutputStream.javaMetric.javametricsCompoundStat.javaJmxReporter.javaKafkaMetric.javaMeasurable.javaMeasurableStat.javaMetricConfig.javaMetrics.javaMetricsReporter.javaQuota.javaQuotaViolationException.javaSensor.javaStat.javastatsAvg.javaCount.javaHistogram.javaMax.javaMin.javaPercentile.javaPercentiles.javaRate.javaSampledStat.javaTotal.javanetworkByteBufferReceive.javaByteBufferSend.javaNetworkReceive.javaNetworkSend.javaReceive.javaSelectable.javaSelector.javaSend.javaNode.javaPartitionInfo.javaprotocolApiKeys.javaErrors.javaProtocol.javaProtoUtils.javatypesArrayOf.javaField.javaSchema.javaSchemaException.javaStruct.javaType.javarecordByteBufferInputStream.javaByteBufferOutputStream.javaCompressionType.javaCompressor.javaInvalidRecordException.javaLogEntry.javaMemoryRecords.javaRecord.javaRecords.javarequestsAbstractRequestResponse.javaConsumerMetadataRequest.javaConsumerMetadataResponse.javaFetchRequest.javaFetchResponse.javaHeartbeatRequest.javaHeartbeatResponse.javaJoinGroupRequest.javaJoinGroupResponse.javaListOffsetRequest.javaListOffsetResponse.javaMetadataRequest.javaMetadataResponse.javaOffsetCommitRequest.javaOffsetCommitResponse.javaOffsetFetchRequest.javaOffsetFetchResponse.javaProduceRequest.javaProduceResponse.javaRequestHeader.javaRequestSend.javaResponseHeader.javaTopicPartition.javautilsAbstractIterator.javaClientUtils.javaCollectionUtils.javaCopyOnWriteMap.javaCrc32.javaKafkaThread.javaSystemTime.javaTime.javaUtils.java