MINOR: Follow-up Update on 1.0.0 release 1. Replaced 100 folder with 10 folder. 2. Update Streams/index.html file with a couple follow-up PRs that went in post RC4. 3. Add the paragraph that Sally and Jun suggested in release notes.
ijuma rajinisivaram Author: Guozhang Wang <[email protected]> Reviewers: Ismael Juma <[email protected]> Closes #107 from guozhangwang/KMinor-1.0-release-update Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/2e200cfc Tree: http://git-wip-us.apache.org/repos/asf/kafka-site/tree/2e200cfc Diff: http://git-wip-us.apache.org/repos/asf/kafka-site/diff/2e200cfc Branch: refs/heads/asf-site Commit: 2e200cfce9dbdb276d3332655b520f2cf2e00fc8 Parents: 6050b14 Author: Guozhang Wang <[email protected]> Authored: Wed Nov 1 15:40:16 2017 -0700 Committer: Guozhang Wang <[email protected]> Committed: Wed Nov 1 15:40:16 2017 -0700 ---------------------------------------------------------------------- 10/api.html | 113 + 10/configuration.html | 262 + 10/connect.html | 514 + 10/design.html | 624 + 10/documentation.html | 83 + 10/documentation/index.html | 18 + 10/documentation/streams/architecture.html | 19 + 10/documentation/streams/core-concepts.html | 19 + 10/documentation/streams/developer-guide.html | 19 + 10/documentation/streams/index.html | 19 + 10/documentation/streams/quickstart.html | 19 + 10/documentation/streams/tutorial.html | 19 + 10/documentation/streams/upgrade-guide.html | 19 + 10/ecosystem.html | 18 + 10/generated/admin_client_config.html | 86 + 10/generated/connect_config.html | 145 + 10/generated/connect_metrics.html | 158 + 10/generated/connect_transforms.html | 228 + 10/generated/consumer_config.html | 122 + 10/generated/consumer_metrics.html | 64 + 10/generated/kafka_config.html | 332 + 10/generated/producer_config.html | 116 + 10/generated/producer_metrics.html | 78 + 10/generated/protocol_api_keys.html | 81 + 10/generated/protocol_errors.html | 70 + 10/generated/protocol_messages.html | 4345 +++++++ 10/generated/streams_config.html | 86 + 10/generated/topic_config.html | 59 + 10/images/consumer-groups.png | Bin 0 -> 26820 bytes 10/images/icons/NYT.jpg | Bin 0 -> 12605 bytes 10/images/icons/architecture--white.png | Bin 0 -> 812 bytes 10/images/icons/architecture.png | Bin 0 -> 818 bytes 10/images/icons/documentation--white.png | Bin 0 -> 1758 bytes 10/images/icons/documentation.png | Bin 0 -> 1642 bytes 10/images/icons/line.png | Bin 0 -> 676 bytes 10/images/icons/new-york.png | Bin 0 -> 3381 bytes 10/images/icons/rabobank.png | Bin 0 -> 3593 bytes 10/images/icons/tutorials--white.png | Bin 0 -> 1047 bytes 10/images/icons/tutorials.png | Bin 0 -> 985 bytes 10/images/icons/zalando.png | Bin 0 -> 2716 bytes 10/images/kafka-apis.png | Bin 0 -> 86640 bytes 10/images/kafka_log.png | Bin 0 -> 134321 bytes 10/images/kafka_multidc.png | Bin 0 -> 33959 bytes 10/images/kafka_multidc_complex.png | Bin 0 -> 38559 bytes 10/images/log_anatomy.png | Bin 0 -> 19579 bytes 10/images/log_cleaner_anatomy.png | Bin 0 -> 18638 bytes 10/images/log_compaction.png | Bin 0 -> 41414 bytes 10/images/log_consumer.png | Bin 0 -> 139658 bytes 10/images/mirror-maker.png | Bin 0 -> 6579 bytes 10/images/producer_consumer.png | Bin 0 -> 8691 bytes 10/images/streams-architecture-overview.jpg | Bin 0 -> 420929 bytes 10/images/streams-architecture-states.jpg | Bin 0 -> 147338 bytes 10/images/streams-architecture-tasks.jpg | Bin 0 -> 130435 bytes 10/images/streams-architecture-threads.jpg | Bin 0 -> 153622 bytes 10/images/streams-architecture-topology.jpg | Bin 0 -> 182199 bytes 10/images/streams-cache-and-commit-interval.png | Bin 0 -> 38648 bytes 10/images/streams-concepts-topology.jpg | Bin 0 -> 136983 bytes 10/images/streams-interactive-queries-01.png | Bin 0 -> 80976 bytes 10/images/streams-interactive-queries-02.png | Bin 0 -> 73218 bytes 10/images/streams-interactive-queries-03.png | Bin 0 -> 79879 bytes .../streams-interactive-queries-api-01.png | Bin 0 -> 84438 bytes .../streams-interactive-queries-api-02.png | Bin 0 -> 100725 bytes 10/images/streams-stateful_operations.png | Bin 0 -> 123213 bytes 10/images/streams-table-duality-01.png | Bin 0 -> 14534 bytes 10/images/streams-table-duality-02.png | Bin 0 -> 56736 bytes 10/images/streams-table-duality-03.png | Bin 0 -> 91331 bytes 10/images/streams-table-updates-01.png | Bin 0 -> 78069 bytes 10/images/streams-table-updates-02.png | Bin 0 -> 91880 bytes 10/images/streams-welcome.png | Bin 0 -> 80530 bytes 10/images/tracking_high_level.png | Bin 0 -> 82759 bytes 10/implementation.html | 319 + 10/introduction.html | 209 + 10/javadoc/allclasses-frame.html | 420 + 10/javadoc/allclasses-noframe.html | 420 + 10/javadoc/constant-values.html | 2196 ++++ 10/javadoc/deprecated-list.html | 1034 ++ 10/javadoc/help-doc.html | 223 + 10/javadoc/index-all.html | 10050 +++++++++++++++++ 10/javadoc/index.html | 75 + .../kafka/clients/admin/AbstractOptions.html | 296 + .../apache/kafka/clients/admin/AdminClient.html | 1180 ++ .../kafka/clients/admin/AdminClientConfig.html | 651 ++ .../clients/admin/AlterConfigsOptions.html | 304 + .../kafka/clients/admin/AlterConfigsResult.html | 258 + .../admin/AlterReplicaLogDirsOptions.html | 249 + .../admin/AlterReplicaLogDirsResult.html | 263 + .../org/apache/kafka/clients/admin/Config.html | 346 + .../apache/kafka/clients/admin/ConfigEntry.html | 399 + .../kafka/clients/admin/CreateAclsOptions.html | 251 + .../kafka/clients/admin/CreateAclsResult.html | 260 + .../clients/admin/CreatePartitionsOptions.html | 304 + .../clients/admin/CreatePartitionsResult.html | 260 + .../clients/admin/CreateTopicsOptions.html | 304 + .../kafka/clients/admin/CreateTopicsResult.html | 260 + .../kafka/clients/admin/DeleteAclsOptions.html | 251 + .../admin/DeleteAclsResult.FilterResult.html | 259 + .../admin/DeleteAclsResult.FilterResults.html | 243 + .../kafka/clients/admin/DeleteAclsResult.html | 288 + .../clients/admin/DeleteTopicsOptions.html | 251 + .../kafka/clients/admin/DeleteTopicsResult.html | 260 + .../clients/admin/DescribeAclsOptions.html | 251 + .../kafka/clients/admin/DescribeAclsResult.html | 242 + .../clients/admin/DescribeClusterOptions.html | 251 + .../clients/admin/DescribeClusterResult.html | 276 + .../clients/admin/DescribeConfigsOptions.html | 251 + .../clients/admin/DescribeConfigsResult.html | 260 + .../clients/admin/DescribeLogDirsOptions.html | 251 + .../clients/admin/DescribeLogDirsResult.html | 258 + .../admin/DescribeReplicaLogDirsOptions.html | 251 + ...eReplicaLogDirsResult.ReplicaLogDirInfo.html | 295 + .../admin/DescribeReplicaLogDirsResult.html | 277 + .../clients/admin/DescribeTopicsOptions.html | 251 + .../clients/admin/DescribeTopicsResult.html | 260 + .../kafka/clients/admin/KafkaAdminClient.html | 758 ++ .../kafka/clients/admin/ListTopicsOptions.html | 311 + .../kafka/clients/admin/ListTopicsResult.html | 274 + .../kafka/clients/admin/NewPartitions.html | 338 + .../apache/kafka/clients/admin/NewTopic.html | 391 + .../kafka/clients/admin/TopicDescription.html | 339 + .../kafka/clients/admin/TopicListing.html | 317 + .../kafka/clients/admin/package-frame.html | 60 + .../kafka/clients/admin/package-summary.html | 380 + .../kafka/clients/admin/package-tree.html | 185 + .../clients/consumer/CommitFailedException.html | 274 + .../apache/kafka/clients/consumer/Consumer.html | 761 ++ .../kafka/clients/consumer/ConsumerConfig.html | 1153 ++ .../clients/consumer/ConsumerInterceptor.html | 309 + .../consumer/ConsumerRebalanceListener.html | 334 + .../kafka/clients/consumer/ConsumerRecord.html | 670 ++ .../kafka/clients/consumer/ConsumerRecords.html | 422 + .../consumer/InvalidOffsetException.html | 312 + .../kafka/clients/consumer/KafkaConsumer.html | 1895 ++++ .../kafka/clients/consumer/MockConsumer.html | 998 ++ .../consumer/NoOffsetForPartitionException.html | 356 + .../clients/consumer/OffsetAndMetadata.html | 375 + .../clients/consumer/OffsetAndTimestamp.html | 336 + .../clients/consumer/OffsetCommitCallback.html | 244 + .../consumer/OffsetOutOfRangeException.html | 328 + .../clients/consumer/OffsetResetStrategy.html | 351 + .../kafka/clients/consumer/RangeAssignor.html | 330 + .../RetriableCommitFailedException.html | 347 + .../clients/consumer/RoundRobinAssignor.html | 357 + .../kafka/clients/consumer/StickyAssignor.html | 492 + .../kafka/clients/consumer/package-frame.html | 48 + .../kafka/clients/consumer/package-summary.html | 290 + .../kafka/clients/consumer/package-tree.html | 215 + .../producer/BufferExhaustedException.html | 272 + .../apache/kafka/clients/producer/Callback.html | 253 + .../kafka/clients/producer/KafkaProducer.html | 1015 ++ .../kafka/clients/producer/MockProducer.html | 829 ++ .../kafka/clients/producer/Partitioner.html | 276 + .../apache/kafka/clients/producer/Producer.html | 445 + .../kafka/clients/producer/ProducerConfig.html | 1047 ++ .../clients/producer/ProducerInterceptor.html | 333 + .../kafka/clients/producer/ProducerRecord.html | 604 + .../kafka/clients/producer/RecordMetadata.html | 537 + .../kafka/clients/producer/package-frame.html | 35 + .../kafka/clients/producer/package-summary.html | 220 + .../kafka/clients/producer/package-tree.html | 180 + 10/javadoc/org/apache/kafka/common/Cluster.html | 630 ++ .../apache/kafka/common/ClusterResource.html | 300 + .../kafka/common/ClusterResourceListener.html | 252 + .../org/apache/kafka/common/Configurable.html | 231 + .../org/apache/kafka/common/KafkaException.html | 308 + .../kafka/common/KafkaFuture.BiConsumer.html | 278 + .../kafka/common/KafkaFuture.Function.html | 276 + .../org/apache/kafka/common/KafkaFuture.html | 559 + 10/javadoc/org/apache/kafka/common/Metric.html | 259 + .../org/apache/kafka/common/MetricName.html | 414 + .../apache/kafka/common/MetricNameTemplate.html | 387 + 10/javadoc/org/apache/kafka/common/Node.html | 462 + .../org/apache/kafka/common/PartitionInfo.html | 402 + .../org/apache/kafka/common/TopicPartition.html | 345 + .../apache/kafka/common/TopicPartitionInfo.html | 358 + .../kafka/common/TopicPartitionReplica.html | 360 + .../kafka/common/acl/AccessControlEntry.html | 423 + .../common/acl/AccessControlEntryFilter.html | 498 + .../org/apache/kafka/common/acl/AclBinding.html | 385 + .../kafka/common/acl/AclBindingFilter.html | 457 + .../apache/kafka/common/acl/AclOperation.html | 602 + .../kafka/common/acl/AclPermissionType.html | 451 + .../apache/kafka/common/acl/package-frame.html | 28 + .../kafka/common/acl/package-summary.html | 183 + .../apache/kafka/common/acl/package-tree.html | 151 + .../annotation/InterfaceStability.Evolving.html | 164 + .../annotation/InterfaceStability.Stable.html | 169 + .../annotation/InterfaceStability.Unstable.html | 164 + .../common/annotation/InterfaceStability.html | 272 + .../kafka/common/annotation/package-frame.html | 26 + .../common/annotation/package-summary.html | 172 + .../kafka/common/annotation/package-tree.html | 141 + .../kafka/common/config/AbstractConfig.html | 696 ++ .../org/apache/kafka/common/config/Config.html | 269 + .../common/config/ConfigDef.ConfigKey.html | 489 + .../common/config/ConfigDef.Importance.html | 356 + .../common/config/ConfigDef.NonEmptyString.html | 308 + .../kafka/common/config/ConfigDef.Range.html | 313 + .../common/config/ConfigDef.Recommender.html | 265 + .../kafka/common/config/ConfigDef.Type.html | 428 + .../common/config/ConfigDef.ValidList.html | 287 + .../common/config/ConfigDef.ValidString.html | 287 + .../common/config/ConfigDef.Validator.html | 240 + .../kafka/common/config/ConfigDef.Width.html | 368 + .../apache/kafka/common/config/ConfigDef.html | 1448 +++ .../kafka/common/config/ConfigException.html | 301 + .../common/config/ConfigResource.Type.html | 356 + .../kafka/common/config/ConfigResource.html | 371 + .../apache/kafka/common/config/ConfigValue.html | 442 + .../apache/kafka/common/config/SaslConfigs.html | 765 ++ .../apache/kafka/common/config/SslConfigs.html | 1009 ++ .../apache/kafka/common/config/TopicConfig.html | 1046 ++ .../kafka/common/config/package-frame.html | 48 + .../kafka/common/config/package-summary.html | 274 + .../kafka/common/config/package-tree.html | 184 + .../kafka/common/errors/ApiException.html | 352 + .../common/errors/AuthenticationException.html | 312 + .../common/errors/AuthorizationException.html | 300 + .../errors/BrokerNotAvailableException.html | 296 + .../errors/ClusterAuthorizationException.html | 301 + .../errors/ConcurrentTransactionsException.html | 282 + .../common/errors/ControllerMovedException.html | 296 + .../CoordinatorLoadInProgressException.html | 307 + .../CoordinatorNotAvailableException.html | 342 + .../common/errors/CorruptRecordException.html | 327 + .../common/errors/DisconnectException.html | 362 + .../errors/DuplicateSequenceException.html | 282 + .../errors/GroupAuthorizationException.html | 321 + .../GroupCoordinatorNotAvailableException.html | 382 + .../errors/GroupLoadInProgressException.html | 343 + .../errors/IllegalGenerationException.html | 320 + .../errors/IllegalSaslStateException.html | 304 + .../InconsistentGroupProtocolException.html | 296 + .../kafka/common/errors/InterruptException.html | 297 + .../InvalidCommitOffsetSizeException.html | 296 + .../errors/InvalidConfigurationException.html | 296 + .../errors/InvalidFetchSizeException.html | 296 + .../common/errors/InvalidGroupIdException.html | 296 + .../common/errors/InvalidMetadataException.html | 330 + .../common/errors/InvalidOffsetException.html | 303 + .../errors/InvalidPartitionsException.html | 296 + .../errors/InvalidPidMappingException.html | 282 + .../InvalidReplicaAssignmentException.html | 296 + .../InvalidReplicationFactorException.html | 296 + .../common/errors/InvalidRequestException.html | 299 + .../errors/InvalidRequiredAcksException.html | 282 + .../errors/InvalidSessionTimeoutException.html | 296 + .../errors/InvalidTimestampException.html | 297 + .../common/errors/InvalidTopicException.html | 324 + .../common/errors/InvalidTxnStateException.html | 282 + .../errors/InvalidTxnTimeoutException.html | 298 + .../common/errors/KafkaStorageException.html | 339 + .../errors/LeaderNotAvailableException.html | 308 + .../common/errors/LogDirNotFoundException.html | 309 + .../kafka/common/errors/NetworkException.html | 332 + .../common/errors/NotControllerException.html | 301 + .../common/errors/NotCoordinatorException.html | 306 + .../errors/NotCoordinatorForGroupException.html | 343 + .../NotEnoughReplicasAfterAppendException.html | 289 + .../errors/NotEnoughReplicasException.html | 326 + .../errors/NotLeaderForPartitionException.html | 331 + .../common/errors/OffsetMetadataTooLarge.html | 321 + .../errors/OffsetOutOfRangeException.html | 303 + .../errors/OperationNotAttemptedException.html | 284 + .../errors/OutOfOrderSequenceException.html | 292 + .../common/errors/PolicyViolationException.html | 297 + .../common/errors/ProducerFencedException.html | 286 + .../errors/ReassignmentInProgressException.html | 297 + .../errors/RebalanceInProgressException.html | 320 + .../errors/RecordBatchTooLargeException.html | 321 + .../common/errors/RecordTooLargeException.html | 369 + .../errors/ReplicaNotAvailableException.html | 308 + .../kafka/common/errors/RetriableException.html | 325 + .../errors/SaslAuthenticationException.html | 314 + .../errors/SecurityDisabledException.html | 297 + .../common/errors/SerializationException.html | 347 + .../errors/SslAuthenticationException.html | 310 + .../kafka/common/errors/TimeoutException.html | 326 + .../errors/TopicAuthorizationException.html | 333 + .../common/errors/TopicExistsException.html | 296 + .../TransactionCoordinatorFencedException.html | 296 + .../TransactionalIdAuthorizationException.html | 287 + .../common/errors/UnknownMemberIdException.html | 320 + .../errors/UnknownProducerIdException.html | 291 + .../common/errors/UnknownServerException.html | 322 + .../UnknownTopicOrPartitionException.html | 334 + .../UnsupportedForMessageFormatException.html | 298 + .../UnsupportedSaslMechanismException.html | 303 + .../errors/UnsupportedVersionException.html | 304 + .../kafka/common/errors/WakeupException.html | 274 + .../kafka/common/errors/package-frame.html | 94 + .../kafka/common/errors/package-summary.html | 544 + .../kafka/common/errors/package-tree.html | 246 + .../org/apache/kafka/common/header/Header.html | 232 + .../org/apache/kafka/common/header/Headers.html | 360 + .../kafka/common/header/package-frame.html | 21 + .../kafka/common/header/package-summary.html | 144 + .../kafka/common/header/package-tree.html | 136 + .../org/apache/kafka/common/package-frame.html | 41 + .../apache/kafka/common/package-summary.html | 254 + .../org/apache/kafka/common/package-tree.html | 165 + .../apache/kafka/common/resource/Resource.html | 444 + .../kafka/common/resource/ResourceFilter.html | 456 + .../kafka/common/resource/ResourceType.html | 484 + .../kafka/common/resource/package-frame.html | 25 + .../kafka/common/resource/package-summary.html | 165 + .../kafka/common/resource/package-tree.html | 148 + .../security/auth/AuthenticationContext.html | 244 + .../security/auth/DefaultPrincipalBuilder.html | 348 + .../common/security/auth/KafkaPrincipal.html | 454 + .../security/auth/KafkaPrincipalBuilder.html | 236 + .../auth/PlaintextAuthenticationContext.html | 303 + .../common/security/auth/PrincipalBuilder.html | 292 + .../auth/SaslAuthenticationContext.html | 320 + .../common/security/auth/SecurityProtocol.html | 472 + .../security/auth/SslAuthenticationContext.html | 318 + .../common/security/auth/package-frame.html | 34 + .../common/security/auth/package-summary.html | 205 + .../common/security/auth/package-tree.html | 161 + .../serialization/ByteArrayDeserializer.html | 336 + .../serialization/ByteArraySerializer.html | 342 + .../serialization/ByteBufferDeserializer.html | 336 + .../serialization/ByteBufferSerializer.html | 342 + .../common/serialization/BytesDeserializer.html | 336 + .../common/serialization/BytesSerializer.html | 342 + .../common/serialization/Deserializer.html | 295 + .../serialization/DoubleDeserializer.html | 336 + .../common/serialization/DoubleSerializer.html | 342 + .../ExtendedDeserializer.Wrapper.html | 399 + .../serialization/ExtendedDeserializer.html | 280 + .../ExtendedSerializer.Wrapper.html | 409 + .../serialization/ExtendedSerializer.html | 282 + .../common/serialization/FloatDeserializer.html | 336 + .../common/serialization/FloatSerializer.html | 342 + .../serialization/IntegerDeserializer.html | 336 + .../common/serialization/IntegerSerializer.html | 342 + .../common/serialization/LongDeserializer.html | 336 + .../common/serialization/LongSerializer.html | 342 + .../kafka/common/serialization/Serde.html | 294 + .../serialization/Serdes.ByteArraySerde.html | 255 + .../serialization/Serdes.ByteBufferSerde.html | 255 + .../common/serialization/Serdes.BytesSerde.html | 255 + .../serialization/Serdes.DoubleSerde.html | 255 + .../common/serialization/Serdes.FloatSerde.html | 255 + .../serialization/Serdes.IntegerSerde.html | 255 + .../common/serialization/Serdes.LongSerde.html | 255 + .../common/serialization/Serdes.ShortSerde.html | 255 + .../serialization/Serdes.StringSerde.html | 255 + .../serialization/Serdes.WrapperSerde.html | 357 + .../kafka/common/serialization/Serdes.html | 465 + .../kafka/common/serialization/Serializer.html | 302 + .../common/serialization/ShortDeserializer.html | 336 + .../common/serialization/ShortSerializer.html | 342 + .../serialization/StringDeserializer.html | 338 + .../common/serialization/StringSerializer.html | 344 + .../common/serialization/package-frame.html | 58 + .../common/serialization/package-summary.html | 309 + .../common/serialization/package-tree.html | 190 + .../kafka/connect/connector/ConnectRecord.html | 448 + .../kafka/connect/connector/Connector.html | 531 + .../connect/connector/ConnectorContext.html | 246 + .../apache/kafka/connect/connector/Task.html | 277 + .../kafka/connect/connector/package-frame.html | 26 + .../connect/connector/package-summary.html | 175 + .../kafka/connect/connector/package-tree.html | 141 + .../kafka/connect/data/ConnectSchema.html | 746 ++ .../org/apache/kafka/connect/data/Date.html | 375 + .../org/apache/kafka/connect/data/Decimal.html | 402 + .../org/apache/kafka/connect/data/Field.html | 357 + .../apache/kafka/connect/data/Schema.Type.html | 547 + .../org/apache/kafka/connect/data/Schema.html | 731 ++ .../kafka/connect/data/SchemaAndValue.html | 371 + .../kafka/connect/data/SchemaBuilder.html | 1030 ++ .../kafka/connect/data/SchemaProjector.html | 291 + .../org/apache/kafka/connect/data/Struct.html | 681 ++ .../org/apache/kafka/connect/data/Time.html | 375 + .../apache/kafka/connect/data/Timestamp.html | 373 + .../kafka/connect/data/package-frame.html | 37 + .../kafka/connect/data/package-summary.html | 236 + .../apache/kafka/connect/data/package-tree.html | 160 + .../connect/errors/AlreadyExistsException.html | 302 + .../kafka/connect/errors/ConnectException.html | 301 + .../kafka/connect/errors/DataException.html | 306 + .../errors/IllegalWorkerStateException.html | 302 + .../kafka/connect/errors/NotFoundException.html | 302 + .../connect/errors/RetriableException.html | 302 + .../connect/errors/SchemaBuilderException.html | 306 + .../errors/SchemaProjectorException.html | 306 + .../kafka/connect/errors/package-frame.html | 27 + .../kafka/connect/errors/package-summary.html | 180 + .../kafka/connect/errors/package-tree.html | 164 + .../kafka/connect/sink/SinkConnector.html | 305 + .../apache/kafka/connect/sink/SinkRecord.html | 424 + .../org/apache/kafka/connect/sink/SinkTask.html | 581 + .../kafka/connect/sink/SinkTaskContext.html | 362 + .../kafka/connect/sink/package-frame.html | 26 + .../kafka/connect/sink/package-summary.html | 172 + .../apache/kafka/connect/sink/package-tree.html | 149 + .../kafka/connect/source/SourceConnector.html | 264 + .../kafka/connect/source/SourceRecord.html | 502 + .../apache/kafka/connect/source/SourceTask.html | 455 + .../kafka/connect/source/SourceTaskContext.html | 224 + .../kafka/connect/source/package-frame.html | 26 + .../kafka/connect/source/package-summary.html | 175 + .../kafka/connect/source/package-tree.html | 149 + .../apache/kafka/connect/storage/Converter.html | 289 + .../connect/storage/OffsetStorageReader.html | 272 + .../kafka/connect/storage/StringConverter.html | 354 + .../kafka/connect/storage/package-frame.html | 25 + .../kafka/connect/storage/package-summary.html | 167 + .../kafka/connect/storage/package-tree.html | 140 + .../connect/transforms/Transformation.html | 281 + .../kafka/connect/transforms/package-frame.html | 20 + .../connect/transforms/package-summary.html | 142 + .../kafka/connect/transforms/package-tree.html | 144 + .../kafka/connect/util/ConnectorUtils.html | 288 + .../kafka/connect/util/package-frame.html | 20 + .../kafka/connect/util/package-summary.html | 142 + .../apache/kafka/connect/util/package-tree.html | 135 + .../AlterConfigPolicy.RequestMetadata.html | 314 + .../kafka/server/policy/AlterConfigPolicy.html | 283 + .../CreateTopicPolicy.RequestMetadata.html | 384 + .../kafka/server/policy/CreateTopicPolicy.html | 282 + .../kafka/server/policy/package-frame.html | 26 + .../kafka/server/policy/package-summary.html | 171 + .../kafka/server/policy/package-tree.html | 151 + .../org/apache/kafka/streams/Consumed.html | 567 + .../kafka/streams/KafkaClientSupplier.html | 280 + .../kafka/streams/KafkaStreams.State.html | 457 + .../streams/KafkaStreams.StateListener.html | 234 + .../org/apache/kafka/streams/KafkaStreams.html | 958 ++ .../org/apache/kafka/streams/KeyValue.html | 411 + .../apache/kafka/streams/StreamsBuilder.html | 867 ++ .../streams/StreamsConfig.InternalConfig.html | 279 + .../org/apache/kafka/streams/StreamsConfig.html | 1571 +++ .../apache/kafka/streams/StreamsMetrics.html | 456 + .../kafka/streams/Topology.AutoOffsetReset.html | 346 + .../org/apache/kafka/streams/Topology.html | 1242 ++ .../TopologyDescription.GlobalStore.html | 256 + .../kafka/streams/TopologyDescription.Node.html | 279 + .../streams/TopologyDescription.Processor.html | 243 + .../kafka/streams/TopologyDescription.Sink.html | 243 + .../streams/TopologyDescription.Source.html | 243 + .../TopologyDescription.Subtopology.html | 255 + .../kafka/streams/TopologyDescription.html | 306 + .../streams/errors/BrokerNotFoundException.html | 304 + ...nHandler.DeserializationHandlerResponse.html | 399 + .../errors/DeserializationExceptionHandler.html | 271 + .../errors/InvalidStateStoreException.html | 308 + .../kafka/streams/errors/LockException.html | 303 + .../errors/LogAndContinueExceptionHandler.html | 328 + .../errors/LogAndFailExceptionHandler.html | 328 + .../streams/errors/ProcessorStateException.html | 303 + .../kafka/streams/errors/StreamsException.html | 301 + .../streams/errors/TaskAssignmentException.html | 304 + .../streams/errors/TaskIdFormatException.html | 304 + .../streams/errors/TaskMigratedException.html | 309 + .../errors/TopologyBuilderException.html | 315 + .../kafka/streams/errors/TopologyException.html | 303 + .../kafka/streams/errors/package-frame.html | 42 + .../kafka/streams/errors/package-summary.html | 263 + .../kafka/streams/errors/package-tree.html | 185 + .../kafka/streams/kstream/Aggregator.html | 259 + .../kafka/streams/kstream/ForeachAction.html | 246 + .../kafka/streams/kstream/GlobalKTable.html | 212 + .../kafka/streams/kstream/Initializer.html | 242 + .../kafka/streams/kstream/JoinWindows.html | 555 + .../apache/kafka/streams/kstream/Joined.html | 446 + .../kafka/streams/kstream/KGroupedStream.html | 2364 ++++ .../kafka/streams/kstream/KGroupedTable.html | 1360 +++ .../apache/kafka/streams/kstream/KStream.html | 3817 +++++++ .../kafka/streams/kstream/KStreamBuilder.html | 1995 ++++ .../apache/kafka/streams/kstream/KTable.html | 3467 ++++++ .../kafka/streams/kstream/KeyValueMapper.html | 262 + .../kafka/streams/kstream/Materialized.html | 667 ++ .../apache/kafka/streams/kstream/Merger.html | 242 + .../apache/kafka/streams/kstream/Predicate.html | 249 + .../apache/kafka/streams/kstream/Printed.html | 443 + .../apache/kafka/streams/kstream/Produced.html | 548 + .../apache/kafka/streams/kstream/Reducer.html | 254 + .../kafka/streams/kstream/Serialized.html | 393 + .../streams/kstream/SessionWindowedKStream.html | 544 + .../kafka/streams/kstream/SessionWindows.html | 355 + .../streams/kstream/TimeWindowedKStream.html | 548 + .../kafka/streams/kstream/TimeWindows.html | 520 + .../kafka/streams/kstream/Transformer.html | 351 + .../streams/kstream/TransformerSupplier.html | 242 + .../kafka/streams/kstream/UnlimitedWindows.html | 469 + .../kafka/streams/kstream/ValueJoiner.html | 259 + .../kafka/streams/kstream/ValueMapper.html | 249 + .../kafka/streams/kstream/ValueTransformer.html | 352 + .../kstream/ValueTransformerSupplier.html | 240 + .../apache/kafka/streams/kstream/Window.html | 438 + .../apache/kafka/streams/kstream/Windowed.html | 366 + .../apache/kafka/streams/kstream/Windows.html | 429 + .../kafka/streams/kstream/package-frame.html | 55 + .../kafka/streams/kstream/package-summary.html | 353 + .../kafka/streams/kstream/package-tree.html | 177 + .../org/apache/kafka/streams/package-frame.html | 44 + .../apache/kafka/streams/package-summary.html | 274 + .../org/apache/kafka/streams/package-tree.html | 174 + ...bstractNotifyingBatchingRestoreCallback.html | 402 + .../AbstractNotifyingRestoreCallback.html | 378 + .../streams/processor/AbstractProcessor.html | 375 + .../processor/BatchingStateRestoreCallback.html | 247 + .../kafka/streams/processor/Cancellable.html | 227 + .../processor/DefaultPartitionGrouper.html | 312 + .../processor/FailOnInvalidTimestamp.html | 342 + .../processor/LogAndSkipOnInvalidTimestamp.html | 343 + .../streams/processor/PartitionGrouper.html | 249 + .../kafka/streams/processor/Processor.html | 311 + .../streams/processor/ProcessorContext.html | 693 ++ .../streams/processor/ProcessorSupplier.html | 236 + .../streams/processor/PunctuationType.html | 349 + .../kafka/streams/processor/Punctuator.html | 231 + .../streams/processor/StateRestoreCallback.html | 232 + .../streams/processor/StateRestoreListener.html | 315 + .../kafka/streams/processor/StateStore.html | 338 + .../streams/processor/StateStoreSupplier.html | 305 + .../streams/processor/StreamPartitioner.html | 268 + .../apache/kafka/streams/processor/TaskId.html | 466 + .../kafka/streams/processor/TaskMetadata.html | 336 + .../kafka/streams/processor/ThreadMetadata.html | 366 + .../streams/processor/TimestampExtractor.html | 252 + .../TopologyBuilder.AutoOffsetReset.html | 344 + .../processor/TopologyBuilder.TopicsInfo.html | 394 + .../streams/processor/TopologyBuilder.html | 1680 +++ .../UsePreviousTimeOnInvalidTimestamp.html | 342 + .../processor/WallclockTimestampExtractor.html | 301 + .../kafka/streams/processor/package-frame.html | 53 + .../streams/processor/package-summary.html | 335 + .../kafka/streams/processor/package-tree.html | 179 + .../apache/kafka/streams/state/HostInfo.html | 348 + .../state/KeyValueBytesStoreSupplier.html | 192 + .../kafka/streams/state/KeyValueIterator.html | 270 + .../kafka/streams/state/KeyValueStore.html | 337 + .../kafka/streams/state/QueryableStoreType.html | 268 + .../streams/state/QueryableStoreTypes.html | 328 + .../streams/state/ReadOnlyKeyValueStore.html | 326 + .../streams/state/ReadOnlySessionStore.html | 281 + .../streams/state/ReadOnlyWindowStore.html | 313 + .../streams/state/RocksDBConfigSetter.html | 234 + .../state/SessionBytesStoreSupplier.html | 240 + .../kafka/streams/state/SessionStore.html | 357 + .../apache/kafka/streams/state/StateSerdes.html | 546 + .../kafka/streams/state/StoreBuilder.html | 357 + .../kafka/streams/state/StoreSupplier.html | 276 + .../state/Stores.InMemoryKeyValueFactory.html | 316 + .../streams/state/Stores.KeyValueFactory.html | 254 + .../state/Stores.PersistentKeyValueFactory.html | 364 + .../streams/state/Stores.StoreFactory.html | 424 + .../streams/state/Stores.ValueFactory.html | 429 + .../org/apache/kafka/streams/state/Stores.html | 585 + .../kafka/streams/state/StreamsMetadata.html | 422 + .../streams/state/WindowBytesStoreSupplier.html | 303 + .../apache/kafka/streams/state/WindowStore.html | 289 + .../streams/state/WindowStoreIterator.html | 254 + .../kafka/streams/state/package-frame.html | 47 + .../kafka/streams/state/package-summary.html | 294 + .../kafka/streams/state/package-tree.html | 202 + 10/javadoc/overview-frame.html | 46 + 10/javadoc/overview-summary.html | 236 + 10/javadoc/overview-tree.html | 716 ++ 10/javadoc/package-list | 26 + 10/javadoc/script.js | 30 + 10/javadoc/serialized-form.html | 1108 ++ 10/javadoc/stylesheet.css | 574 + 10/js/templateData.js | 24 + 10/migration.html | 34 + 10/ops.html | 1564 +++ 10/protocol.html | 230 + 10/quickstart.html | 300 + 10/security.html | 931 ++ 10/streams/architecture.html | 160 + 10/streams/core-concepts.html | 187 + 10/streams/developer-guide.html | 3001 +++++ 10/streams/index.html | 359 + 10/streams/quickstart.html | 361 + 10/streams/tutorial.html | 638 ++ 10/streams/upgrade-guide.html | 390 + 10/toc.html | 158 + 10/upgrade.html | 602 + 10/uses.html | 81 + 100/api.html | 113 - 100/configuration.html | 262 - 100/connect.html | 514 - 100/design.html | 624 - 100/documentation.html | 83 - 100/documentation/index.html | 18 - 100/documentation/streams/architecture.html | 19 - 100/documentation/streams/core-concepts.html | 19 - 100/documentation/streams/developer-guide.html | 19 - 100/documentation/streams/index.html | 19 - 100/documentation/streams/quickstart.html | 19 - 100/documentation/streams/tutorial.html | 19 - 100/documentation/streams/upgrade-guide.html | 19 - 100/ecosystem.html | 18 - 100/generated/admin_client_config.html | 86 - 100/generated/connect_config.html | 145 - 100/generated/connect_metrics.html | 158 - 100/generated/connect_transforms.html | 228 - 100/generated/consumer_config.html | 122 - 100/generated/consumer_metrics.html | 64 - 100/generated/kafka_config.html | 332 - 100/generated/producer_config.html | 116 - 100/generated/producer_metrics.html | 78 - 100/generated/protocol_api_keys.html | 81 - 100/generated/protocol_errors.html | 70 - 100/generated/protocol_messages.html | 4345 ------- 100/generated/streams_config.html | 86 - 100/generated/topic_config.html | 59 - 100/images/consumer-groups.png | Bin 26820 -> 0 bytes 100/images/icons/NYT.jpg | Bin 12605 -> 0 bytes 100/images/icons/architecture--white.png | Bin 812 -> 0 bytes 100/images/icons/architecture.png | Bin 818 -> 0 bytes 100/images/icons/documentation--white.png | Bin 1758 -> 0 bytes 100/images/icons/documentation.png | Bin 1642 -> 0 bytes 100/images/icons/line.png | Bin 676 -> 0 bytes 100/images/icons/new-york.png | Bin 3381 -> 0 bytes 100/images/icons/rabobank.png | Bin 3593 -> 0 bytes 100/images/icons/tutorials--white.png | Bin 1047 -> 0 bytes 100/images/icons/tutorials.png | Bin 985 -> 0 bytes 100/images/icons/zalando.png | Bin 2716 -> 0 bytes 100/images/kafka-apis.png | Bin 86640 -> 0 bytes 100/images/kafka_log.png | Bin 134321 -> 0 bytes 100/images/kafka_multidc.png | Bin 33959 -> 0 bytes 100/images/kafka_multidc_complex.png | Bin 38559 -> 0 bytes 100/images/log_anatomy.png | Bin 19579 -> 0 bytes 100/images/log_cleaner_anatomy.png | Bin 18638 -> 0 bytes 100/images/log_compaction.png | Bin 41414 -> 0 bytes 100/images/log_consumer.png | Bin 139658 -> 0 bytes 100/images/mirror-maker.png | Bin 6579 -> 0 bytes 100/images/producer_consumer.png | Bin 8691 -> 0 bytes 100/images/streams-architecture-overview.jpg | Bin 420929 -> 0 bytes 100/images/streams-architecture-states.jpg | Bin 147338 -> 0 bytes 100/images/streams-architecture-tasks.jpg | Bin 130435 -> 0 bytes 100/images/streams-architecture-threads.jpg | Bin 153622 -> 0 bytes 100/images/streams-architecture-topology.jpg | Bin 182199 -> 0 bytes .../streams-cache-and-commit-interval.png | Bin 38648 -> 0 bytes 100/images/streams-concepts-topology.jpg | Bin 136983 -> 0 bytes 100/images/streams-interactive-queries-01.png | Bin 80976 -> 0 bytes 100/images/streams-interactive-queries-02.png | Bin 73218 -> 0 bytes 100/images/streams-interactive-queries-03.png | Bin 79879 -> 0 bytes .../streams-interactive-queries-api-01.png | Bin 84438 -> 0 bytes .../streams-interactive-queries-api-02.png | Bin 100725 -> 0 bytes 100/images/streams-stateful_operations.png | Bin 123213 -> 0 bytes 100/images/streams-table-duality-01.png | Bin 14534 -> 0 bytes 100/images/streams-table-duality-02.png | Bin 56736 -> 0 bytes 100/images/streams-table-duality-03.png | Bin 91331 -> 0 bytes 100/images/streams-table-updates-01.png | Bin 78069 -> 0 bytes 100/images/streams-table-updates-02.png | Bin 91880 -> 0 bytes 100/images/streams-welcome.png | Bin 80530 -> 0 bytes 100/images/tracking_high_level.png | Bin 82759 -> 0 bytes 100/implementation.html | 319 - 100/introduction.html | 209 - 100/javadoc/allclasses-frame.html | 420 - 100/javadoc/allclasses-noframe.html | 420 - 100/javadoc/constant-values.html | 2196 ---- 100/javadoc/deprecated-list.html | 1034 -- 100/javadoc/help-doc.html | 223 - 100/javadoc/index-all.html | 10050 ----------------- 100/javadoc/index.html | 75 - .../kafka/clients/admin/AbstractOptions.html | 296 - .../apache/kafka/clients/admin/AdminClient.html | 1180 -- .../kafka/clients/admin/AdminClientConfig.html | 651 -- .../clients/admin/AlterConfigsOptions.html | 304 - .../kafka/clients/admin/AlterConfigsResult.html | 258 - .../admin/AlterReplicaLogDirsOptions.html | 249 - .../admin/AlterReplicaLogDirsResult.html | 263 - .../org/apache/kafka/clients/admin/Config.html | 346 - .../apache/kafka/clients/admin/ConfigEntry.html | 399 - .../kafka/clients/admin/CreateAclsOptions.html | 251 - .../kafka/clients/admin/CreateAclsResult.html | 260 - .../clients/admin/CreatePartitionsOptions.html | 304 - .../clients/admin/CreatePartitionsResult.html | 260 - .../clients/admin/CreateTopicsOptions.html | 304 - .../kafka/clients/admin/CreateTopicsResult.html | 260 - .../kafka/clients/admin/DeleteAclsOptions.html | 251 - .../admin/DeleteAclsResult.FilterResult.html | 259 - .../admin/DeleteAclsResult.FilterResults.html | 243 - .../kafka/clients/admin/DeleteAclsResult.html | 288 - .../clients/admin/DeleteTopicsOptions.html | 251 - .../kafka/clients/admin/DeleteTopicsResult.html | 260 - .../clients/admin/DescribeAclsOptions.html | 251 - .../kafka/clients/admin/DescribeAclsResult.html | 242 - .../clients/admin/DescribeClusterOptions.html | 251 - .../clients/admin/DescribeClusterResult.html | 276 - .../clients/admin/DescribeConfigsOptions.html | 251 - .../clients/admin/DescribeConfigsResult.html | 260 - .../clients/admin/DescribeLogDirsOptions.html | 251 - .../clients/admin/DescribeLogDirsResult.html | 258 - .../admin/DescribeReplicaLogDirsOptions.html | 251 - ...eReplicaLogDirsResult.ReplicaLogDirInfo.html | 295 - .../admin/DescribeReplicaLogDirsResult.html | 277 - .../clients/admin/DescribeTopicsOptions.html | 251 - .../clients/admin/DescribeTopicsResult.html | 260 - .../kafka/clients/admin/KafkaAdminClient.html | 758 -- .../kafka/clients/admin/ListTopicsOptions.html | 311 - .../kafka/clients/admin/ListTopicsResult.html | 274 - .../kafka/clients/admin/NewPartitions.html | 338 - .../apache/kafka/clients/admin/NewTopic.html | 391 - .../kafka/clients/admin/TopicDescription.html | 339 - .../kafka/clients/admin/TopicListing.html | 317 - .../kafka/clients/admin/package-frame.html | 60 - .../kafka/clients/admin/package-summary.html | 380 - .../kafka/clients/admin/package-tree.html | 185 - .../clients/consumer/CommitFailedException.html | 274 - .../apache/kafka/clients/consumer/Consumer.html | 761 -- .../kafka/clients/consumer/ConsumerConfig.html | 1153 -- .../clients/consumer/ConsumerInterceptor.html | 309 - .../consumer/ConsumerRebalanceListener.html | 334 - .../kafka/clients/consumer/ConsumerRecord.html | 670 -- .../kafka/clients/consumer/ConsumerRecords.html | 422 - .../consumer/InvalidOffsetException.html | 312 - .../kafka/clients/consumer/KafkaConsumer.html | 1895 ---- .../kafka/clients/consumer/MockConsumer.html | 998 -- .../consumer/NoOffsetForPartitionException.html | 356 - .../clients/consumer/OffsetAndMetadata.html | 375 - .../clients/consumer/OffsetAndTimestamp.html | 336 - .../clients/consumer/OffsetCommitCallback.html | 244 - .../consumer/OffsetOutOfRangeException.html | 328 - .../clients/consumer/OffsetResetStrategy.html | 351 - .../kafka/clients/consumer/RangeAssignor.html | 330 - .../RetriableCommitFailedException.html | 347 - .../clients/consumer/RoundRobinAssignor.html | 357 - .../kafka/clients/consumer/StickyAssignor.html | 492 - .../kafka/clients/consumer/package-frame.html | 48 - .../kafka/clients/consumer/package-summary.html | 290 - .../kafka/clients/consumer/package-tree.html | 215 - .../producer/BufferExhaustedException.html | 272 - .../apache/kafka/clients/producer/Callback.html | 253 - .../kafka/clients/producer/KafkaProducer.html | 1015 -- .../kafka/clients/producer/MockProducer.html | 829 -- .../kafka/clients/producer/Partitioner.html | 276 - .../apache/kafka/clients/producer/Producer.html | 445 - .../kafka/clients/producer/ProducerConfig.html | 1047 -- .../clients/producer/ProducerInterceptor.html | 333 - .../kafka/clients/producer/ProducerRecord.html | 604 - .../kafka/clients/producer/RecordMetadata.html | 537 - .../kafka/clients/producer/package-frame.html | 35 - .../kafka/clients/producer/package-summary.html | 220 - .../kafka/clients/producer/package-tree.html | 180 - .../org/apache/kafka/common/Cluster.html | 630 -- .../apache/kafka/common/ClusterResource.html | 300 - .../kafka/common/ClusterResourceListener.html | 252 - .../org/apache/kafka/common/Configurable.html | 231 - .../org/apache/kafka/common/KafkaException.html | 308 - .../kafka/common/KafkaFuture.BiConsumer.html | 278 - .../kafka/common/KafkaFuture.Function.html | 276 - .../org/apache/kafka/common/KafkaFuture.html | 559 - 100/javadoc/org/apache/kafka/common/Metric.html | 259 - .../org/apache/kafka/common/MetricName.html | 414 - .../apache/kafka/common/MetricNameTemplate.html | 387 - 100/javadoc/org/apache/kafka/common/Node.html | 462 - .../org/apache/kafka/common/PartitionInfo.html | 402 - .../org/apache/kafka/common/TopicPartition.html | 345 - .../apache/kafka/common/TopicPartitionInfo.html | 358 - .../kafka/common/TopicPartitionReplica.html | 360 - .../kafka/common/acl/AccessControlEntry.html | 423 - .../common/acl/AccessControlEntryFilter.html | 498 - .../org/apache/kafka/common/acl/AclBinding.html | 385 - .../kafka/common/acl/AclBindingFilter.html | 457 - .../apache/kafka/common/acl/AclOperation.html | 602 - .../kafka/common/acl/AclPermissionType.html | 451 - .../apache/kafka/common/acl/package-frame.html | 28 - .../kafka/common/acl/package-summary.html | 183 - .../apache/kafka/common/acl/package-tree.html | 151 - .../annotation/InterfaceStability.Evolving.html | 164 - .../annotation/InterfaceStability.Stable.html | 169 - .../annotation/InterfaceStability.Unstable.html | 164 - .../common/annotation/InterfaceStability.html | 272 - .../kafka/common/annotation/package-frame.html | 26 - .../common/annotation/package-summary.html | 172 - .../kafka/common/annotation/package-tree.html | 141 - .../kafka/common/config/AbstractConfig.html | 696 -- .../org/apache/kafka/common/config/Config.html | 269 - .../common/config/ConfigDef.ConfigKey.html | 489 - .../common/config/ConfigDef.Importance.html | 356 - .../common/config/ConfigDef.NonEmptyString.html | 308 - .../kafka/common/config/ConfigDef.Range.html | 313 - .../common/config/ConfigDef.Recommender.html | 265 - .../kafka/common/config/ConfigDef.Type.html | 428 - .../common/config/ConfigDef.ValidList.html | 287 - .../common/config/ConfigDef.ValidString.html | 287 - .../common/config/ConfigDef.Validator.html | 240 - .../kafka/common/config/ConfigDef.Width.html | 368 - .../apache/kafka/common/config/ConfigDef.html | 1448 --- .../kafka/common/config/ConfigException.html | 301 - .../common/config/ConfigResource.Type.html | 356 - .../kafka/common/config/ConfigResource.html | 371 - .../apache/kafka/common/config/ConfigValue.html | 442 - .../apache/kafka/common/config/SaslConfigs.html | 765 -- .../apache/kafka/common/config/SslConfigs.html | 1009 -- .../apache/kafka/common/config/TopicConfig.html | 1046 -- .../kafka/common/config/package-frame.html | 48 - .../kafka/common/config/package-summary.html | 274 - .../kafka/common/config/package-tree.html | 184 - .../kafka/common/errors/ApiException.html | 352 - .../common/errors/AuthenticationException.html | 312 - .../common/errors/AuthorizationException.html | 300 - .../errors/BrokerNotAvailableException.html | 296 - .../errors/ClusterAuthorizationException.html | 301 - .../errors/ConcurrentTransactionsException.html | 282 - .../common/errors/ControllerMovedException.html | 296 - .../CoordinatorLoadInProgressException.html | 307 - .../CoordinatorNotAvailableException.html | 342 - .../common/errors/CorruptRecordException.html | 327 - .../common/errors/DisconnectException.html | 362 - .../errors/DuplicateSequenceException.html | 282 - .../errors/GroupAuthorizationException.html | 321 - .../GroupCoordinatorNotAvailableException.html | 382 - .../errors/GroupLoadInProgressException.html | 343 - .../errors/IllegalGenerationException.html | 320 - .../errors/IllegalSaslStateException.html | 304 - .../InconsistentGroupProtocolException.html | 296 - .../kafka/common/errors/InterruptException.html | 297 - .../InvalidCommitOffsetSizeException.html | 296 - .../errors/InvalidConfigurationException.html | 296 - .../errors/InvalidFetchSizeException.html | 296 - .../common/errors/InvalidGroupIdException.html | 296 - .../common/errors/InvalidMetadataException.html | 330 - .../common/errors/InvalidOffsetException.html | 303 - .../errors/InvalidPartitionsException.html | 296 - .../errors/InvalidPidMappingException.html | 282 - .../InvalidReplicaAssignmentException.html | 296 - .../InvalidReplicationFactorException.html | 296 - .../common/errors/InvalidRequestException.html | 299 - .../errors/InvalidRequiredAcksException.html | 282 - .../errors/InvalidSessionTimeoutException.html | 296 - .../errors/InvalidTimestampException.html | 297 - .../common/errors/InvalidTopicException.html | 324 - .../common/errors/InvalidTxnStateException.html | 282 - .../errors/InvalidTxnTimeoutException.html | 298 - .../common/errors/KafkaStorageException.html | 339 - .../errors/LeaderNotAvailableException.html | 308 - .../common/errors/LogDirNotFoundException.html | 309 - .../kafka/common/errors/NetworkException.html | 332 - .../common/errors/NotControllerException.html | 301 - .../common/errors/NotCoordinatorException.html | 306 - .../errors/NotCoordinatorForGroupException.html | 343 - .../NotEnoughReplicasAfterAppendException.html | 289 - .../errors/NotEnoughReplicasException.html | 326 - .../errors/NotLeaderForPartitionException.html | 331 - .../common/errors/OffsetMetadataTooLarge.html | 321 - .../errors/OffsetOutOfRangeException.html | 303 - .../errors/OperationNotAttemptedException.html | 284 - .../errors/OutOfOrderSequenceException.html | 292 - .../common/errors/PolicyViolationException.html | 297 - .../common/errors/ProducerFencedException.html | 286 - .../errors/ReassignmentInProgressException.html | 297 - .../errors/RebalanceInProgressException.html | 320 - .../errors/RecordBatchTooLargeException.html | 321 - .../common/errors/RecordTooLargeException.html | 369 - .../errors/ReplicaNotAvailableException.html | 308 - .../kafka/common/errors/RetriableException.html | 325 - .../errors/SaslAuthenticationException.html | 314 - .../errors/SecurityDisabledException.html | 297 - .../common/errors/SerializationException.html | 347 - .../errors/SslAuthenticationException.html | 310 - .../kafka/common/errors/TimeoutException.html | 326 - .../errors/TopicAuthorizationException.html | 333 - .../common/errors/TopicExistsException.html | 296 - .../TransactionCoordinatorFencedException.html | 296 - .../TransactionalIdAuthorizationException.html | 287 - .../common/errors/UnknownMemberIdException.html | 320 - .../errors/UnknownProducerIdException.html | 291 - .../common/errors/UnknownServerException.html | 322 - .../UnknownTopicOrPartitionException.html | 334 - .../UnsupportedForMessageFormatException.html | 298 - .../UnsupportedSaslMechanismException.html | 303 - .../errors/UnsupportedVersionException.html | 304 - .../kafka/common/errors/WakeupException.html | 274 - .../kafka/common/errors/package-frame.html | 94 - .../kafka/common/errors/package-summary.html | 544 - .../kafka/common/errors/package-tree.html | 246 - .../org/apache/kafka/common/header/Header.html | 232 - .../org/apache/kafka/common/header/Headers.html | 360 - .../kafka/common/header/package-frame.html | 21 - .../kafka/common/header/package-summary.html | 144 - .../kafka/common/header/package-tree.html | 136 - .../org/apache/kafka/common/package-frame.html | 41 - .../apache/kafka/common/package-summary.html | 254 - .../org/apache/kafka/common/package-tree.html | 165 - .../apache/kafka/common/resource/Resource.html | 444 - .../kafka/common/resource/ResourceFilter.html | 456 - .../kafka/common/resource/ResourceType.html | 484 - .../kafka/common/resource/package-frame.html | 25 - .../kafka/common/resource/package-summary.html | 165 - .../kafka/common/resource/package-tree.html | 148 - .../security/auth/AuthenticationContext.html | 244 - .../security/auth/DefaultPrincipalBuilder.html | 348 - .../common/security/auth/KafkaPrincipal.html | 454 - .../security/auth/KafkaPrincipalBuilder.html | 236 - .../auth/PlaintextAuthenticationContext.html | 303 - .../common/security/auth/PrincipalBuilder.html | 292 - .../auth/SaslAuthenticationContext.html | 320 - .../common/security/auth/SecurityProtocol.html | 472 - .../security/auth/SslAuthenticationContext.html | 318 - .../common/security/auth/package-frame.html | 34 - .../common/security/auth/package-summary.html | 205 - .../common/security/auth/package-tree.html | 161 - .../serialization/ByteArrayDeserializer.html | 336 - .../serialization/ByteArraySerializer.html | 342 - .../serialization/ByteBufferDeserializer.html | 336 - .../serialization/ByteBufferSerializer.html | 342 - .../common/serialization/BytesDeserializer.html | 336 - .../common/serialization/BytesSerializer.html | 342 - .../common/serialization/Deserializer.html | 295 - .../serialization/DoubleDeserializer.html | 336 - .../common/serialization/DoubleSerializer.html | 342 - .../ExtendedDeserializer.Wrapper.html | 399 - .../serialization/ExtendedDeserializer.html | 280 - .../ExtendedSerializer.Wrapper.html | 409 - .../serialization/ExtendedSerializer.html | 282 - .../common/serialization/FloatDeserializer.html | 336 - .../common/serialization/FloatSerializer.html | 342 - .../serialization/IntegerDeserializer.html | 336 - .../common/serialization/IntegerSerializer.html | 342 - .../common/serialization/LongDeserializer.html | 336 - .../common/serialization/LongSerializer.html | 342 - .../kafka/common/serialization/Serde.html | 294 - .../serialization/Serdes.ByteArraySerde.html | 255 - .../serialization/Serdes.ByteBufferSerde.html | 255 - .../common/serialization/Serdes.BytesSerde.html | 255 - .../serialization/Serdes.DoubleSerde.html | 255 - .../common/serialization/Serdes.FloatSerde.html | 255 - .../serialization/Serdes.IntegerSerde.html | 255 - .../common/serialization/Serdes.LongSerde.html | 255 - .../common/serialization/Serdes.ShortSerde.html | 255 - .../serialization/Serdes.StringSerde.html | 255 - .../serialization/Serdes.WrapperSerde.html | 357 - .../kafka/common/serialization/Serdes.html | 465 - .../kafka/common/serialization/Serializer.html | 302 - .../common/serialization/ShortDeserializer.html | 336 - .../common/serialization/ShortSerializer.html | 342 - .../serialization/StringDeserializer.html | 338 - .../common/serialization/StringSerializer.html | 344 - .../common/serialization/package-frame.html | 58 - .../common/serialization/package-summary.html | 309 - .../common/serialization/package-tree.html | 190 - .../kafka/connect/connector/ConnectRecord.html | 448 - .../kafka/connect/connector/Connector.html | 531 - .../connect/connector/ConnectorContext.html | 246 - .../apache/kafka/connect/connector/Task.html | 277 - .../kafka/connect/connector/package-frame.html | 26 - .../connect/connector/package-summary.html | 175 - .../kafka/connect/connector/package-tree.html | 141 - .../kafka/connect/data/ConnectSchema.html | 746 -- .../org/apache/kafka/connect/data/Date.html | 375 - .../org/apache/kafka/connect/data/Decimal.html | 402 - .../org/apache/kafka/connect/data/Field.html | 357 - .../apache/kafka/connect/data/Schema.Type.html | 547 - .../org/apache/kafka/connect/data/Schema.html | 731 -- .../kafka/connect/data/SchemaAndValue.html | 371 - .../kafka/connect/data/SchemaBuilder.html | 1030 -- .../kafka/connect/data/SchemaProjector.html | 291 - .../org/apache/kafka/connect/data/Struct.html | 681 -- .../org/apache/kafka/connect/data/Time.html | 375 - .../apache/kafka/connect/data/Timestamp.html | 373 - .../kafka/connect/data/package-frame.html | 37 - .../kafka/connect/data/package-summary.html | 236 - .../apache/kafka/connect/data/package-tree.html | 160 - .../connect/errors/AlreadyExistsException.html | 302 - .../kafka/connect/errors/ConnectException.html | 301 - .../kafka/connect/errors/DataException.html | 306 - .../errors/IllegalWorkerStateException.html | 302 - .../kafka/connect/errors/NotFoundException.html | 302 - .../connect/errors/RetriableException.html | 302 - .../connect/errors/SchemaBuilderException.html | 306 - .../errors/SchemaProjectorException.html | 306 - .../kafka/connect/errors/package-frame.html | 27 - .../kafka/connect/errors/package-summary.html | 180 - .../kafka/connect/errors/package-tree.html | 164 - .../kafka/connect/sink/SinkConnector.html | 305 - .../apache/kafka/connect/sink/SinkRecord.html | 424 - .../org/apache/kafka/connect/sink/SinkTask.html | 581 - .../kafka/connect/sink/SinkTaskContext.html | 362 - .../kafka/connect/sink/package-frame.html | 26 - .../kafka/connect/sink/package-summary.html | 172 - .../apache/kafka/connect/sink/package-tree.html | 149 - .../kafka/connect/source/SourceConnector.html | 264 - .../kafka/connect/source/SourceRecord.html | 502 - .../apache/kafka/connect/source/SourceTask.html | 455 - .../kafka/connect/source/SourceTaskContext.html | 224 - .../kafka/connect/source/package-frame.html | 26 - .../kafka/connect/source/package-summary.html | 175 - .../kafka/connect/source/package-tree.html | 149 - .../apache/kafka/connect/storage/Converter.html | 289 - .../connect/storage/OffsetStorageReader.html | 272 - .../kafka/connect/storage/StringConverter.html | 354 - .../kafka/connect/storage/package-frame.html | 25 - .../kafka/connect/storage/package-summary.html | 167 - .../kafka/connect/storage/package-tree.html | 140 - .../connect/transforms/Transformation.html | 281 - .../kafka/connect/transforms/package-frame.html | 20 - .../connect/transforms/package-summary.html | 142 - .../kafka/connect/transforms/package-tree.html | 144 - .../kafka/connect/util/ConnectorUtils.html | 288 - .../kafka/connect/util/package-frame.html | 20 - .../kafka/connect/util/package-summary.html | 142 - .../apache/kafka/connect/util/package-tree.html | 135 - .../AlterConfigPolicy.RequestMetadata.html | 314 - .../kafka/server/policy/AlterConfigPolicy.html | 283 - .../CreateTopicPolicy.RequestMetadata.html | 384 - .../kafka/server/policy/CreateTopicPolicy.html | 282 - .../kafka/server/policy/package-frame.html | 26 - .../kafka/server/policy/package-summary.html | 171 - .../kafka/server/policy/package-tree.html | 151 - .../org/apache/kafka/streams/Consumed.html | 567 - .../kafka/streams/KafkaClientSupplier.html | 280 - .../kafka/streams/KafkaStreams.State.html | 457 - .../streams/KafkaStreams.StateListener.html | 234 - .../org/apache/kafka/streams/KafkaStreams.html | 958 -- .../org/apache/kafka/streams/KeyValue.html | 411 - .../apache/kafka/streams/StreamsBuilder.html | 867 -- .../streams/StreamsConfig.InternalConfig.html | 279 - .../org/apache/kafka/streams/StreamsConfig.html | 1571 --- .../apache/kafka/streams/StreamsMetrics.html | 456 - .../kafka/streams/Topology.AutoOffsetReset.html | 346 - .../org/apache/kafka/streams/Topology.html | 1242 -- .../TopologyDescription.GlobalStore.html | 256 - .../kafka/streams/TopologyDescription.Node.html | 279 - .../streams/TopologyDescription.Processor.html | 243 - .../kafka/streams/TopologyDescription.Sink.html | 243 - .../streams/TopologyDescription.Source.html | 243 - .../TopologyDescription.Subtopology.html | 255 - .../kafka/streams/TopologyDescription.html | 306 - .../streams/errors/BrokerNotFoundException.html | 304 - ...nHandler.DeserializationHandlerResponse.html | 399 - .../errors/DeserializationExceptionHandler.html | 271 - .../errors/InvalidStateStoreException.html | 308 - .../kafka/streams/errors/LockException.html | 303 - .../errors/LogAndContinueExceptionHandler.html | 328 - .../errors/LogAndFailExceptionHandler.html | 328 - .../streams/errors/ProcessorStateException.html | 303 - .../kafka/streams/errors/StreamsException.html | 301 - .../streams/errors/TaskAssignmentException.html | 304 - .../streams/errors/TaskIdFormatException.html | 304 - .../streams/errors/TaskMigratedException.html | 309 - .../errors/TopologyBuilderException.html | 315 - .../kafka/streams/errors/TopologyException.html | 303 - .../kafka/streams/errors/package-frame.html | 42 - .../kafka/streams/errors/package-summary.html | 263 - .../kafka/streams/errors/package-tree.html | 185 - .../kafka/streams/kstream/Aggregator.html | 259 - .../kafka/streams/kstream/ForeachAction.html | 246 - .../kafka/streams/kstream/GlobalKTable.html | 212 - .../kafka/streams/kstream/Initializer.html | 242 - .../kafka/streams/kstream/JoinWindows.html | 555 - .../apache/kafka/streams/kstream/Joined.html | 446 - .../kafka/streams/kstream/KGroupedStream.html | 2364 ---- .../kafka/streams/kstream/KGroupedTable.html | 1360 --- .../apache/kafka/streams/kstream/KStream.html | 3817 ------- .../kafka/streams/kstream/KStreamBuilder.html | 1995 ---- .../apache/kafka/streams/kstream/KTable.html | 3467 ------ .../kafka/streams/kstream/KeyValueMapper.html | 262 - .../kafka/streams/kstream/Materialized.html | 667 -- .../apache/kafka/streams/kstream/Merger.html | 242 - .../apache/kafka/streams/kstream/Predicate.html | 249 - .../apache/kafka/streams/kstream/Printed.html | 443 - .../apache/kafka/streams/kstream/Produced.html | 548 - .../apache/kafka/streams/kstream/Reducer.html | 254 - .../kafka/streams/kstream/Serialized.html | 393 - .../streams/kstream/SessionWindowedKStream.html | 544 - .../kafka/streams/kstream/SessionWindows.html | 355 - .../streams/kstream/TimeWindowedKStream.html | 548 - .../kafka/streams/kstream/TimeWindows.html | 520 - .../kafka/streams/kstream/Transformer.html | 351 - .../streams/kstream/TransformerSupplier.html | 242 - .../kafka/streams/kstream/UnlimitedWindows.html | 469 - .../kafka/streams/kstream/ValueJoiner.html | 259 - .../kafka/streams/kstream/ValueMapper.html | 249 - .../kafka/streams/kstream/ValueTransformer.html | 352 - .../kstream/ValueTransformerSupplier.html | 240 - .../apache/kafka/streams/kstream/Window.html | 438 - .../apache/kafka/streams/kstream/Windowed.html | 366 - .../apache/kafka/streams/kstream/Windows.html | 429 - .../kafka/streams/kstream/package-frame.html | 55 - .../kafka/streams/kstream/package-summary.html | 353 - .../kafka/streams/kstream/package-tree.html | 177 - .../org/apache/kafka/streams/package-frame.html | 44 - .../apache/kafka/streams/package-summary.html | 274 - .../org/apache/kafka/streams/package-tree.html | 174 - ...bstractNotifyingBatchingRestoreCallback.html | 402 - .../AbstractNotifyingRestoreCallback.html | 378 - .../streams/processor/AbstractProcessor.html | 375 - .../processor/BatchingStateRestoreCallback.html | 247 - .../kafka/streams/processor/Cancellable.html | 227 - .../processor/DefaultPartitionGrouper.html | 312 - .../processor/FailOnInvalidTimestamp.html | 342 - .../processor/LogAndSkipOnInvalidTimestamp.html | 343 - .../streams/processor/PartitionGrouper.html | 249 - .../kafka/streams/processor/Processor.html | 311 - .../streams/processor/ProcessorContext.html | 693 -- .../streams/processor/ProcessorSupplier.html | 236 - .../streams/processor/PunctuationType.html | 349 - .../kafka/streams/processor/Punctuator.html | 231 - .../streams/processor/StateRestoreCallback.html | 232 - .../streams/processor/StateRestoreListener.html | 315 - .../kafka/streams/processor/StateStore.html | 338 - .../streams/processor/StateStoreSupplier.html | 305 - .../streams/processor/StreamPartitioner.html | 268 - .../apache/kafka/streams/processor/TaskId.html | 466 - .../kafka/streams/processor/TaskMetadata.html | 336 - .../kafka/streams/processor/ThreadMetadata.html | 366 - .../streams/processor/TimestampExtractor.html | 252 - .../TopologyBuilder.AutoOffsetReset.html | 344 - .../processor/TopologyBuilder.TopicsInfo.html | 394 - .../streams/processor/TopologyBuilder.html | 1680 --- .../UsePreviousTimeOnInvalidTimestamp.html | 342 - .../processor/WallclockTimestampExtractor.html | 301 - .../kafka/streams/processor/package-frame.html | 53 - .../streams/processor/package-summary.html | 335 - .../kafka/streams/processor/package-tree.html | 179 - .../apache/kafka/streams/state/HostInfo.html | 348 - .../state/KeyValueBytesStoreSupplier.html | 192 - .../kafka/streams/state/KeyValueIterator.html | 270 - .../kafka/streams/state/KeyValueStore.html | 337 - .../kafka/streams/state/QueryableStoreType.html | 268 - .../streams/state/QueryableStoreTypes.html | 328 - .../streams/state/ReadOnlyKeyValueStore.html | 326 - .../streams/state/ReadOnlySessionStore.html | 281 - .../streams/state/ReadOnlyWindowStore.html | 313 - .../streams/state/RocksDBConfigSetter.html | 234 - .../state/SessionBytesStoreSupplier.html | 240 - .../kafka/streams/state/SessionStore.html | 357 - .../apache/kafka/streams/state/StateSerdes.html | 546 - .../kafka/streams/state/StoreBuilder.html | 357 - .../kafka/streams/state/StoreSupplier.html | 276 - .../state/Stores.InMemoryKeyValueFactory.html | 316 - .../streams/state/Stores.KeyValueFactory.html | 254 - .../state/Stores.PersistentKeyValueFactory.html | 364 - .../streams/state/Stores.StoreFactory.html | 424 - .../streams/state/Stores.ValueFactory.html | 429 - .../org/apache/kafka/streams/state/Stores.html | 585 - .../kafka/streams/state/StreamsMetadata.html | 422 - .../streams/state/WindowBytesStoreSupplier.html | 303 - .../apache/kafka/streams/state/WindowStore.html | 289 - .../streams/state/WindowStoreIterator.html | 254 - .../kafka/streams/state/package-frame.html | 47 - .../kafka/streams/state/package-summary.html | 294 - .../kafka/streams/state/package-tree.html | 202 - 100/javadoc/overview-frame.html | 46 - 100/javadoc/overview-summary.html | 236 - 100/javadoc/overview-tree.html | 716 -- 100/javadoc/package-list | 26 - 100/javadoc/script.js | 30 - 100/javadoc/serialized-form.html | 1108 -- 100/javadoc/stylesheet.css | 574 - 100/js/templateData.js | 24 - 100/migration.html | 34 - 100/ops.html | 1564 --- 100/protocol.html | 230 - 100/quickstart.html | 300 - 100/security.html | 931 -- 100/streams/architecture.html | 160 - 100/streams/core-concepts.html | 187 - 100/streams/developer-guide.html | 3001 ----- 100/streams/index.html | 338 - 100/streams/quickstart.html | 361 - 100/streams/tutorial.html | 638 -- 100/streams/upgrade-guide.html | 390 - 100/toc.html | 158 - 100/upgrade.html | 602 - 100/uses.html | 81 - documentation.html | 2 +- downloads.html | 107 +- intro.html | 2 +- protocol.html | 2 +- quickstart.html | 2 +- 1169 files changed, 206983 insertions(+), 206935 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka-site/blob/2e200cfc/10/api.html ---------------------------------------------------------------------- diff --git a/10/api.html b/10/api.html new file mode 100644 index 0000000..9777186 --- /dev/null +++ b/10/api.html @@ -0,0 +1,113 @@ +<!-- + Licensed to the Apache Software Foundation (ASF) under one or more + contributor license agreements. See the NOTICE file distributed with + this work for additional information regarding copyright ownership. + The ASF licenses this file to You under the Apache License, Version 2.0 + (the "License"); you may not use this file except in compliance with + the License. You may obtain a copy of the License at + + http://www.apache.org/licenses/LICENSE-2.0 + + Unless required by applicable law or agreed to in writing, software + distributed under the License is distributed on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + See the License for the specific language governing permissions and + limitations under the License. +--> +<script id="api-template" type="text/x-handlebars-template"> + Kafka includes five core apis: + <ol> + <li>The <a href="#producerapi">Producer</a> API allows applications to send streams of data to topics in the Kafka cluster. + <li>The <a href="#consumerapi">Consumer</a> API allows applications to read streams of data from topics in the Kafka cluster. + <li>The <a href="#streamsapi">Streams</a> API allows transforming streams of data from input topics to output topics. + <li>The <a href="#connectapi">Connect</a> API allows implementing connectors that continually pull from some source system or application into Kafka or push from Kafka into some sink system or application. + <li>The <a href="#adminapi">AdminClient</a> API allows managing and inspecting topics, brokers, and other Kafka objects. + </ol> + + Kafka exposes all its functionality over a language independent protocol which has clients available in many programming languages. However only the Java clients are maintained as part of the main Kafka project, the others are available as independent open source projects. A list of non-Java clients is available <a href="https://cwiki.apache.org/confluence/display/KAFKA/Clients";>here</a>. + + <h3><a id="producerapi" href="#producerapi">2.1 Producer API</a></h3> + + The Producer API allows applications to send streams of data to topics in the Kafka cluster. + <p> + Examples showing how to use the producer are given in the + <a href="/{{version}}/javadoc/index.html?org/apache/kafka/clients/producer/KafkaProducer.html" title="Kafka {{dotVersion}} Javadoc">javadocs</a>. + <p> + To use the producer, you can use the following maven dependency: + + <pre class="brush: xml;"> + <dependency> + <groupId>org.apache.kafka</groupId> + <artifactId>kafka-clients</artifactId> + <version>{{fullDotVersion}}</version> + </dependency> + </pre> + + <h3><a id="consumerapi" href="#consumerapi">2.2 Consumer API</a></h3> + + The Consumer API allows applications to read streams of data from topics in the Kafka cluster. + <p> + Examples showing how to use the consumer are given in the + <a href="/{{version}}/javadoc/index.html?org/apache/kafka/clients/consumer/KafkaConsumer.html" title="Kafka {{dotVersion}} Javadoc">javadocs</a>. + <p> + To use the consumer, you can use the following maven dependency: + <pre class="brush: xml;"> + <dependency> + <groupId>org.apache.kafka</groupId> + <artifactId>kafka-clients</artifactId> + <version>{{fullDotVersion}}</version> + </dependency> + </pre> + + <h3><a id="streamsapi" href="#streamsapi">2.3 Streams API</a></h3> + + The <a href="#streamsapi">Streams</a> API allows transforming streams of data from input topics to output topics. + <p> + Examples showing how to use this library are given in the + <a href="/{{version}}/javadoc/index.html?org/apache/kafka/streams/KafkaStreams.html" title="Kafka {{dotVersion}} Javadoc">javadocs</a> + <p> + Additional documentation on using the Streams API is available <a href="/{{version}}/documentation/streams">here</a>. + <p> + To use Kafka Streams you can use the following maven dependency: + + <pre class="brush: xml;"> + <dependency> + <groupId>org.apache.kafka</groupId> + <artifactId>kafka-streams</artifactId> + <version>{{fullDotVersion}}</version> + </dependency> + </pre> + + <h3><a id="connectapi" href="#connectapi">2.4 Connect API</a></h3> + + The Connect API allows implementing connectors that continually pull from some source data system into Kafka or push from Kafka into some sink data system. + <p> + Many users of Connect won't need to use this API directly, though, they can use pre-built connectors without needing to write any code. Additional information on using Connect is available <a href="/documentation.html#connect">here</a>. + <p> + Those who want to implement custom connectors can see the <a href="/{{version}}/javadoc/index.html?org/apache/kafka/connect" title="Kafka {{dotVersion}} Javadoc">javadoc</a>. + <p> + + <h3><a id="adminapi" href="#adminapi">2.5 AdminClient API</a></h3> + + The AdminClient API supports managing and inspecting topics, brokers, acls, and other Kafka objects. + <p> + To use the AdminClient API, add the following Maven dependency: + <pre class="brush: xml;"> + <dependency> + <groupId>org.apache.kafka</groupId> + <artifactId>kafka-clients</artifactId> + <version>{{fullDotVersion}}</version> + </dependency> + </pre> + For more information about the AdminClient APIs, see the <a href="/{{version}}/javadoc/index.html?org/apache/kafka/clients/admin/AdminClient.html" title="Kafka {{dotVersion}} Javadoc">javadoc</a>. + <p> + + <h3><a id="legacyapis" href="#legacyapis">2.6 Legacy APIs</a></h3> + + <p> + A more limited legacy producer and consumer api is also included in Kafka. These old Scala APIs are deprecated and only still available for compatibility purposes. Information on them can be found here <a href="/081/documentation.html#producerapi" title="Kafka 0.8.1 Docs"> + here</a>. + </p> +</script> + +<div class="p-api"></div>
