This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 724032b MINOR: Fix incorrect JavaDoc (type mismatch) (#4632)
724032b is described below
commit 724032bd06ae6928595ad3d5d21ead7f9e834d34
Author: Detharon <[email protected]>
AuthorDate: Tue Mar 13 00:32:19 2018 +0100
MINOR: Fix incorrect JavaDoc (type mismatch) (#4632)
Reviewers: Guozhang Wang <[email protected]>
---
streams/src/main/java/org/apache/kafka/streams/state/Stores.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/streams/src/main/java/org/apache/kafka/streams/state/Stores.java
b/streams/src/main/java/org/apache/kafka/streams/state/Stores.java
index 0aaa2b2..daa2915 100644
--- a/streams/src/main/java/org/apache/kafka/streams/state/Stores.java
+++ b/streams/src/main/java/org/apache/kafka/streams/state/Stores.java
@@ -55,7 +55,7 @@ import java.util.Objects;
* KeyValueBytesStoreSupplier storeSupplier =
Stores.inMemoryKeyValueStore("queryable-store-name");
* KTable<Long,String> table = builder.table(
* "topicName",
- * Materialized.as(storeSupplier)
+ * Materialized.<Long,String>as(storeSupplier)
* .withKeySerde(Serdes.Long())
* .withValueSerde(Serdes.String())
* .withCachingDisabled());
--
To stop receiving notification emails like this one, please contact
[email protected].
