Repository: kafka-site Updated Branches: refs/heads/asf-site 749b548f3 -> 4ac323afc http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.html b/0102/javadoc/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.html index 8b76135..a7e506e 100644 --- a/0102/javadoc/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.html +++ b/0102/javadoc/org/apache/kafka/streams/processor/UsePreviousTimeOnInvalidTimestamp.html @@ -2,15 +2,15 @@ - -UsePreviousTimeOnInvalidTimestamp (kafka 0.10.2.0 API) - + +UsePreviousTimeOnInvalidTimestamp (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/WallclockTimestampExtractor.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/processor/WallclockTimestampExtractor.html b/0102/javadoc/org/apache/kafka/streams/processor/WallclockTimestampExtractor.html index 0585a7b..014f503 100644 --- a/0102/javadoc/org/apache/kafka/streams/processor/WallclockTimestampExtractor.html +++ b/0102/javadoc/org/apache/kafka/streams/processor/WallclockTimestampExtractor.html @@ -2,15 +2,15 @@ - -WallclockTimestampExtractor (kafka 0.10.2.0 API) - + +WallclockTimestampExtractor (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/package-frame.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/processor/package-frame.html b/0102/javadoc/org/apache/kafka/streams/processor/package-frame.html index a937426..fd8ac60 100644 --- a/0102/javadoc/org/apache/kafka/streams/processor/package-frame.html +++ b/0102/javadoc/org/apache/kafka/streams/processor/package-frame.html @@ -2,9 +2,9 @@ - -org.apache.kafka.streams.processor (kafka 0.10.2.0 API) - + +org.apache.kafka.streams.processor (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/package-summary.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/processor/package-summary.html b/0102/javadoc/org/apache/kafka/streams/processor/package-summary.html index 585ae47..5de79fb 100644 --- a/0102/javadoc/org/apache/kafka/streams/processor/package-summary.html +++ b/0102/javadoc/org/apache/kafka/streams/processor/package-summary.html @@ -2,15 +2,15 @@ - -org.apache.kafka.streams.processor (kafka 0.10.2.0 API) - + +org.apache.kafka.streams.processor (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/processor/package-tree.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/processor/package-tree.html b/0102/javadoc/org/apache/kafka/streams/processor/package-tree.html index 6b68198..a3c96eb 100644 --- a/0102/javadoc/org/apache/kafka/streams/processor/package-tree.html +++ b/0102/javadoc/org/apache/kafka/streams/processor/package-tree.html @@ -2,15 +2,15 @@ - -org.apache.kafka.streams.processor Class Hierarchy (kafka 0.10.2.0 API) - + +org.apache.kafka.streams.processor Class Hierarchy (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/HostInfo.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/HostInfo.html b/0102/javadoc/org/apache/kafka/streams/state/HostInfo.html index bd426ba..2188381 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/HostInfo.html +++ b/0102/javadoc/org/apache/kafka/streams/state/HostInfo.html @@ -2,15 +2,15 @@ - -HostInfo (kafka 0.10.2.0 API) - + +HostInfo (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/KeyValueIterator.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/KeyValueIterator.html b/0102/javadoc/org/apache/kafka/streams/state/KeyValueIterator.html index 7e250b9..7b111e0 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/KeyValueIterator.html +++ b/0102/javadoc/org/apache/kafka/streams/state/KeyValueIterator.html @@ -2,15 +2,15 @@ - -KeyValueIterator (kafka 0.10.2.0 API) - + +KeyValueIterator (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/KeyValueStore.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/KeyValueStore.html b/0102/javadoc/org/apache/kafka/streams/state/KeyValueStore.html index cb749ab..1f0d5cc 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/KeyValueStore.html +++ b/0102/javadoc/org/apache/kafka/streams/state/KeyValueStore.html @@ -2,15 +2,15 @@ - -KeyValueStore (kafka 0.10.2.0 API) - + +KeyValueStore (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/QueryableStoreType.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/QueryableStoreType.html b/0102/javadoc/org/apache/kafka/streams/state/QueryableStoreType.html index 8fd01a8..f16a881 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/QueryableStoreType.html +++ b/0102/javadoc/org/apache/kafka/streams/state/QueryableStoreType.html @@ -2,15 +2,15 @@ - -QueryableStoreType (kafka 0.10.2.0 API) - + +QueryableStoreType (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/QueryableStoreTypes.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/QueryableStoreTypes.html b/0102/javadoc/org/apache/kafka/streams/state/QueryableStoreTypes.html index 370ad90..5d26890 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/QueryableStoreTypes.html +++ b/0102/javadoc/org/apache/kafka/streams/state/QueryableStoreTypes.html @@ -2,15 +2,15 @@ - -QueryableStoreTypes (kafka 0.10.2.0 API) - + +QueryableStoreTypes (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html b/0102/javadoc/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html index ae6ffd3..9fc6b26 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html +++ b/0102/javadoc/org/apache/kafka/streams/state/ReadOnlyKeyValueStore.html @@ -2,15 +2,15 @@ - -ReadOnlyKeyValueStore (kafka 0.10.2.0 API) - + +ReadOnlyKeyValueStore (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/ReadOnlySessionStore.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/ReadOnlySessionStore.html b/0102/javadoc/org/apache/kafka/streams/state/ReadOnlySessionStore.html index dadd735..a6cb5e0 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/ReadOnlySessionStore.html +++ b/0102/javadoc/org/apache/kafka/streams/state/ReadOnlySessionStore.html @@ -2,15 +2,15 @@ - -ReadOnlySessionStore (kafka 0.10.2.0 API) - + +ReadOnlySessionStore (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/ReadOnlyWindowStore.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/ReadOnlyWindowStore.html b/0102/javadoc/org/apache/kafka/streams/state/ReadOnlyWindowStore.html index 9d45d94..9534c04 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/ReadOnlyWindowStore.html +++ b/0102/javadoc/org/apache/kafka/streams/state/ReadOnlyWindowStore.html @@ -2,15 +2,15 @@ - -ReadOnlyWindowStore (kafka 0.10.2.0 API) - + +ReadOnlyWindowStore (kafka 0.10.2.1 API) + @@ -151,7 +151,26 @@ public interface ReadOnlyWindowStore<K,V>
Get all the key-value pairs with the given key and the time range from all - the existing windows.
+ the existing windows. +

+ The time range is inclusive and applies to the starting timestamp of the window. + For example, if we have the following windows: +

+

+ +-------------------------------+
+ |  key  | start time | end time |
+ +-------+------------+----------+
+ |   A   |     10     |    20    |
+ +-------+------------+----------+
+ |   A   |     15     |    25    |
+ +-------+------------+----------+
+ |   A   |     20     |    30    |
+ +-------+------------+----------+
+ |   A   |     25     |    35    |
+ +--------------------------------
+ 
+ And we call store.fetch("A", 10, 20) then the results will contain the first + three windows from the table above, i.e., all those where 10 <= start time <= 20.
Returns:
an iterator over key-value pairs <timestamp, value>
Throws:
InvalidStateStoreException - if the store is not initialized
http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/RocksDBConfigSetter.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/RocksDBConfigSetter.html b/0102/javadoc/org/apache/kafka/streams/state/RocksDBConfigSetter.html index bc16453..d05ea16 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/RocksDBConfigSetter.html +++ b/0102/javadoc/org/apache/kafka/streams/state/RocksDBConfigSetter.html @@ -2,15 +2,15 @@ - -RocksDBConfigSetter (kafka 0.10.2.0 API) - + +RocksDBConfigSetter (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/SessionStore.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/SessionStore.html b/0102/javadoc/org/apache/kafka/streams/state/SessionStore.html index a1be968..aec25c6 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/SessionStore.html +++ b/0102/javadoc/org/apache/kafka/streams/state/SessionStore.html @@ -2,15 +2,15 @@ - -SessionStore (kafka 0.10.2.0 API) - + +SessionStore (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/StateSerdes.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/StateSerdes.html b/0102/javadoc/org/apache/kafka/streams/state/StateSerdes.html index cc2a953..7cf1b39 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/StateSerdes.html +++ b/0102/javadoc/org/apache/kafka/streams/state/StateSerdes.html @@ -2,15 +2,15 @@ - -StateSerdes (kafka 0.10.2.0 API) - + +StateSerdes (kafka 0.10.2.1 API) + @@ -117,7 +117,7 @@ extends Constructor and Description -StateSerdes(String stateName, +StateSerdes(String topic, Serde<K> keySerde, Serde<V> valueSerde)
Create a context for serialization using the specified serializers and deserializers which @@ -179,8 +179,8 @@ extends String -stateName() -
Return the name of the state.
+topic() +
Return the topic.
@@ -209,7 +209,7 @@ extends static <K,V> StateSerdes<K,V> -withBuiltinTypes(String stateName, +withBuiltinTypes(String topic, Class<K> keyClass, Class<V> valueClass)
Create a new instance of StateSerdes for the given state name and key-/value-type classes.
@@ -243,14 +243,14 @@ extends
  • StateSerdes

    -
    public StateSerdes(String stateName,
    +
    public StateSerdes(String topic,
                Serde<K> keySerde,
                Serde<V> valueSerde)
    Create a context for serialization using the specified serializers and deserializers which must match the key and value types used as parameters for this object; the state changelog topic is provided to bind this serde factory to, so that future calls for serialize / deserialize do not need to provide the topic name any more.
    -
    Parameters:
    stateName - the name of the state
    keySerde - the serde for keys; cannot be null
    valueSerde - the serde for values; cannot be null
    +
    Parameters:
    topic - the topic name
    keySerde - the serde for keys; cannot be null
    valueSerde - the serde for values; cannot be null
    Throws:
    IllegalArgumentException - if key or value serde is null
  • @@ -269,11 +269,11 @@ extends
  • withBuiltinTypes

    -
    public static <K,V> StateSerdes<K,V> withBuiltinTypes(String stateName,
    +
    public static <K,V> StateSerdes<K,V> withBuiltinTypes(String topic,
                                           Class<K> keyClass,
                                           Class<V> valueClass)
    Create a new instance of StateSerdes for the given state name and key-/value-type classes.
    -
    Type Parameters:
    K - the key type
    V - the value type
    Parameters:
    stateName - the name of the state
    keyClass - the class of the key type
    valueClass - the class of the value type
    +
    Type Parameters:
    K - the key type
    V - the value type
    Parameters:
    topic - the topic name
    keyClass - the class of the key type
    valueClass - the class of the value type
    Returns:
    a new instance of StateSerdes
  • @@ -343,15 +343,15 @@ extends Returns:
    the value serializer
    -
    +
    • -

      stateName

      -
      public String stateName()
      -
      Return the name of the state.
      -
      Returns:
      the name of the state
      +

      topic

      +
      public String topic()
      +
      Return the topic.
      +
      Returns:
      the topic
    http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/Stores.InMemoryKeyValueFactory.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/Stores.InMemoryKeyValueFactory.html b/0102/javadoc/org/apache/kafka/streams/state/Stores.InMemoryKeyValueFactory.html index 0dd318e..3b5946c 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/Stores.InMemoryKeyValueFactory.html +++ b/0102/javadoc/org/apache/kafka/streams/state/Stores.InMemoryKeyValueFactory.html @@ -2,15 +2,15 @@ - -Stores.InMemoryKeyValueFactory (kafka 0.10.2.0 API) - + +Stores.InMemoryKeyValueFactory (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/Stores.KeyValueFactory.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/Stores.KeyValueFactory.html b/0102/javadoc/org/apache/kafka/streams/state/Stores.KeyValueFactory.html index d51bf6e..cb766a0 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/Stores.KeyValueFactory.html +++ b/0102/javadoc/org/apache/kafka/streams/state/Stores.KeyValueFactory.html @@ -2,15 +2,15 @@ - -Stores.KeyValueFactory (kafka 0.10.2.0 API) - + +Stores.KeyValueFactory (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/Stores.PersistentKeyValueFactory.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/Stores.PersistentKeyValueFactory.html b/0102/javadoc/org/apache/kafka/streams/state/Stores.PersistentKeyValueFactory.html index cfe6a7c..e46342b 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/Stores.PersistentKeyValueFactory.html +++ b/0102/javadoc/org/apache/kafka/streams/state/Stores.PersistentKeyValueFactory.html @@ -2,15 +2,15 @@ - -Stores.PersistentKeyValueFactory (kafka 0.10.2.0 API) - + +Stores.PersistentKeyValueFactory (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/Stores.StoreFactory.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/Stores.StoreFactory.html b/0102/javadoc/org/apache/kafka/streams/state/Stores.StoreFactory.html index 58a4d9a..7a1a1dd 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/Stores.StoreFactory.html +++ b/0102/javadoc/org/apache/kafka/streams/state/Stores.StoreFactory.html @@ -2,15 +2,15 @@ - -Stores.StoreFactory (kafka 0.10.2.0 API) - + +Stores.StoreFactory (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/Stores.ValueFactory.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/Stores.ValueFactory.html b/0102/javadoc/org/apache/kafka/streams/state/Stores.ValueFactory.html index 1b80fd8..fe4ef13 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/Stores.ValueFactory.html +++ b/0102/javadoc/org/apache/kafka/streams/state/Stores.ValueFactory.html @@ -2,15 +2,15 @@ - -Stores.ValueFactory (kafka 0.10.2.0 API) - + +Stores.ValueFactory (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/Stores.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/Stores.html b/0102/javadoc/org/apache/kafka/streams/state/Stores.html index 8af92e5..48119e2 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/Stores.html +++ b/0102/javadoc/org/apache/kafka/streams/state/Stores.html @@ -2,15 +2,15 @@ - -Stores (kafka 0.10.2.0 API) - + +Stores (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/StreamsMetadata.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/StreamsMetadata.html b/0102/javadoc/org/apache/kafka/streams/state/StreamsMetadata.html index 969f37a..10b7f9e 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/StreamsMetadata.html +++ b/0102/javadoc/org/apache/kafka/streams/state/StreamsMetadata.html @@ -2,15 +2,15 @@ - -StreamsMetadata (kafka 0.10.2.0 API) - + +StreamsMetadata (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/WindowStore.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/WindowStore.html b/0102/javadoc/org/apache/kafka/streams/state/WindowStore.html index bd999f8..5f40a01 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/WindowStore.html +++ b/0102/javadoc/org/apache/kafka/streams/state/WindowStore.html @@ -2,15 +2,15 @@ - -WindowStore (kafka 0.10.2.0 API) - + +WindowStore (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/WindowStoreIterator.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/WindowStoreIterator.html b/0102/javadoc/org/apache/kafka/streams/state/WindowStoreIterator.html index cdf0bfa..1328699 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/WindowStoreIterator.html +++ b/0102/javadoc/org/apache/kafka/streams/state/WindowStoreIterator.html @@ -2,15 +2,15 @@ - -WindowStoreIterator (kafka 0.10.2.0 API) - + +WindowStoreIterator (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/package-frame.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/package-frame.html b/0102/javadoc/org/apache/kafka/streams/state/package-frame.html index d081a23..0da3b5d 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/package-frame.html +++ b/0102/javadoc/org/apache/kafka/streams/state/package-frame.html @@ -2,9 +2,9 @@ - -org.apache.kafka.streams.state (kafka 0.10.2.0 API) - + +org.apache.kafka.streams.state (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/package-summary.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/package-summary.html b/0102/javadoc/org/apache/kafka/streams/state/package-summary.html index e2e16c0..e103777 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/package-summary.html +++ b/0102/javadoc/org/apache/kafka/streams/state/package-summary.html @@ -2,15 +2,15 @@ - -org.apache.kafka.streams.state (kafka 0.10.2.0 API) - + +org.apache.kafka.streams.state (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/org/apache/kafka/streams/state/package-tree.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/org/apache/kafka/streams/state/package-tree.html b/0102/javadoc/org/apache/kafka/streams/state/package-tree.html index 0a4bd76..7053eca 100644 --- a/0102/javadoc/org/apache/kafka/streams/state/package-tree.html +++ b/0102/javadoc/org/apache/kafka/streams/state/package-tree.html @@ -2,15 +2,15 @@ - -org.apache.kafka.streams.state Class Hierarchy (kafka 0.10.2.0 API) - + +org.apache.kafka.streams.state Class Hierarchy (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/overview-frame.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/overview-frame.html b/0102/javadoc/overview-frame.html index 437bb6b..60572a2 100644 --- a/0102/javadoc/overview-frame.html +++ b/0102/javadoc/overview-frame.html @@ -2,9 +2,9 @@ - -Overview List (kafka 0.10.2.0 API) - + +Overview List (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/overview-summary.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/overview-summary.html b/0102/javadoc/overview-summary.html index 7e0cd67..4752d4e 100644 --- a/0102/javadoc/overview-summary.html +++ b/0102/javadoc/overview-summary.html @@ -2,15 +2,15 @@ - -Overview (kafka 0.10.2.0 API) - + +Overview (kafka 0.10.2.1 API) + @@ -62,7 +62,7 @@
    -

    kafka 0.10.2.0 API

    +

    kafka 0.10.2.1 API

    http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/overview-tree.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/overview-tree.html b/0102/javadoc/overview-tree.html index 1a4d80e..11dedc7 100644 --- a/0102/javadoc/overview-tree.html +++ b/0102/javadoc/overview-tree.html @@ -2,15 +2,15 @@ - -Class Hierarchy (kafka 0.10.2.0 API) - + +Class Hierarchy (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/javadoc/serialized-form.html ---------------------------------------------------------------------- diff --git a/0102/javadoc/serialized-form.html b/0102/javadoc/serialized-form.html index 72b93c9..f8709dc 100644 --- a/0102/javadoc/serialized-form.html +++ b/0102/javadoc/serialized-form.html @@ -2,15 +2,15 @@ - -Serialized Form (kafka 0.10.2.0 API) - + +Serialized Form (kafka 0.10.2.1 API) + http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/quickstart.html ---------------------------------------------------------------------- diff --git a/0102/quickstart.html b/0102/quickstart.html index 69f6a7a..51d85fd 100644 --- a/0102/quickstart.html +++ b/0102/quickstart.html @@ -282,7 +282,7 @@ data in the topic (or use custom consumer code to process it):

    Kafka Streams is a client library of Kafka for real-time stream processing and analyzing data stored in Kafka brokers. This quickstart example will demonstrate how to run a streaming application coded in this library. Here is the gist -of the WordCountDemo example code (converted to use Java 8 lambda expressions for easy reading). +of the WordCountDemo example code (converted to use Java 8 lambda expressions for easy reading).

     // Serializers/deserializers (serde) for String and Long types
    @@ -446,4 +446,4 @@ console consumer, as described above).
     
     
     
    -
    \ No newline at end of file +
    http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/security.html ---------------------------------------------------------------------- diff --git a/0102/security.html b/0102/security.html index 81d5c40..3443c0c 100644 --- a/0102/security.html +++ b/0102/security.html @@ -903,7 +903,7 @@ Here is an example of how to run the migration tool:
    -    ./bin/zookeeper-security-migration --zookeeper.acl=secure --zookeeper.connection=localhost:2181
    +    ./bin/zookeeper-security-migration --zookeeper.acl=secure --zookeeper.connect=localhost:2181
         

    Run this to see the full list of parameters:

    
    http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/streams.html
    ----------------------------------------------------------------------
    diff --git a/0102/streams.html b/0102/streams.html
    index 6461f86..2b4c441 100644
    --- a/0102/streams.html
    +++ b/0102/streams.html
    @@ -307,7 +307,7 @@
             

    -public class MyProcessor extends Processor<String, String> {
    +public class MyProcessor implements Processor<String, String> {
         private ProcessorContext context;
         private KeyValueStore<String, Long> kvStore;
     
    @@ -355,8 +355,9 @@ public class MyProcessor extends Processor<String, String> {
     
         @Override
         public void close() {
    -        // close the key-value store
    -        this.kvStore.close();
    +        // close any resources managed by this processor.
    +        // Note: Do not close any StateStores as these are managed
    +        // by the library
         }
     };
     
    http://git-wip-us.apache.org/repos/asf/kafka-site/blob/4ac323af/0102/upgrade.html ---------------------------------------------------------------------- diff --git a/0102/upgrade.html b/0102/upgrade.html index 8fe9a4f..58754dd 100644 --- a/0102/upgrade.html +++ b/0102/upgrade.html @@ -18,7 +18,7 @@