Re: usage of depricated method in kafka 2_12.1.0.0

2018-02-22 Thread Matthias J. Sax
As the JavaDocs point out (https://kafka.apache.org/10/javadoc/org/apache/kafka/streams/kstream/KGroupedStream.html#count-java.lang.String-), the new method is #count(Materialized) for example stream.groupByKey.count(Materialized.as("store-name")); -Matthias On 2/21/18 11:08 PM, pravin kumar

usage of depricated method in kafka 2_12.1.0.0

2018-02-21 Thread pravin kumar
i have tried wikifeed example with Kafka 2_12.1.0.0.the count method is now depricated , previously in kafka_2.11-0.10.2.1 i have given count(localStateStoreName). how to give the statestore name in Kafka 2_12.1.0.0. i have attached the code below, package kafka.examples.wikifeed; import org.ap