I'm attempting to create a stream from a multi schema topic, similar to the train example at the end of this video. I would then split into multiple streams/topics for each message type. However, I can't seem to create the stream in a way that it's populated with the messages from the multi schema topic. Is there an actual example you can reference for this scenario?
ksqlDB can only connect to one Kafka cluster at a time. Please head over to www.confluent.io/en-gb/community/ask-the-community/ for more help with this requirement.
I noticed that topics and streams are mentioned interchangeably, it it safe to assume the concepts are essentially the same but their usage is where we find the differences? Thank you
I'm attempting to create a stream from a multi schema topic, similar to the train example at the end of this video. I would then split into multiple streams/topics for each message type. However, I can't seem to create the stream in a way that it's populated with the messages from the multi schema topic. Is there an actual example you can reference for this scenario?
KSQL is so incredible. (from Angola)
It certainly is :)
Can we make the insert query persistent ? So then it will be running automatically, not at that time when we write the query
Can I consume from two topics in one Kafka instance, then combine and push it to another Kafka instance?
ksqlDB can only connect to one Kafka cluster at a time. Please head over to www.confluent.io/en-gb/community/ask-the-community/ for more help with this requirement.
is the schema created reused or called ORDERS_COMBINED-value ? or can you use another name ?
The schema is tied to the topic, and inherits (but does not reuse) the parent schema. IIRC it'll take the name of -value by default.
That is what we need, awesome!
Thanks :)
thank you
I noticed that topics and streams are mentioned interchangeably, it it safe to assume the concepts are essentially the same but their usage is where we find the differences? Thank you
Hi Aldo, a stream is a topic but with a schema declared. Both are immutable unbounded streams of events :) Let me know if that answers your question.
@@rmoff Thank you for your reply! It makes a lot of sense now. Great content, keep it up!