You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by KhajaAsmath Mohammed <md...@gmail.com> on 2019/10/04 15:42:30 UTC

Kstream to Kafka table

Hi,

I have kstreams table that was created from select statement of ksql table
and kstreams.

Since kstream is process, how do I need to push the data into kafka topic
from this stream? I also want the schema to be created in schema
registry for this topic.

Thanks,
Asmath

Re: Kstream to Kafka table

Posted by Boyang Chen <re...@gmail.com>.

I'm not KSQL expert, but if you want to write SQL queries as commands, you
could check some instructions here:
https://docs.confluent.io/current/ksql/docs/developer-guide/index.html which
is built on top of Kafka Streams.

On Fri, Oct 4, 2019 at 2:27 PM KhajaAsmath Mohammed <md...@gmail.com>
wrote:

> Thanks Chen. Can we do through commands instead of using programming
> library?
>
> Sent from my iPhone
>
> > On Oct 4, 2019, at 3:51 PM, Boyang Chen <re...@gmail.com>
> wrote:
> >
> > Hey Asmath,
> >
> > just for the KStream question, feel free to checkout our official doc:
> >
> https://kafka.apache.org/23/documentation/streams/developer-guide/dsl-api.html
> > if you need to push to a output topic, in DSL there is a #to(String
> topic)
> > function which will write the stream output to your intended topic.
> >
> > Boyang
> >
> > On Fri, Oct 4, 2019 at 8:43 AM KhajaAsmath Mohammed <
> mdkhajaasmath@gmail.com>
> > wrote:
> >
> >> Hi,
> >>
> >> I have kstreams table that was created from select statement of ksql
> table
> >> and kstreams.
> >>
> >> Since kstream is process, how do I need to push the data into kafka
> topic
> >> from this stream? I also want the schema to be created in schema
> >> registry for this topic.
> >>
> >> Thanks,
> >> Asmath
> >>
>

Re: Kstream to Kafka table

Posted by KhajaAsmath Mohammed <md...@gmail.com>.

Thanks Chen. Can we do through commands instead of using programming library?

Sent from my iPhone

> On Oct 4, 2019, at 3:51 PM, Boyang Chen <re...@gmail.com> wrote:
> 
> Hey Asmath,
> 
> just for the KStream question, feel free to checkout our official doc:
> https://kafka.apache.org/23/documentation/streams/developer-guide/dsl-api.html
> if you need to push to a output topic, in DSL there is a #to(String topic)
> function which will write the stream output to your intended topic.
> 
> Boyang
> 
> On Fri, Oct 4, 2019 at 8:43 AM KhajaAsmath Mohammed <md...@gmail.com>
> wrote:
> 
>> Hi,
>> 
>> I have kstreams table that was created from select statement of ksql table
>> and kstreams.
>> 
>> Since kstream is process, how do I need to push the data into kafka topic
>> from this stream? I also want the schema to be created in schema
>> registry for this topic.
>> 
>> Thanks,
>> Asmath
>>

Re: Kstream to Kafka table

Posted by Boyang Chen <re...@gmail.com>.

Hey Asmath,

just for the KStream question, feel free to checkout our official doc:
https://kafka.apache.org/23/documentation/streams/developer-guide/dsl-api.html
if you need to push to a output topic, in DSL there is a #to(String topic)
function which will write the stream output to your intended topic.

Boyang

On Fri, Oct 4, 2019 at 8:43 AM KhajaAsmath Mohammed <md...@gmail.com>
wrote:

> Hi,
>
> I have kstreams table that was created from select statement of ksql table
> and kstreams.
>
> Since kstream is process, how do I need to push the data into kafka topic
> from this stream? I also want the schema to be created in schema
> registry for this topic.
>
> Thanks,
> Asmath
>