Hi Shekar, Could you demonstrate your input data. More specifically, what are the key types of your input streams, and are they not-null values? It seems the root cause is similar to the other thread you asked on the mailing list.
Also, could you provide your used Kafka Streams version? Guozhang On Sun, Jun 25, 2017 at 12:45 AM, Shekar Tippur <[email protected]> wrote: > Hello, > > I am having trouble implementing streams to table join. > > I have 2 POJO's each representing streams and table data structures. raw > topic contains streams and cache topic contains table structure. The join > is not happening since the print statement is not being called. > > Appreciate any pointers. > > - Shekar > > raw.leftJoin(cache, new ValueJoiner<RawPOJOClass, > CachePOJOClass,RawPOJOClass>() { > > @Override > public RawPOJOClass apply(RawPOJOClass r, CachePOJOClass c) { > > String src=r.getSource(); > String cSrc=c.getSnowHost(); > Custom custom=new Custom(); > > if (src.matches(snowSrc)){ > System.out.println("In apply code"); > custom.setAdditionalProperty("custom",cSrc.getAll()); > r.setCustom(custom); > } > return r; > } > }).to("parser"); > -- -- Guozhang
