You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2017/11/01 22:41:13 UTC
[51/51] [partial] kafka-site git commit: MINOR: Follow-up Update on
1.0.0 release
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 <wa...@gmail.com>
Reviewers: Ismael Juma <is...@juma.me.uk>
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 <wa...@gmail.com>
Authored: Wed Nov 1 15:40:16 2017 -0700
Committer: Guozhang Wang <wa...@gmail.com>
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>