You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ij...@apache.org on 2016/05/19 00:02:41 UTC
[51/51] [partial] kafka-site git commit: Update javadoc for 0.10 to
include connect and streams
Update javadoc for 0.10 to include connect and streams
Project: http://git-wip-us.apache.org/repos/asf/kafka-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka-site/commit/af5a933b
Tree: http://git-wip-us.apache.org/repos/asf/kafka-site/tree/af5a933b
Diff: http://git-wip-us.apache.org/repos/asf/kafka-site/diff/af5a933b
Branch: refs/heads/asf-site
Commit: af5a933bb7e5e9f34f6bbcdd88e9b608ddf6dccf
Parents: b91f790
Author: Ismael Juma <is...@juma.me.uk>
Authored: Thu May 19 01:01:22 2016 +0100
Committer: Ismael Juma <is...@juma.me.uk>
Committed: Thu May 19 01:01:22 2016 +0100
----------------------------------------------------------------------
0100/javadoc/allclasses-frame.html | 102 +-
0100/javadoc/allclasses-noframe.html | 102 +-
0100/javadoc/constant-values.html | 565 +++-
0100/javadoc/deprecated-list.html | 34 +-
0100/javadoc/help-doc.html | 8 +-
0100/javadoc/index-all.html | 2451 +++++++++++++++++-
0100/javadoc/index.html | 4 +-
.../javaapi/consumer/ConsumerConnector.html | 361 ---
.../consumer/ConsumerRebalanceListener.html | 236 --
.../kafka/javaapi/consumer/package-frame.html | 20 -
.../kafka/javaapi/consumer/package-summary.html | 136 -
.../kafka/javaapi/consumer/package-tree.html | 117 -
.../clients/consumer/CommitFailedException.html | 30 +-
.../apache/kafka/clients/consumer/Consumer.html | 82 +-
.../kafka/clients/consumer/ConsumerConfig.html | 166 +-
.../clients/consumer/ConsumerInterceptor.html | 12 +-
.../consumer/ConsumerRebalanceListener.html | 16 +-
.../kafka/clients/consumer/ConsumerRecord.html | 34 +-
.../kafka/clients/consumer/ConsumerRecords.html | 48 +-
.../consumer/InvalidOffsetException.html | 34 +-
.../kafka/clients/consumer/KafkaConsumer.html | 116 +-
.../kafka/clients/consumer/MockConsumer.html | 112 +-
.../consumer/NoOffsetForPartitionException.html | 30 +-
.../clients/consumer/OffsetAndMetadata.html | 42 +-
.../clients/consumer/OffsetCommitCallback.html | 16 +-
.../consumer/OffsetOutOfRangeException.html | 38 +-
.../clients/consumer/OffsetResetStrategy.html | 32 +-
.../kafka/clients/consumer/RangeAssignor.html | 28 +-
.../RetriableCommitFailedException.html | 38 +-
.../clients/consumer/RoundRobinAssignor.html | 38 +-
.../kafka/clients/consumer/package-frame.html | 6 +-
.../kafka/clients/consumer/package-summary.html | 8 +-
.../kafka/clients/consumer/package-tree.html | 28 +-
.../producer/BufferExhaustedException.html | 30 +-
.../apache/kafka/clients/producer/Callback.html | 12 +-
.../kafka/clients/producer/KafkaProducer.html | 70 +-
.../kafka/clients/producer/MockProducer.html | 54 +-
.../kafka/clients/producer/Partitioner.html | 20 +-
.../apache/kafka/clients/producer/Producer.html | 40 +-
.../kafka/clients/producer/ProducerConfig.html | 168 +-
.../clients/producer/ProducerInterceptor.html | 12 +-
.../kafka/clients/producer/ProducerRecord.html | 70 +-
.../kafka/clients/producer/RecordMetadata.html | 28 +-
.../kafka/clients/producer/package-frame.html | 6 +-
.../kafka/clients/producer/package-summary.html | 8 +-
.../kafka/clients/producer/package-tree.html | 20 +-
.../org/apache/kafka/common/Cluster.html | 76 +-
.../org/apache/kafka/common/Configurable.html | 12 +-
.../org/apache/kafka/common/KafkaException.html | 46 +-
.../javadoc/org/apache/kafka/common/Metric.html | 8 +-
.../org/apache/kafka/common/MetricName.html | 118 +-
0100/javadoc/org/apache/kafka/common/Node.html | 54 +-
.../org/apache/kafka/common/PartitionInfo.html | 30 +-
.../org/apache/kafka/common/TopicPartition.html | 42 +-
.../kafka/common/config/AbstractConfig.html | 142 +-
.../org/apache/kafka/common/config/Config.html | 24 +-
.../common/config/ConfigDef.ConfigKey.html | 64 +-
.../common/config/ConfigDef.Importance.html | 32 +-
.../kafka/common/config/ConfigDef.Range.html | 42 +-
.../common/config/ConfigDef.Recommender.html | 26 +-
.../kafka/common/config/ConfigDef.Type.html | 32 +-
.../common/config/ConfigDef.ValidString.html | 34 +-
.../common/config/ConfigDef.Validator.html | 16 +-
.../kafka/common/config/ConfigDef.Width.html | 32 +-
.../apache/kafka/common/config/ConfigDef.html | 342 +--
.../kafka/common/config/ConfigException.html | 50 +-
.../apache/kafka/common/config/ConfigValue.html | 78 +-
.../apache/kafka/common/config/SaslConfigs.html | 100 +-
.../apache/kafka/common/config/SslConfigs.html | 172 +-
.../kafka/common/config/package-frame.html | 6 +-
.../kafka/common/config/package-summary.html | 8 +-
.../kafka/common/config/package-tree.html | 22 +-
.../kafka/common/errors/ApiException.html | 48 +-
.../common/errors/AuthenticationException.html | 38 +-
.../common/errors/AuthorizationException.html | 38 +-
.../errors/BrokerNotAvailableException.html | 38 +-
.../errors/ClusterAuthorizationException.html | 38 +-
.../common/errors/ControllerMovedException.html | 38 +-
.../common/errors/CorruptRecordException.html | 42 +-
.../common/errors/DisconnectException.html | 42 +-
.../errors/GroupAuthorizationException.html | 34 +-
.../GroupCoordinatorNotAvailableException.html | 42 +-
.../errors/GroupLoadInProgressException.html | 42 +-
.../errors/IllegalGenerationException.html | 42 +-
.../errors/IllegalSaslStateException.html | 38 +-
.../InconsistentGroupProtocolException.html | 38 +-
.../kafka/common/errors/InterruptException.html | 42 +-
.../InvalidCommitOffsetSizeException.html | 38 +-
.../errors/InvalidFetchSizeException.html | 38 +-
.../common/errors/InvalidGroupIdException.html | 38 +-
.../common/errors/InvalidMetadataException.html | 42 +-
.../common/errors/InvalidOffsetException.html | 38 +-
.../errors/InvalidRequiredAcksException.html | 30 +-
.../errors/InvalidSessionTimeoutException.html | 38 +-
.../errors/InvalidTimestampException.html | 38 +-
.../common/errors/InvalidTopicException.html | 42 +-
.../errors/LeaderNotAvailableException.html | 38 +-
.../kafka/common/errors/NetworkException.html | 42 +-
.../errors/NotCoordinatorForGroupException.html | 42 +-
.../NotEnoughReplicasAfterAppendException.html | 30 +-
.../errors/NotEnoughReplicasException.html | 42 +-
.../errors/NotLeaderForPartitionException.html | 42 +-
.../common/errors/OffsetMetadataTooLarge.html | 42 +-
.../errors/OffsetOutOfRangeException.html | 38 +-
.../errors/RebalanceInProgressException.html | 42 +-
.../errors/RecordBatchTooLargeException.html | 42 +-
.../common/errors/RecordTooLargeException.html | 54 +-
.../errors/ReplicaNotAvailableException.html | 42 +-
.../kafka/common/errors/RetriableException.html | 42 +-
.../common/errors/SerializationException.html | 48 +-
.../kafka/common/errors/TimeoutException.html | 42 +-
.../errors/TopicAuthorizationException.html | 38 +-
.../common/errors/UnknownMemberIdException.html | 42 +-
.../common/errors/UnknownServerException.html | 42 +-
.../UnknownTopicOrPartitionException.html | 42 +-
.../UnsupportedSaslMechanismException.html | 38 +-
.../errors/UnsupportedVersionException.html | 38 +-
.../kafka/common/errors/WakeupException.html | 26 +-
.../kafka/common/errors/package-frame.html | 6 +-
.../kafka/common/errors/package-summary.html | 8 +-
.../kafka/common/errors/package-tree.html | 16 +-
.../org/apache/kafka/common/package-frame.html | 6 +-
.../apache/kafka/common/package-summary.html | 8 +-
.../org/apache/kafka/common/package-tree.html | 18 +-
.../serialization/ByteArrayDeserializer.html | 30 +-
.../serialization/ByteArraySerializer.html | 30 +-
.../serialization/ByteBufferDeserializer.html | 42 +-
.../serialization/ByteBufferSerializer.html | 42 +-
.../common/serialization/BytesDeserializer.html | 30 +-
.../common/serialization/BytesSerializer.html | 30 +-
.../common/serialization/Deserializer.html | 24 +-
.../serialization/DoubleDeserializer.html | 42 +-
.../common/serialization/DoubleSerializer.html | 42 +-
.../serialization/IntegerDeserializer.html | 42 +-
.../common/serialization/IntegerSerializer.html | 42 +-
.../common/serialization/LongDeserializer.html | 42 +-
.../common/serialization/LongSerializer.html | 42 +-
.../kafka/common/serialization/Serde.html | 20 +-
.../serialization/Serdes.ByteArraySerde.html | 18 +-
.../serialization/Serdes.ByteBufferSerde.html | 18 +-
.../common/serialization/Serdes.BytesSerde.html | 18 +-
.../serialization/Serdes.DoubleSerde.html | 18 +-
.../serialization/Serdes.IntegerSerde.html | 18 +-
.../common/serialization/Serdes.LongSerde.html | 18 +-
.../serialization/Serdes.StringSerde.html | 18 +-
.../kafka/common/serialization/Serdes.html | 40 +-
.../kafka/common/serialization/Serializer.html | 24 +-
.../serialization/StringDeserializer.html | 42 +-
.../common/serialization/StringSerializer.html | 42 +-
.../common/serialization/package-frame.html | 6 +-
.../common/serialization/package-summary.html | 12 +-
.../common/serialization/package-tree.html | 18 +-
.../kafka/connect/connector/ConnectRecord.html | 409 +++
.../kafka/connect/connector/Connector.html | 490 ++++
.../connect/connector/ConnectorContext.html | 229 ++
.../apache/kafka/connect/connector/Task.html | 257 ++
.../kafka/connect/connector/package-frame.html | 25 +
.../connect/connector/package-summary.html | 166 ++
.../kafka/connect/connector/package-tree.html | 132 +
.../kafka/connect/data/ConnectSchema.html | 678 +++++
.../org/apache/kafka/connect/data/Date.html | 350 +++
.../org/apache/kafka/connect/data/Decimal.html | 373 +++
.../org/apache/kafka/connect/data/Field.html | 333 +++
.../apache/kafka/connect/data/Schema.Type.html | 468 ++++
.../org/apache/kafka/connect/data/Schema.html | 679 +++++
.../kafka/connect/data/SchemaAndValue.html | 356 +++
.../kafka/connect/data/SchemaBuilder.html | 874 +++++++
.../kafka/connect/data/SchemaProjector.html | 270 ++
.../org/apache/kafka/connect/data/Struct.html | 621 +++++
.../org/apache/kafka/connect/data/Time.html | 350 +++
.../apache/kafka/connect/data/Timestamp.html | 348 +++
.../kafka/connect/data/package-frame.html | 36 +
.../kafka/connect/data/package-summary.html | 227 ++
.../apache/kafka/connect/data/package-tree.html | 151 ++
.../connect/errors/AlreadyExistsException.html | 290 +++
.../kafka/connect/errors/ConnectException.html | 290 +++
.../kafka/connect/errors/DataException.html | 294 +++
.../errors/IllegalWorkerStateException.html | 290 +++
.../kafka/connect/errors/NotFoundException.html | 290 +++
.../connect/errors/RetriableException.html | 290 +++
.../connect/errors/SchemaBuilderException.html | 294 +++
.../errors/SchemaProjectorException.html | 294 +++
.../kafka/connect/errors/package-frame.html | 26 +
.../kafka/connect/errors/package-summary.html | 171 ++
.../kafka/connect/errors/package-tree.html | 155 ++
.../kafka/connect/sink/SinkConnector.html | 294 +++
.../apache/kafka/connect/sink/SinkRecord.html | 333 +++
.../org/apache/kafka/connect/sink/SinkTask.html | 521 ++++
.../kafka/connect/sink/SinkTaskContext.html | 310 +++
.../kafka/connect/sink/package-frame.html | 25 +
.../kafka/connect/sink/package-summary.html | 163 ++
.../apache/kafka/connect/sink/package-tree.html | 140 +
.../kafka/connect/source/SourceConnector.html | 256 ++
.../kafka/connect/source/SourceRecord.html | 427 +++
.../apache/kafka/connect/source/SourceTask.html | 431 +++
.../kafka/connect/source/SourceTaskContext.html | 210 ++
.../kafka/connect/source/package-frame.html | 25 +
.../kafka/connect/source/package-summary.html | 166 ++
.../kafka/connect/source/package-tree.html | 140 +
.../apache/kafka/connect/storage/Converter.html | 260 ++
.../connect/storage/OffsetStorageReader.html | 250 ++
.../kafka/connect/storage/StringConverter.html | 327 +++
.../kafka/connect/storage/package-frame.html | 24 +
.../kafka/connect/storage/package-summary.html | 158 ++
.../kafka/connect/storage/package-tree.html | 131 +
.../kafka/connect/util/ConnectorUtils.html | 270 ++
.../kafka/connect/util/package-frame.html | 19 +
.../kafka/connect/util/package-summary.html | 133 +
.../apache/kafka/connect/util/package-tree.html | 126 +
.../kafka/streams/KafkaClientSupplier.html | 246 ++
.../org/apache/kafka/streams/KafkaStreams.html | 379 +++
.../org/apache/kafka/streams/KeyValue.html | 381 +++
.../streams/StreamsConfig.InternalConfig.html | 267 ++
.../org/apache/kafka/streams/StreamsConfig.html | 758 ++++++
.../apache/kafka/streams/StreamsMetrics.html | 228 ++
.../streams/errors/ProcessorStateException.html | 290 +++
.../kafka/streams/errors/StreamsException.html | 290 +++
.../streams/errors/TaskAssignmentException.html | 290 +++
.../streams/errors/TaskIdFormatException.html | 264 ++
.../errors/TopologyBuilderException.html | 264 ++
.../kafka/streams/errors/package-frame.html | 23 +
.../kafka/streams/errors/package-summary.html | 157 ++
.../kafka/streams/errors/package-tree.html | 149 ++
.../kafka/streams/kstream/Aggregator.html | 217 ++
.../kafka/streams/kstream/ForeachAction.html | 217 ++
.../kafka/streams/kstream/Initializer.html | 210 ++
.../kafka/streams/kstream/JoinWindows.html | 427 +++
.../kafka/streams/kstream/KGroupedTable.html | 295 +++
.../apache/kafka/streams/kstream/KStream.html | 1198 +++++++++
.../kafka/streams/kstream/KStreamBuilder.html | 402 +++
.../apache/kafka/streams/kstream/KTable.html | 714 +++++
.../kafka/streams/kstream/KeyValueMapper.html | 215 ++
.../apache/kafka/streams/kstream/Predicate.html | 215 ++
.../apache/kafka/streams/kstream/Reducer.html | 215 ++
.../kafka/streams/kstream/TimeWindows.html | 404 +++
.../kafka/streams/kstream/Transformer.html | 272 ++
.../streams/kstream/TransformerSupplier.html | 209 ++
.../kafka/streams/kstream/UnlimitedWindows.html | 356 +++
.../kafka/streams/kstream/ValueJoiner.html | 215 ++
.../kafka/streams/kstream/ValueMapper.html | 213 ++
.../kafka/streams/kstream/ValueTransformer.html | 270 ++
.../kstream/ValueTransformerSupplier.html | 209 ++
.../apache/kafka/streams/kstream/Window.html | 332 +++
.../apache/kafka/streams/kstream/Windowed.html | 334 +++
.../apache/kafka/streams/kstream/Windows.html | 382 +++
.../kafka/streams/kstream/package-frame.html | 43 +
.../kafka/streams/kstream/package-summary.html | 273 ++
.../kafka/streams/kstream/package-tree.html | 157 ++
.../org/apache/kafka/streams/package-frame.html | 27 +
.../apache/kafka/streams/package-summary.html | 171 ++
.../org/apache/kafka/streams/package-tree.html | 138 +
.../streams/processor/AbstractProcessor.html | 348 +++
.../ConsumerRecordTimestampExtractor.html | 281 ++
.../processor/DefaultPartitionGrouper.html | 291 +++
.../streams/processor/PartitionGrouper.html | 223 ++
.../kafka/streams/processor/Processor.html | 275 ++
.../streams/processor/ProcessorContext.html | 517 ++++
.../streams/processor/ProcessorSupplier.html | 214 ++
.../streams/processor/StateRestoreCallback.html | 208 ++
.../kafka/streams/processor/StateStore.html | 287 ++
.../streams/processor/StateStoreSupplier.html | 226 ++
.../streams/processor/StreamPartitioner.html | 240 ++
.../apache/kafka/streams/processor/TaskId.html | 445 ++++
.../streams/processor/TimestampExtractor.html | 217 ++
.../processor/TopologyBuilder.TopicsInfo.html | 360 +++
.../streams/processor/TopologyBuilder.html | 707 +++++
.../processor/WallclockTimestampExtractor.html | 273 ++
.../kafka/streams/processor/package-frame.html | 37 +
.../streams/processor/package-summary.html | 234 ++
.../kafka/streams/processor/package-tree.html | 144 +
.../kafka/streams/state/KeyValueIterator.html | 224 ++
.../kafka/streams/state/KeyValueStore.html | 359 +++
.../apache/kafka/streams/state/StateSerdes.html | 476 ++++
.../state/Stores.InMemoryKeyValueFactory.html | 235 ++
.../streams/state/Stores.KeyValueFactory.html | 235 ++
.../state/Stores.PersistentKeyValueFactory.html | 235 ++
.../streams/state/Stores.StoreFactory.html | 383 +++
.../streams/state/Stores.ValueFactory.html | 385 +++
.../org/apache/kafka/streams/state/Stores.html | 303 +++
.../apache/kafka/streams/state/WindowStore.html | 275 ++
.../streams/state/WindowStoreIterator.html | 218 ++
.../kafka/streams/state/package-frame.html | 32 +
.../kafka/streams/state/package-summary.html | 202 ++
.../kafka/streams/state/package-tree.html | 156 ++
0100/javadoc/overview-frame.html | 18 +-
0100/javadoc/overview-summary.html | 58 +-
0100/javadoc/overview-tree.html | 169 +-
0100/javadoc/package-list | 12 +
0100/javadoc/serialized-form.html | 117 +-
289 files changed, 43548 insertions(+), 3976 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/allclasses-frame.html
----------------------------------------------------------------------
diff --git a/0100/javadoc/allclasses-frame.html b/0100/javadoc/allclasses-frame.html
index e189853..acd425e 100644
--- a/0100/javadoc/allclasses-frame.html
+++ b/0100/javadoc/allclasses-frame.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue May 17 21:36:38 PDT 2016 -->
-<title>All Classes (clients 0.10.0.0 API)</title>
-<meta name="date" content="2016-05-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu May 19 00:52:06 BST 2016 -->
+<title>All Classes (kafka 0.10.0.0 API)</title>
+<meta name="date" content="2016-05-19">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
</head>
<body>
@@ -12,6 +12,9 @@
<div class="indexContainer">
<ul>
<li><a href="org/apache/kafka/common/config/AbstractConfig.html" title="class in org.apache.kafka.common.config" target="classFrame">AbstractConfig</a></li>
+<li><a href="org/apache/kafka/streams/processor/AbstractProcessor.html" title="class in org.apache.kafka.streams.processor" target="classFrame">AbstractProcessor</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Aggregator.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>Aggregator</i></a></li>
+<li><a href="org/apache/kafka/connect/errors/AlreadyExistsException.html" title="class in org.apache.kafka.connect.errors" target="classFrame">AlreadyExistsException</a></li>
<li><a href="org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors" target="classFrame">ApiException</a></li>
<li><a href="org/apache/kafka/common/errors/AuthenticationException.html" title="class in org.apache.kafka.common.errors" target="classFrame">AuthenticationException</a></li>
<li><a href="org/apache/kafka/common/errors/AuthorizationException.html" title="class in org.apache.kafka.common.errors" target="classFrame">AuthorizationException</a></li>
@@ -40,24 +43,40 @@
<li><a href="org/apache/kafka/common/config/ConfigException.html" title="class in org.apache.kafka.common.config" target="classFrame">ConfigException</a></li>
<li><a href="org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common" target="classFrame"><i>Configurable</i></a></li>
<li><a href="org/apache/kafka/common/config/ConfigValue.html" title="class in org.apache.kafka.common.config" target="classFrame">ConfigValue</a></li>
+<li><a href="org/apache/kafka/connect/errors/ConnectException.html" title="class in org.apache.kafka.connect.errors" target="classFrame">ConnectException</a></li>
+<li><a href="org/apache/kafka/connect/connector/Connector.html" title="class in org.apache.kafka.connect.connector" target="classFrame">Connector</a></li>
+<li><a href="org/apache/kafka/connect/connector/ConnectorContext.html" title="interface in org.apache.kafka.connect.connector" target="classFrame"><i>ConnectorContext</i></a></li>
+<li><a href="org/apache/kafka/connect/util/ConnectorUtils.html" title="class in org.apache.kafka.connect.util" target="classFrame">ConnectorUtils</a></li>
+<li><a href="org/apache/kafka/connect/connector/ConnectRecord.html" title="class in org.apache.kafka.connect.connector" target="classFrame">ConnectRecord</a></li>
+<li><a href="org/apache/kafka/connect/data/ConnectSchema.html" title="class in org.apache.kafka.connect.data" target="classFrame">ConnectSchema</a></li>
<li><a href="org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer" target="classFrame"><i>Consumer</i></a></li>
<li><a href="org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer" target="classFrame">ConsumerConfig</a></li>
<li><a href="org/apache/kafka/clients/consumer/ConsumerInterceptor.html" title="interface in org.apache.kafka.clients.consumer" target="classFrame"><i>ConsumerInterceptor</i></a></li>
<li><a href="org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html" title="interface in org.apache.kafka.clients.consumer" target="classFrame"><i>ConsumerRebalanceListener</i></a></li>
<li><a href="org/apache/kafka/clients/consumer/ConsumerRecord.html" title="class in org.apache.kafka.clients.consumer" target="classFrame">ConsumerRecord</a></li>
<li><a href="org/apache/kafka/clients/consumer/ConsumerRecords.html" title="class in org.apache.kafka.clients.consumer" target="classFrame">ConsumerRecords</a></li>
+<li><a href="org/apache/kafka/streams/processor/ConsumerRecordTimestampExtractor.html" title="class in org.apache.kafka.streams.processor" target="classFrame">ConsumerRecordTimestampExtractor</a></li>
<li><a href="org/apache/kafka/common/errors/ControllerMovedException.html" title="class in org.apache.kafka.common.errors" target="classFrame">ControllerMovedException</a></li>
+<li><a href="org/apache/kafka/connect/storage/Converter.html" title="interface in org.apache.kafka.connect.storage" target="classFrame"><i>Converter</i></a></li>
<li><a href="org/apache/kafka/common/errors/CorruptRecordException.html" title="class in org.apache.kafka.common.errors" target="classFrame">CorruptRecordException</a></li>
+<li><a href="org/apache/kafka/connect/errors/DataException.html" title="class in org.apache.kafka.connect.errors" target="classFrame">DataException</a></li>
+<li><a href="org/apache/kafka/connect/data/Date.html" title="class in org.apache.kafka.connect.data" target="classFrame">Date</a></li>
+<li><a href="org/apache/kafka/connect/data/Decimal.html" title="class in org.apache.kafka.connect.data" target="classFrame">Decimal</a></li>
+<li><a href="org/apache/kafka/streams/processor/DefaultPartitionGrouper.html" title="class in org.apache.kafka.streams.processor" target="classFrame">DefaultPartitionGrouper</a></li>
<li><a href="org/apache/kafka/common/serialization/Deserializer.html" title="interface in org.apache.kafka.common.serialization" target="classFrame"><i>Deserializer</i></a></li>
<li><a href="org/apache/kafka/common/errors/DisconnectException.html" title="class in org.apache.kafka.common.errors" target="classFrame">DisconnectException</a></li>
<li><a href="org/apache/kafka/common/serialization/DoubleDeserializer.html" title="class in org.apache.kafka.common.serialization" target="classFrame">DoubleDeserializer</a></li>
<li><a href="org/apache/kafka/common/serialization/DoubleSerializer.html" title="class in org.apache.kafka.common.serialization" target="classFrame">DoubleSerializer</a></li>
+<li><a href="org/apache/kafka/connect/data/Field.html" title="class in org.apache.kafka.connect.data" target="classFrame">Field</a></li>
+<li><a href="org/apache/kafka/streams/kstream/ForeachAction.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>ForeachAction</i></a></li>
<li><a href="org/apache/kafka/common/errors/GroupAuthorizationException.html" title="class in org.apache.kafka.common.errors" target="classFrame">GroupAuthorizationException</a></li>
<li><a href="org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html" title="class in org.apache.kafka.common.errors" target="classFrame">GroupCoordinatorNotAvailableException</a></li>
<li><a href="org/apache/kafka/common/errors/GroupLoadInProgressException.html" title="class in org.apache.kafka.common.errors" target="classFrame">GroupLoadInProgressException</a></li>
<li><a href="org/apache/kafka/common/errors/IllegalGenerationException.html" title="class in org.apache.kafka.common.errors" target="classFrame">IllegalGenerationException</a></li>
<li><a href="org/apache/kafka/common/errors/IllegalSaslStateException.html" title="class in org.apache.kafka.common.errors" target="classFrame">IllegalSaslStateException</a></li>
+<li><a href="org/apache/kafka/connect/errors/IllegalWorkerStateException.html" title="class in org.apache.kafka.connect.errors" target="classFrame">IllegalWorkerStateException</a></li>
<li><a href="org/apache/kafka/common/errors/InconsistentGroupProtocolException.html" title="class in org.apache.kafka.common.errors" target="classFrame">InconsistentGroupProtocolException</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Initializer.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>Initializer</i></a></li>
<li><a href="org/apache/kafka/common/serialization/IntegerDeserializer.html" title="class in org.apache.kafka.common.serialization" target="classFrame">IntegerDeserializer</a></li>
<li><a href="org/apache/kafka/common/serialization/IntegerSerializer.html" title="class in org.apache.kafka.common.serialization" target="classFrame">IntegerSerializer</a></li>
<li><a href="org/apache/kafka/common/errors/InterruptException.html" title="class in org.apache.kafka.common.errors" target="classFrame">InterruptException</a></li>
@@ -71,9 +90,20 @@
<li><a href="org/apache/kafka/common/errors/InvalidSessionTimeoutException.html" title="class in org.apache.kafka.common.errors" target="classFrame">InvalidSessionTimeoutException</a></li>
<li><a href="org/apache/kafka/common/errors/InvalidTimestampException.html" title="class in org.apache.kafka.common.errors" target="classFrame">InvalidTimestampException</a></li>
<li><a href="org/apache/kafka/common/errors/InvalidTopicException.html" title="class in org.apache.kafka.common.errors" target="classFrame">InvalidTopicException</a></li>
+<li><a href="org/apache/kafka/streams/kstream/JoinWindows.html" title="class in org.apache.kafka.streams.kstream" target="classFrame">JoinWindows</a></li>
+<li><a href="org/apache/kafka/streams/KafkaClientSupplier.html" title="interface in org.apache.kafka.streams" target="classFrame"><i>KafkaClientSupplier</i></a></li>
<li><a href="org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer" target="classFrame">KafkaConsumer</a></li>
<li><a href="org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common" target="classFrame">KafkaException</a></li>
<li><a href="org/apache/kafka/clients/producer/KafkaProducer.html" title="class in org.apache.kafka.clients.producer" target="classFrame">KafkaProducer</a></li>
+<li><a href="org/apache/kafka/streams/KafkaStreams.html" title="class in org.apache.kafka.streams" target="classFrame">KafkaStreams</a></li>
+<li><a href="org/apache/kafka/streams/KeyValue.html" title="class in org.apache.kafka.streams" target="classFrame">KeyValue</a></li>
+<li><a href="org/apache/kafka/streams/state/KeyValueIterator.html" title="interface in org.apache.kafka.streams.state" target="classFrame"><i>KeyValueIterator</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>KeyValueMapper</i></a></li>
+<li><a href="org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state" target="classFrame"><i>KeyValueStore</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>KGroupedTable</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>KStream</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/KStreamBuilder.html" title="class in org.apache.kafka.streams.kstream" target="classFrame">KStreamBuilder</a></li>
+<li><a href="org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>KTable</i></a></li>
<li><a href="org/apache/kafka/common/errors/LeaderNotAvailableException.html" title="class in org.apache.kafka.common.errors" target="classFrame">LeaderNotAvailableException</a></li>
<li><a href="org/apache/kafka/common/serialization/LongDeserializer.html" title="class in org.apache.kafka.common.serialization" target="classFrame">LongDeserializer</a></li>
<li><a href="org/apache/kafka/common/serialization/LongSerializer.html" title="class in org.apache.kafka.common.serialization" target="classFrame">LongSerializer</a></li>
@@ -87,6 +117,7 @@
<li><a href="org/apache/kafka/common/errors/NotCoordinatorForGroupException.html" title="class in org.apache.kafka.common.errors" target="classFrame">NotCoordinatorForGroupException</a></li>
<li><a href="org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html" title="class in org.apache.kafka.common.errors" target="classFrame">NotEnoughReplicasAfterAppendException</a></li>
<li><a href="org/apache/kafka/common/errors/NotEnoughReplicasException.html" title="class in org.apache.kafka.common.errors" target="classFrame">NotEnoughReplicasException</a></li>
+<li><a href="org/apache/kafka/connect/errors/NotFoundException.html" title="class in org.apache.kafka.connect.errors" target="classFrame">NotFoundException</a></li>
<li><a href="org/apache/kafka/common/errors/NotLeaderForPartitionException.html" title="class in org.apache.kafka.common.errors" target="classFrame">NotLeaderForPartitionException</a></li>
<li><a href="org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer" target="classFrame">OffsetAndMetadata</a></li>
<li><a href="org/apache/kafka/clients/consumer/OffsetCommitCallback.html" title="interface in org.apache.kafka.clients.consumer" target="classFrame"><i>OffsetCommitCallback</i></a></li>
@@ -94,8 +125,15 @@
<li><a href="org/apache/kafka/clients/consumer/OffsetOutOfRangeException.html" title="class in org.apache.kafka.clients.consumer" target="classFrame">OffsetOutOfRangeException</a></li>
<li><a href="org/apache/kafka/common/errors/OffsetOutOfRangeException.html" title="class in org.apache.kafka.common.errors" target="classFrame">OffsetOutOfRangeException</a></li>
<li><a href="org/apache/kafka/clients/consumer/OffsetResetStrategy.html" title="enum in org.apache.kafka.clients.consumer" target="classFrame">OffsetResetStrategy</a></li>
+<li><a href="org/apache/kafka/connect/storage/OffsetStorageReader.html" title="interface in org.apache.kafka.connect.storage" target="classFrame"><i>OffsetStorageReader</i></a></li>
<li><a href="org/apache/kafka/clients/producer/Partitioner.html" title="interface in org.apache.kafka.clients.producer" target="classFrame"><i>Partitioner</i></a></li>
+<li><a href="org/apache/kafka/streams/processor/PartitionGrouper.html" title="interface in org.apache.kafka.streams.processor" target="classFrame"><i>PartitionGrouper</i></a></li>
<li><a href="org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common" target="classFrame">PartitionInfo</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Predicate.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>Predicate</i></a></li>
+<li><a href="org/apache/kafka/streams/processor/Processor.html" title="interface in org.apache.kafka.streams.processor" target="classFrame"><i>Processor</i></a></li>
+<li><a href="org/apache/kafka/streams/processor/ProcessorContext.html" title="interface in org.apache.kafka.streams.processor" target="classFrame"><i>ProcessorContext</i></a></li>
+<li><a href="org/apache/kafka/streams/errors/ProcessorStateException.html" title="class in org.apache.kafka.streams.errors" target="classFrame">ProcessorStateException</a></li>
+<li><a href="org/apache/kafka/streams/processor/ProcessorSupplier.html" title="interface in org.apache.kafka.streams.processor" target="classFrame"><i>ProcessorSupplier</i></a></li>
<li><a href="org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer" target="classFrame"><i>Producer</i></a></li>
<li><a href="org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer" target="classFrame">ProducerConfig</a></li>
<li><a href="org/apache/kafka/clients/producer/ProducerInterceptor.html" title="interface in org.apache.kafka.clients.producer" target="classFrame"><i>ProducerInterceptor</i></a></li>
@@ -105,11 +143,20 @@
<li><a href="org/apache/kafka/common/errors/RecordBatchTooLargeException.html" title="class in org.apache.kafka.common.errors" target="classFrame">RecordBatchTooLargeException</a></li>
<li><a href="org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer" target="classFrame">RecordMetadata</a></li>
<li><a href="org/apache/kafka/common/errors/RecordTooLargeException.html" title="class in org.apache.kafka.common.errors" target="classFrame">RecordTooLargeException</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Reducer.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>Reducer</i></a></li>
<li><a href="org/apache/kafka/common/errors/ReplicaNotAvailableException.html" title="class in org.apache.kafka.common.errors" target="classFrame">ReplicaNotAvailableException</a></li>
<li><a href="org/apache/kafka/clients/consumer/RetriableCommitFailedException.html" title="class in org.apache.kafka.clients.consumer" target="classFrame">RetriableCommitFailedException</a></li>
<li><a href="org/apache/kafka/common/errors/RetriableException.html" title="class in org.apache.kafka.common.errors" target="classFrame">RetriableException</a></li>
+<li><a href="org/apache/kafka/connect/errors/RetriableException.html" title="class in org.apache.kafka.connect.errors" target="classFrame">RetriableException</a></li>
<li><a href="org/apache/kafka/clients/consumer/RoundRobinAssignor.html" title="class in org.apache.kafka.clients.consumer" target="classFrame">RoundRobinAssignor</a></li>
<li><a href="org/apache/kafka/common/config/SaslConfigs.html" title="class in org.apache.kafka.common.config" target="classFrame">SaslConfigs</a></li>
+<li><a href="org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data" target="classFrame"><i>Schema</i></a></li>
+<li><a href="org/apache/kafka/connect/data/Schema.Type.html" title="enum in org.apache.kafka.connect.data" target="classFrame">Schema.Type</a></li>
+<li><a href="org/apache/kafka/connect/data/SchemaAndValue.html" title="class in org.apache.kafka.connect.data" target="classFrame">SchemaAndValue</a></li>
+<li><a href="org/apache/kafka/connect/data/SchemaBuilder.html" title="class in org.apache.kafka.connect.data" target="classFrame">SchemaBuilder</a></li>
+<li><a href="org/apache/kafka/connect/errors/SchemaBuilderException.html" title="class in org.apache.kafka.connect.errors" target="classFrame">SchemaBuilderException</a></li>
+<li><a href="org/apache/kafka/connect/data/SchemaProjector.html" title="class in org.apache.kafka.connect.data" target="classFrame">SchemaProjector</a></li>
+<li><a href="org/apache/kafka/connect/errors/SchemaProjectorException.html" title="class in org.apache.kafka.connect.errors" target="classFrame">SchemaProjectorException</a></li>
<li><a href="org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization" target="classFrame"><i>Serde</i></a></li>
<li><a href="org/apache/kafka/common/serialization/Serdes.html" title="class in org.apache.kafka.common.serialization" target="classFrame">Serdes</a></li>
<li><a href="org/apache/kafka/common/serialization/Serdes.ByteArraySerde.html" title="class in org.apache.kafka.common.serialization" target="classFrame">Serdes.ByteArraySerde</a></li>
@@ -121,18 +168,67 @@
<li><a href="org/apache/kafka/common/serialization/Serdes.StringSerde.html" title="class in org.apache.kafka.common.serialization" target="classFrame">Serdes.StringSerde</a></li>
<li><a href="org/apache/kafka/common/errors/SerializationException.html" title="class in org.apache.kafka.common.errors" target="classFrame">SerializationException</a></li>
<li><a href="org/apache/kafka/common/serialization/Serializer.html" title="interface in org.apache.kafka.common.serialization" target="classFrame"><i>Serializer</i></a></li>
+<li><a href="org/apache/kafka/connect/sink/SinkConnector.html" title="class in org.apache.kafka.connect.sink" target="classFrame">SinkConnector</a></li>
+<li><a href="org/apache/kafka/connect/sink/SinkRecord.html" title="class in org.apache.kafka.connect.sink" target="classFrame">SinkRecord</a></li>
+<li><a href="org/apache/kafka/connect/sink/SinkTask.html" title="class in org.apache.kafka.connect.sink" target="classFrame">SinkTask</a></li>
+<li><a href="org/apache/kafka/connect/sink/SinkTaskContext.html" title="interface in org.apache.kafka.connect.sink" target="classFrame"><i>SinkTaskContext</i></a></li>
+<li><a href="org/apache/kafka/connect/source/SourceConnector.html" title="class in org.apache.kafka.connect.source" target="classFrame">SourceConnector</a></li>
+<li><a href="org/apache/kafka/connect/source/SourceRecord.html" title="class in org.apache.kafka.connect.source" target="classFrame">SourceRecord</a></li>
+<li><a href="org/apache/kafka/connect/source/SourceTask.html" title="class in org.apache.kafka.connect.source" target="classFrame">SourceTask</a></li>
+<li><a href="org/apache/kafka/connect/source/SourceTaskContext.html" title="interface in org.apache.kafka.connect.source" target="classFrame"><i>SourceTaskContext</i></a></li>
<li><a href="org/apache/kafka/common/config/SslConfigs.html" title="class in org.apache.kafka.common.config" target="classFrame">SslConfigs</a></li>
+<li><a href="org/apache/kafka/streams/processor/StateRestoreCallback.html" title="interface in org.apache.kafka.streams.processor" target="classFrame"><i>StateRestoreCallback</i></a></li>
+<li><a href="org/apache/kafka/streams/state/StateSerdes.html" title="class in org.apache.kafka.streams.state" target="classFrame">StateSerdes</a></li>
+<li><a href="org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor" target="classFrame"><i>StateStore</i></a></li>
+<li><a href="org/apache/kafka/streams/processor/StateStoreSupplier.html" title="interface in org.apache.kafka.streams.processor" target="classFrame"><i>StateStoreSupplier</i></a></li>
+<li><a href="org/apache/kafka/streams/state/Stores.html" title="class in org.apache.kafka.streams.state" target="classFrame">Stores</a></li>
+<li><a href="org/apache/kafka/streams/state/Stores.InMemoryKeyValueFactory.html" title="interface in org.apache.kafka.streams.state" target="classFrame"><i>Stores.InMemoryKeyValueFactory</i></a></li>
+<li><a href="org/apache/kafka/streams/state/Stores.KeyValueFactory.html" title="interface in org.apache.kafka.streams.state" target="classFrame"><i>Stores.KeyValueFactory</i></a></li>
+<li><a href="org/apache/kafka/streams/state/Stores.PersistentKeyValueFactory.html" title="interface in org.apache.kafka.streams.state" target="classFrame"><i>Stores.PersistentKeyValueFactory</i></a></li>
+<li><a href="org/apache/kafka/streams/state/Stores.StoreFactory.html" title="class in org.apache.kafka.streams.state" target="classFrame">Stores.StoreFactory</a></li>
+<li><a href="org/apache/kafka/streams/state/Stores.ValueFactory.html" title="class in org.apache.kafka.streams.state" target="classFrame">Stores.ValueFactory</a></li>
+<li><a href="org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor" target="classFrame"><i>StreamPartitioner</i></a></li>
+<li><a href="org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams" target="classFrame">StreamsConfig</a></li>
+<li><a href="org/apache/kafka/streams/StreamsConfig.InternalConfig.html" title="class in org.apache.kafka.streams" target="classFrame">StreamsConfig.InternalConfig</a></li>
+<li><a href="org/apache/kafka/streams/errors/StreamsException.html" title="class in org.apache.kafka.streams.errors" target="classFrame">StreamsException</a></li>
+<li><a href="org/apache/kafka/streams/StreamsMetrics.html" title="interface in org.apache.kafka.streams" target="classFrame"><i>StreamsMetrics</i></a></li>
+<li><a href="org/apache/kafka/connect/storage/StringConverter.html" title="class in org.apache.kafka.connect.storage" target="classFrame">StringConverter</a></li>
<li><a href="org/apache/kafka/common/serialization/StringDeserializer.html" title="class in org.apache.kafka.common.serialization" target="classFrame">StringDeserializer</a></li>
<li><a href="org/apache/kafka/common/serialization/StringSerializer.html" title="class in org.apache.kafka.common.serialization" target="classFrame">StringSerializer</a></li>
+<li><a href="org/apache/kafka/connect/data/Struct.html" title="class in org.apache.kafka.connect.data" target="classFrame">Struct</a></li>
+<li><a href="org/apache/kafka/connect/connector/Task.html" title="interface in org.apache.kafka.connect.connector" target="classFrame"><i>Task</i></a></li>
+<li><a href="org/apache/kafka/streams/errors/TaskAssignmentException.html" title="class in org.apache.kafka.streams.errors" target="classFrame">TaskAssignmentException</a></li>
+<li><a href="org/apache/kafka/streams/processor/TaskId.html" title="class in org.apache.kafka.streams.processor" target="classFrame">TaskId</a></li>
+<li><a href="org/apache/kafka/streams/errors/TaskIdFormatException.html" title="class in org.apache.kafka.streams.errors" target="classFrame">TaskIdFormatException</a></li>
+<li><a href="org/apache/kafka/connect/data/Time.html" title="class in org.apache.kafka.connect.data" target="classFrame">Time</a></li>
<li><a href="org/apache/kafka/common/errors/TimeoutException.html" title="class in org.apache.kafka.common.errors" target="classFrame">TimeoutException</a></li>
+<li><a href="org/apache/kafka/connect/data/Timestamp.html" title="class in org.apache.kafka.connect.data" target="classFrame">Timestamp</a></li>
+<li><a href="org/apache/kafka/streams/processor/TimestampExtractor.html" title="interface in org.apache.kafka.streams.processor" target="classFrame"><i>TimestampExtractor</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/TimeWindows.html" title="class in org.apache.kafka.streams.kstream" target="classFrame">TimeWindows</a></li>
<li><a href="org/apache/kafka/common/errors/TopicAuthorizationException.html" title="class in org.apache.kafka.common.errors" target="classFrame">TopicAuthorizationException</a></li>
<li><a href="org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common" target="classFrame">TopicPartition</a></li>
+<li><a href="org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor" target="classFrame">TopologyBuilder</a></li>
+<li><a href="org/apache/kafka/streams/processor/TopologyBuilder.TopicsInfo.html" title="class in org.apache.kafka.streams.processor" target="classFrame">TopologyBuilder.TopicsInfo</a></li>
+<li><a href="org/apache/kafka/streams/errors/TopologyBuilderException.html" title="class in org.apache.kafka.streams.errors" target="classFrame">TopologyBuilderException</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Transformer.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>Transformer</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/TransformerSupplier.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>TransformerSupplier</i></a></li>
<li><a href="org/apache/kafka/common/errors/UnknownMemberIdException.html" title="class in org.apache.kafka.common.errors" target="classFrame">UnknownMemberIdException</a></li>
<li><a href="org/apache/kafka/common/errors/UnknownServerException.html" title="class in org.apache.kafka.common.errors" target="classFrame">UnknownServerException</a></li>
<li><a href="org/apache/kafka/common/errors/UnknownTopicOrPartitionException.html" title="class in org.apache.kafka.common.errors" target="classFrame">UnknownTopicOrPartitionException</a></li>
+<li><a href="org/apache/kafka/streams/kstream/UnlimitedWindows.html" title="class in org.apache.kafka.streams.kstream" target="classFrame">UnlimitedWindows</a></li>
<li><a href="org/apache/kafka/common/errors/UnsupportedSaslMechanismException.html" title="class in org.apache.kafka.common.errors" target="classFrame">UnsupportedSaslMechanismException</a></li>
<li><a href="org/apache/kafka/common/errors/UnsupportedVersionException.html" title="class in org.apache.kafka.common.errors" target="classFrame">UnsupportedVersionException</a></li>
+<li><a href="org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>ValueJoiner</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/ValueMapper.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>ValueMapper</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/ValueTransformer.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>ValueTransformer</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/ValueTransformerSupplier.html" title="interface in org.apache.kafka.streams.kstream" target="classFrame"><i>ValueTransformerSupplier</i></a></li>
<li><a href="org/apache/kafka/common/errors/WakeupException.html" title="class in org.apache.kafka.common.errors" target="classFrame">WakeupException</a></li>
+<li><a href="org/apache/kafka/streams/processor/WallclockTimestampExtractor.html" title="class in org.apache.kafka.streams.processor" target="classFrame">WallclockTimestampExtractor</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Window.html" title="class in org.apache.kafka.streams.kstream" target="classFrame">Window</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Windowed.html" title="class in org.apache.kafka.streams.kstream" target="classFrame">Windowed</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Windows.html" title="class in org.apache.kafka.streams.kstream" target="classFrame">Windows</a></li>
+<li><a href="org/apache/kafka/streams/state/WindowStore.html" title="interface in org.apache.kafka.streams.state" target="classFrame"><i>WindowStore</i></a></li>
+<li><a href="org/apache/kafka/streams/state/WindowStoreIterator.html" title="interface in org.apache.kafka.streams.state" target="classFrame"><i>WindowStoreIterator</i></a></li>
</ul>
</div>
</body>
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/af5a933b/0100/javadoc/allclasses-noframe.html
----------------------------------------------------------------------
diff --git a/0100/javadoc/allclasses-noframe.html b/0100/javadoc/allclasses-noframe.html
index 5fc3063..0687c2b 100644
--- a/0100/javadoc/allclasses-noframe.html
+++ b/0100/javadoc/allclasses-noframe.html
@@ -2,9 +2,9 @@
<!-- NewPage -->
<html lang="en">
<head>
-<!-- Generated by javadoc (version 1.7.0_79) on Tue May 17 21:36:38 PDT 2016 -->
-<title>All Classes (clients 0.10.0.0 API)</title>
-<meta name="date" content="2016-05-17">
+<!-- Generated by javadoc (version 1.7.0_80) on Thu May 19 00:52:06 BST 2016 -->
+<title>All Classes (kafka 0.10.0.0 API)</title>
+<meta name="date" content="2016-05-19">
<link rel="stylesheet" type="text/css" href="stylesheet.css" title="Style">
</head>
<body>
@@ -12,6 +12,9 @@
<div class="indexContainer">
<ul>
<li><a href="org/apache/kafka/common/config/AbstractConfig.html" title="class in org.apache.kafka.common.config">AbstractConfig</a></li>
+<li><a href="org/apache/kafka/streams/processor/AbstractProcessor.html" title="class in org.apache.kafka.streams.processor">AbstractProcessor</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Aggregator.html" title="interface in org.apache.kafka.streams.kstream"><i>Aggregator</i></a></li>
+<li><a href="org/apache/kafka/connect/errors/AlreadyExistsException.html" title="class in org.apache.kafka.connect.errors">AlreadyExistsException</a></li>
<li><a href="org/apache/kafka/common/errors/ApiException.html" title="class in org.apache.kafka.common.errors">ApiException</a></li>
<li><a href="org/apache/kafka/common/errors/AuthenticationException.html" title="class in org.apache.kafka.common.errors">AuthenticationException</a></li>
<li><a href="org/apache/kafka/common/errors/AuthorizationException.html" title="class in org.apache.kafka.common.errors">AuthorizationException</a></li>
@@ -40,24 +43,40 @@
<li><a href="org/apache/kafka/common/config/ConfigException.html" title="class in org.apache.kafka.common.config">ConfigException</a></li>
<li><a href="org/apache/kafka/common/Configurable.html" title="interface in org.apache.kafka.common"><i>Configurable</i></a></li>
<li><a href="org/apache/kafka/common/config/ConfigValue.html" title="class in org.apache.kafka.common.config">ConfigValue</a></li>
+<li><a href="org/apache/kafka/connect/errors/ConnectException.html" title="class in org.apache.kafka.connect.errors">ConnectException</a></li>
+<li><a href="org/apache/kafka/connect/connector/Connector.html" title="class in org.apache.kafka.connect.connector">Connector</a></li>
+<li><a href="org/apache/kafka/connect/connector/ConnectorContext.html" title="interface in org.apache.kafka.connect.connector"><i>ConnectorContext</i></a></li>
+<li><a href="org/apache/kafka/connect/util/ConnectorUtils.html" title="class in org.apache.kafka.connect.util">ConnectorUtils</a></li>
+<li><a href="org/apache/kafka/connect/connector/ConnectRecord.html" title="class in org.apache.kafka.connect.connector">ConnectRecord</a></li>
+<li><a href="org/apache/kafka/connect/data/ConnectSchema.html" title="class in org.apache.kafka.connect.data">ConnectSchema</a></li>
<li><a href="org/apache/kafka/clients/consumer/Consumer.html" title="interface in org.apache.kafka.clients.consumer"><i>Consumer</i></a></li>
<li><a href="org/apache/kafka/clients/consumer/ConsumerConfig.html" title="class in org.apache.kafka.clients.consumer">ConsumerConfig</a></li>
<li><a href="org/apache/kafka/clients/consumer/ConsumerInterceptor.html" title="interface in org.apache.kafka.clients.consumer"><i>ConsumerInterceptor</i></a></li>
<li><a href="org/apache/kafka/clients/consumer/ConsumerRebalanceListener.html" title="interface in org.apache.kafka.clients.consumer"><i>ConsumerRebalanceListener</i></a></li>
<li><a href="org/apache/kafka/clients/consumer/ConsumerRecord.html" title="class in org.apache.kafka.clients.consumer">ConsumerRecord</a></li>
<li><a href="org/apache/kafka/clients/consumer/ConsumerRecords.html" title="class in org.apache.kafka.clients.consumer">ConsumerRecords</a></li>
+<li><a href="org/apache/kafka/streams/processor/ConsumerRecordTimestampExtractor.html" title="class in org.apache.kafka.streams.processor">ConsumerRecordTimestampExtractor</a></li>
<li><a href="org/apache/kafka/common/errors/ControllerMovedException.html" title="class in org.apache.kafka.common.errors">ControllerMovedException</a></li>
+<li><a href="org/apache/kafka/connect/storage/Converter.html" title="interface in org.apache.kafka.connect.storage"><i>Converter</i></a></li>
<li><a href="org/apache/kafka/common/errors/CorruptRecordException.html" title="class in org.apache.kafka.common.errors">CorruptRecordException</a></li>
+<li><a href="org/apache/kafka/connect/errors/DataException.html" title="class in org.apache.kafka.connect.errors">DataException</a></li>
+<li><a href="org/apache/kafka/connect/data/Date.html" title="class in org.apache.kafka.connect.data">Date</a></li>
+<li><a href="org/apache/kafka/connect/data/Decimal.html" title="class in org.apache.kafka.connect.data">Decimal</a></li>
+<li><a href="org/apache/kafka/streams/processor/DefaultPartitionGrouper.html" title="class in org.apache.kafka.streams.processor">DefaultPartitionGrouper</a></li>
<li><a href="org/apache/kafka/common/serialization/Deserializer.html" title="interface in org.apache.kafka.common.serialization"><i>Deserializer</i></a></li>
<li><a href="org/apache/kafka/common/errors/DisconnectException.html" title="class in org.apache.kafka.common.errors">DisconnectException</a></li>
<li><a href="org/apache/kafka/common/serialization/DoubleDeserializer.html" title="class in org.apache.kafka.common.serialization">DoubleDeserializer</a></li>
<li><a href="org/apache/kafka/common/serialization/DoubleSerializer.html" title="class in org.apache.kafka.common.serialization">DoubleSerializer</a></li>
+<li><a href="org/apache/kafka/connect/data/Field.html" title="class in org.apache.kafka.connect.data">Field</a></li>
+<li><a href="org/apache/kafka/streams/kstream/ForeachAction.html" title="interface in org.apache.kafka.streams.kstream"><i>ForeachAction</i></a></li>
<li><a href="org/apache/kafka/common/errors/GroupAuthorizationException.html" title="class in org.apache.kafka.common.errors">GroupAuthorizationException</a></li>
<li><a href="org/apache/kafka/common/errors/GroupCoordinatorNotAvailableException.html" title="class in org.apache.kafka.common.errors">GroupCoordinatorNotAvailableException</a></li>
<li><a href="org/apache/kafka/common/errors/GroupLoadInProgressException.html" title="class in org.apache.kafka.common.errors">GroupLoadInProgressException</a></li>
<li><a href="org/apache/kafka/common/errors/IllegalGenerationException.html" title="class in org.apache.kafka.common.errors">IllegalGenerationException</a></li>
<li><a href="org/apache/kafka/common/errors/IllegalSaslStateException.html" title="class in org.apache.kafka.common.errors">IllegalSaslStateException</a></li>
+<li><a href="org/apache/kafka/connect/errors/IllegalWorkerStateException.html" title="class in org.apache.kafka.connect.errors">IllegalWorkerStateException</a></li>
<li><a href="org/apache/kafka/common/errors/InconsistentGroupProtocolException.html" title="class in org.apache.kafka.common.errors">InconsistentGroupProtocolException</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Initializer.html" title="interface in org.apache.kafka.streams.kstream"><i>Initializer</i></a></li>
<li><a href="org/apache/kafka/common/serialization/IntegerDeserializer.html" title="class in org.apache.kafka.common.serialization">IntegerDeserializer</a></li>
<li><a href="org/apache/kafka/common/serialization/IntegerSerializer.html" title="class in org.apache.kafka.common.serialization">IntegerSerializer</a></li>
<li><a href="org/apache/kafka/common/errors/InterruptException.html" title="class in org.apache.kafka.common.errors">InterruptException</a></li>
@@ -71,9 +90,20 @@
<li><a href="org/apache/kafka/common/errors/InvalidSessionTimeoutException.html" title="class in org.apache.kafka.common.errors">InvalidSessionTimeoutException</a></li>
<li><a href="org/apache/kafka/common/errors/InvalidTimestampException.html" title="class in org.apache.kafka.common.errors">InvalidTimestampException</a></li>
<li><a href="org/apache/kafka/common/errors/InvalidTopicException.html" title="class in org.apache.kafka.common.errors">InvalidTopicException</a></li>
+<li><a href="org/apache/kafka/streams/kstream/JoinWindows.html" title="class in org.apache.kafka.streams.kstream">JoinWindows</a></li>
+<li><a href="org/apache/kafka/streams/KafkaClientSupplier.html" title="interface in org.apache.kafka.streams"><i>KafkaClientSupplier</i></a></li>
<li><a href="org/apache/kafka/clients/consumer/KafkaConsumer.html" title="class in org.apache.kafka.clients.consumer">KafkaConsumer</a></li>
<li><a href="org/apache/kafka/common/KafkaException.html" title="class in org.apache.kafka.common">KafkaException</a></li>
<li><a href="org/apache/kafka/clients/producer/KafkaProducer.html" title="class in org.apache.kafka.clients.producer">KafkaProducer</a></li>
+<li><a href="org/apache/kafka/streams/KafkaStreams.html" title="class in org.apache.kafka.streams">KafkaStreams</a></li>
+<li><a href="org/apache/kafka/streams/KeyValue.html" title="class in org.apache.kafka.streams">KeyValue</a></li>
+<li><a href="org/apache/kafka/streams/state/KeyValueIterator.html" title="interface in org.apache.kafka.streams.state"><i>KeyValueIterator</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/KeyValueMapper.html" title="interface in org.apache.kafka.streams.kstream"><i>KeyValueMapper</i></a></li>
+<li><a href="org/apache/kafka/streams/state/KeyValueStore.html" title="interface in org.apache.kafka.streams.state"><i>KeyValueStore</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/KGroupedTable.html" title="interface in org.apache.kafka.streams.kstream"><i>KGroupedTable</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/KStream.html" title="interface in org.apache.kafka.streams.kstream"><i>KStream</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/KStreamBuilder.html" title="class in org.apache.kafka.streams.kstream">KStreamBuilder</a></li>
+<li><a href="org/apache/kafka/streams/kstream/KTable.html" title="interface in org.apache.kafka.streams.kstream"><i>KTable</i></a></li>
<li><a href="org/apache/kafka/common/errors/LeaderNotAvailableException.html" title="class in org.apache.kafka.common.errors">LeaderNotAvailableException</a></li>
<li><a href="org/apache/kafka/common/serialization/LongDeserializer.html" title="class in org.apache.kafka.common.serialization">LongDeserializer</a></li>
<li><a href="org/apache/kafka/common/serialization/LongSerializer.html" title="class in org.apache.kafka.common.serialization">LongSerializer</a></li>
@@ -87,6 +117,7 @@
<li><a href="org/apache/kafka/common/errors/NotCoordinatorForGroupException.html" title="class in org.apache.kafka.common.errors">NotCoordinatorForGroupException</a></li>
<li><a href="org/apache/kafka/common/errors/NotEnoughReplicasAfterAppendException.html" title="class in org.apache.kafka.common.errors">NotEnoughReplicasAfterAppendException</a></li>
<li><a href="org/apache/kafka/common/errors/NotEnoughReplicasException.html" title="class in org.apache.kafka.common.errors">NotEnoughReplicasException</a></li>
+<li><a href="org/apache/kafka/connect/errors/NotFoundException.html" title="class in org.apache.kafka.connect.errors">NotFoundException</a></li>
<li><a href="org/apache/kafka/common/errors/NotLeaderForPartitionException.html" title="class in org.apache.kafka.common.errors">NotLeaderForPartitionException</a></li>
<li><a href="org/apache/kafka/clients/consumer/OffsetAndMetadata.html" title="class in org.apache.kafka.clients.consumer">OffsetAndMetadata</a></li>
<li><a href="org/apache/kafka/clients/consumer/OffsetCommitCallback.html" title="interface in org.apache.kafka.clients.consumer"><i>OffsetCommitCallback</i></a></li>
@@ -94,8 +125,15 @@
<li><a href="org/apache/kafka/clients/consumer/OffsetOutOfRangeException.html" title="class in org.apache.kafka.clients.consumer">OffsetOutOfRangeException</a></li>
<li><a href="org/apache/kafka/common/errors/OffsetOutOfRangeException.html" title="class in org.apache.kafka.common.errors">OffsetOutOfRangeException</a></li>
<li><a href="org/apache/kafka/clients/consumer/OffsetResetStrategy.html" title="enum in org.apache.kafka.clients.consumer">OffsetResetStrategy</a></li>
+<li><a href="org/apache/kafka/connect/storage/OffsetStorageReader.html" title="interface in org.apache.kafka.connect.storage"><i>OffsetStorageReader</i></a></li>
<li><a href="org/apache/kafka/clients/producer/Partitioner.html" title="interface in org.apache.kafka.clients.producer"><i>Partitioner</i></a></li>
+<li><a href="org/apache/kafka/streams/processor/PartitionGrouper.html" title="interface in org.apache.kafka.streams.processor"><i>PartitionGrouper</i></a></li>
<li><a href="org/apache/kafka/common/PartitionInfo.html" title="class in org.apache.kafka.common">PartitionInfo</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Predicate.html" title="interface in org.apache.kafka.streams.kstream"><i>Predicate</i></a></li>
+<li><a href="org/apache/kafka/streams/processor/Processor.html" title="interface in org.apache.kafka.streams.processor"><i>Processor</i></a></li>
+<li><a href="org/apache/kafka/streams/processor/ProcessorContext.html" title="interface in org.apache.kafka.streams.processor"><i>ProcessorContext</i></a></li>
+<li><a href="org/apache/kafka/streams/errors/ProcessorStateException.html" title="class in org.apache.kafka.streams.errors">ProcessorStateException</a></li>
+<li><a href="org/apache/kafka/streams/processor/ProcessorSupplier.html" title="interface in org.apache.kafka.streams.processor"><i>ProcessorSupplier</i></a></li>
<li><a href="org/apache/kafka/clients/producer/Producer.html" title="interface in org.apache.kafka.clients.producer"><i>Producer</i></a></li>
<li><a href="org/apache/kafka/clients/producer/ProducerConfig.html" title="class in org.apache.kafka.clients.producer">ProducerConfig</a></li>
<li><a href="org/apache/kafka/clients/producer/ProducerInterceptor.html" title="interface in org.apache.kafka.clients.producer"><i>ProducerInterceptor</i></a></li>
@@ -105,11 +143,20 @@
<li><a href="org/apache/kafka/common/errors/RecordBatchTooLargeException.html" title="class in org.apache.kafka.common.errors">RecordBatchTooLargeException</a></li>
<li><a href="org/apache/kafka/clients/producer/RecordMetadata.html" title="class in org.apache.kafka.clients.producer">RecordMetadata</a></li>
<li><a href="org/apache/kafka/common/errors/RecordTooLargeException.html" title="class in org.apache.kafka.common.errors">RecordTooLargeException</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Reducer.html" title="interface in org.apache.kafka.streams.kstream"><i>Reducer</i></a></li>
<li><a href="org/apache/kafka/common/errors/ReplicaNotAvailableException.html" title="class in org.apache.kafka.common.errors">ReplicaNotAvailableException</a></li>
<li><a href="org/apache/kafka/clients/consumer/RetriableCommitFailedException.html" title="class in org.apache.kafka.clients.consumer">RetriableCommitFailedException</a></li>
<li><a href="org/apache/kafka/common/errors/RetriableException.html" title="class in org.apache.kafka.common.errors">RetriableException</a></li>
+<li><a href="org/apache/kafka/connect/errors/RetriableException.html" title="class in org.apache.kafka.connect.errors">RetriableException</a></li>
<li><a href="org/apache/kafka/clients/consumer/RoundRobinAssignor.html" title="class in org.apache.kafka.clients.consumer">RoundRobinAssignor</a></li>
<li><a href="org/apache/kafka/common/config/SaslConfigs.html" title="class in org.apache.kafka.common.config">SaslConfigs</a></li>
+<li><a href="org/apache/kafka/connect/data/Schema.html" title="interface in org.apache.kafka.connect.data"><i>Schema</i></a></li>
+<li><a href="org/apache/kafka/connect/data/Schema.Type.html" title="enum in org.apache.kafka.connect.data">Schema.Type</a></li>
+<li><a href="org/apache/kafka/connect/data/SchemaAndValue.html" title="class in org.apache.kafka.connect.data">SchemaAndValue</a></li>
+<li><a href="org/apache/kafka/connect/data/SchemaBuilder.html" title="class in org.apache.kafka.connect.data">SchemaBuilder</a></li>
+<li><a href="org/apache/kafka/connect/errors/SchemaBuilderException.html" title="class in org.apache.kafka.connect.errors">SchemaBuilderException</a></li>
+<li><a href="org/apache/kafka/connect/data/SchemaProjector.html" title="class in org.apache.kafka.connect.data">SchemaProjector</a></li>
+<li><a href="org/apache/kafka/connect/errors/SchemaProjectorException.html" title="class in org.apache.kafka.connect.errors">SchemaProjectorException</a></li>
<li><a href="org/apache/kafka/common/serialization/Serde.html" title="interface in org.apache.kafka.common.serialization"><i>Serde</i></a></li>
<li><a href="org/apache/kafka/common/serialization/Serdes.html" title="class in org.apache.kafka.common.serialization">Serdes</a></li>
<li><a href="org/apache/kafka/common/serialization/Serdes.ByteArraySerde.html" title="class in org.apache.kafka.common.serialization">Serdes.ByteArraySerde</a></li>
@@ -121,18 +168,67 @@
<li><a href="org/apache/kafka/common/serialization/Serdes.StringSerde.html" title="class in org.apache.kafka.common.serialization">Serdes.StringSerde</a></li>
<li><a href="org/apache/kafka/common/errors/SerializationException.html" title="class in org.apache.kafka.common.errors">SerializationException</a></li>
<li><a href="org/apache/kafka/common/serialization/Serializer.html" title="interface in org.apache.kafka.common.serialization"><i>Serializer</i></a></li>
+<li><a href="org/apache/kafka/connect/sink/SinkConnector.html" title="class in org.apache.kafka.connect.sink">SinkConnector</a></li>
+<li><a href="org/apache/kafka/connect/sink/SinkRecord.html" title="class in org.apache.kafka.connect.sink">SinkRecord</a></li>
+<li><a href="org/apache/kafka/connect/sink/SinkTask.html" title="class in org.apache.kafka.connect.sink">SinkTask</a></li>
+<li><a href="org/apache/kafka/connect/sink/SinkTaskContext.html" title="interface in org.apache.kafka.connect.sink"><i>SinkTaskContext</i></a></li>
+<li><a href="org/apache/kafka/connect/source/SourceConnector.html" title="class in org.apache.kafka.connect.source">SourceConnector</a></li>
+<li><a href="org/apache/kafka/connect/source/SourceRecord.html" title="class in org.apache.kafka.connect.source">SourceRecord</a></li>
+<li><a href="org/apache/kafka/connect/source/SourceTask.html" title="class in org.apache.kafka.connect.source">SourceTask</a></li>
+<li><a href="org/apache/kafka/connect/source/SourceTaskContext.html" title="interface in org.apache.kafka.connect.source"><i>SourceTaskContext</i></a></li>
<li><a href="org/apache/kafka/common/config/SslConfigs.html" title="class in org.apache.kafka.common.config">SslConfigs</a></li>
+<li><a href="org/apache/kafka/streams/processor/StateRestoreCallback.html" title="interface in org.apache.kafka.streams.processor"><i>StateRestoreCallback</i></a></li>
+<li><a href="org/apache/kafka/streams/state/StateSerdes.html" title="class in org.apache.kafka.streams.state">StateSerdes</a></li>
+<li><a href="org/apache/kafka/streams/processor/StateStore.html" title="interface in org.apache.kafka.streams.processor"><i>StateStore</i></a></li>
+<li><a href="org/apache/kafka/streams/processor/StateStoreSupplier.html" title="interface in org.apache.kafka.streams.processor"><i>StateStoreSupplier</i></a></li>
+<li><a href="org/apache/kafka/streams/state/Stores.html" title="class in org.apache.kafka.streams.state">Stores</a></li>
+<li><a href="org/apache/kafka/streams/state/Stores.InMemoryKeyValueFactory.html" title="interface in org.apache.kafka.streams.state"><i>Stores.InMemoryKeyValueFactory</i></a></li>
+<li><a href="org/apache/kafka/streams/state/Stores.KeyValueFactory.html" title="interface in org.apache.kafka.streams.state"><i>Stores.KeyValueFactory</i></a></li>
+<li><a href="org/apache/kafka/streams/state/Stores.PersistentKeyValueFactory.html" title="interface in org.apache.kafka.streams.state"><i>Stores.PersistentKeyValueFactory</i></a></li>
+<li><a href="org/apache/kafka/streams/state/Stores.StoreFactory.html" title="class in org.apache.kafka.streams.state">Stores.StoreFactory</a></li>
+<li><a href="org/apache/kafka/streams/state/Stores.ValueFactory.html" title="class in org.apache.kafka.streams.state">Stores.ValueFactory</a></li>
+<li><a href="org/apache/kafka/streams/processor/StreamPartitioner.html" title="interface in org.apache.kafka.streams.processor"><i>StreamPartitioner</i></a></li>
+<li><a href="org/apache/kafka/streams/StreamsConfig.html" title="class in org.apache.kafka.streams">StreamsConfig</a></li>
+<li><a href="org/apache/kafka/streams/StreamsConfig.InternalConfig.html" title="class in org.apache.kafka.streams">StreamsConfig.InternalConfig</a></li>
+<li><a href="org/apache/kafka/streams/errors/StreamsException.html" title="class in org.apache.kafka.streams.errors">StreamsException</a></li>
+<li><a href="org/apache/kafka/streams/StreamsMetrics.html" title="interface in org.apache.kafka.streams"><i>StreamsMetrics</i></a></li>
+<li><a href="org/apache/kafka/connect/storage/StringConverter.html" title="class in org.apache.kafka.connect.storage">StringConverter</a></li>
<li><a href="org/apache/kafka/common/serialization/StringDeserializer.html" title="class in org.apache.kafka.common.serialization">StringDeserializer</a></li>
<li><a href="org/apache/kafka/common/serialization/StringSerializer.html" title="class in org.apache.kafka.common.serialization">StringSerializer</a></li>
+<li><a href="org/apache/kafka/connect/data/Struct.html" title="class in org.apache.kafka.connect.data">Struct</a></li>
+<li><a href="org/apache/kafka/connect/connector/Task.html" title="interface in org.apache.kafka.connect.connector"><i>Task</i></a></li>
+<li><a href="org/apache/kafka/streams/errors/TaskAssignmentException.html" title="class in org.apache.kafka.streams.errors">TaskAssignmentException</a></li>
+<li><a href="org/apache/kafka/streams/processor/TaskId.html" title="class in org.apache.kafka.streams.processor">TaskId</a></li>
+<li><a href="org/apache/kafka/streams/errors/TaskIdFormatException.html" title="class in org.apache.kafka.streams.errors">TaskIdFormatException</a></li>
+<li><a href="org/apache/kafka/connect/data/Time.html" title="class in org.apache.kafka.connect.data">Time</a></li>
<li><a href="org/apache/kafka/common/errors/TimeoutException.html" title="class in org.apache.kafka.common.errors">TimeoutException</a></li>
+<li><a href="org/apache/kafka/connect/data/Timestamp.html" title="class in org.apache.kafka.connect.data">Timestamp</a></li>
+<li><a href="org/apache/kafka/streams/processor/TimestampExtractor.html" title="interface in org.apache.kafka.streams.processor"><i>TimestampExtractor</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/TimeWindows.html" title="class in org.apache.kafka.streams.kstream">TimeWindows</a></li>
<li><a href="org/apache/kafka/common/errors/TopicAuthorizationException.html" title="class in org.apache.kafka.common.errors">TopicAuthorizationException</a></li>
<li><a href="org/apache/kafka/common/TopicPartition.html" title="class in org.apache.kafka.common">TopicPartition</a></li>
+<li><a href="org/apache/kafka/streams/processor/TopologyBuilder.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder</a></li>
+<li><a href="org/apache/kafka/streams/processor/TopologyBuilder.TopicsInfo.html" title="class in org.apache.kafka.streams.processor">TopologyBuilder.TopicsInfo</a></li>
+<li><a href="org/apache/kafka/streams/errors/TopologyBuilderException.html" title="class in org.apache.kafka.streams.errors">TopologyBuilderException</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Transformer.html" title="interface in org.apache.kafka.streams.kstream"><i>Transformer</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/TransformerSupplier.html" title="interface in org.apache.kafka.streams.kstream"><i>TransformerSupplier</i></a></li>
<li><a href="org/apache/kafka/common/errors/UnknownMemberIdException.html" title="class in org.apache.kafka.common.errors">UnknownMemberIdException</a></li>
<li><a href="org/apache/kafka/common/errors/UnknownServerException.html" title="class in org.apache.kafka.common.errors">UnknownServerException</a></li>
<li><a href="org/apache/kafka/common/errors/UnknownTopicOrPartitionException.html" title="class in org.apache.kafka.common.errors">UnknownTopicOrPartitionException</a></li>
+<li><a href="org/apache/kafka/streams/kstream/UnlimitedWindows.html" title="class in org.apache.kafka.streams.kstream">UnlimitedWindows</a></li>
<li><a href="org/apache/kafka/common/errors/UnsupportedSaslMechanismException.html" title="class in org.apache.kafka.common.errors">UnsupportedSaslMechanismException</a></li>
<li><a href="org/apache/kafka/common/errors/UnsupportedVersionException.html" title="class in org.apache.kafka.common.errors">UnsupportedVersionException</a></li>
+<li><a href="org/apache/kafka/streams/kstream/ValueJoiner.html" title="interface in org.apache.kafka.streams.kstream"><i>ValueJoiner</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/ValueMapper.html" title="interface in org.apache.kafka.streams.kstream"><i>ValueMapper</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/ValueTransformer.html" title="interface in org.apache.kafka.streams.kstream"><i>ValueTransformer</i></a></li>
+<li><a href="org/apache/kafka/streams/kstream/ValueTransformerSupplier.html" title="interface in org.apache.kafka.streams.kstream"><i>ValueTransformerSupplier</i></a></li>
<li><a href="org/apache/kafka/common/errors/WakeupException.html" title="class in org.apache.kafka.common.errors">WakeupException</a></li>
+<li><a href="org/apache/kafka/streams/processor/WallclockTimestampExtractor.html" title="class in org.apache.kafka.streams.processor">WallclockTimestampExtractor</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Window.html" title="class in org.apache.kafka.streams.kstream">Window</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Windowed.html" title="class in org.apache.kafka.streams.kstream">Windowed</a></li>
+<li><a href="org/apache/kafka/streams/kstream/Windows.html" title="class in org.apache.kafka.streams.kstream">Windows</a></li>
+<li><a href="org/apache/kafka/streams/state/WindowStore.html" title="interface in org.apache.kafka.streams.state"><i>WindowStore</i></a></li>
+<li><a href="org/apache/kafka/streams/state/WindowStoreIterator.html" title="interface in org.apache.kafka.streams.state"><i>WindowStoreIterator</i></a></li>
</ul>
</div>
</body>