GlobalKStore

[pravin kumar]

i have created 3 topics with 10 partitions each

i have intended to store processed information in globalKtable

now i have did with individual Ktable to Output topic then to GlobalKtable

#//

KStreamBuilder builder=new KStreamBuilder();
KStream<String, Long> inputStream =
builder.<String,String>stream(INPUT_TOPICA,INPUT_TOPICB,INPUT_TOPICC)
        .map(((key, value) -> new KeyValue<>(value, value)))
        .groupByKey()
        .count(INPUT_TABLE)
        .toStream();
inputStream.to(Serdes.String(),Serdes.Long(),OUTPUT_TOPIC);
GlobalKTable<Object, Object> objectObjectGlobalKTable =
builder.globalTable(OUTPUT_TOPIC);
KafkaStreams kafkaStreams=new KafkaStreams(builder,props);

//#


how to do it without localStateStore??