`through` = `to` + `stream` operation. So, the consumer-groups command showing the "fname-stream" topic.
Use `to`, if you just want to write the output to the topic. -- Kamal On Mon, Aug 21, 2017 at 12:05 PM, Sachin Mittal <sjmit...@gmail.com> wrote: > Folks any thoughts on this. > Basically I want to know on what topics does consumer group command reports > on. > > I always thought it would only be the topics streams application consumes > from and not write to. > > Any inputs or any part of code I can look at to understand this better > would be helpful. > > Thanks > Sachin > > > On Sun, Aug 6, 2017 at 5:57 PM, Sachin Mittal <sjmit...@gmail.com> wrote: > > > Hi, > > I am executing following command > > bin/kafka-consumer-groups.sh --new-consumer --bootstrap-server > > localhost:9092 --describe --group new-part-advice > > > > It gives output like > > > > GROUP TOPIC PARTITION > > CURRENT-OFFSET LOG-END-OFFSET LAG OWNER > > new-part-advice advice-stream 8 > > 114548551 114548853 302 > > 84-StreamThread-3-consumer_/10.9.56.84 > > new-part-advice fname-stream 1 584 > > 610 26 > > 84-StreamThread-4-consumer_/10.9.56.84 > > ......................... > > > > My pipeline is: > > KStream<String, BeaconNode> input = builder.stream(Serdes.String(), > > beaconSerde, "advice-stream"); > > > > input. > > .... > > foreach(); > > > > > > input. > > .... > > .through(Serdes.String(), valueSerde, "fname-stream"); > > > > So I don't understand why it is showing topic partitions from > fname-stream > > in describe, as the process is just writing to that topic and not > consuming > > from it. > > Also what does lag in the case mean? > > > > Thanks > > Sachin > > > > >
