How can I create a schema on Javascript pulsar client? When sinking, I can’t map the messages to my Astra table and I think it’s because of the absence of schema. Though on pulsar docs, I saw that the Javascript client doesn’t support schema. What’s the best way to go about this?
This question was
closed
by
Erick Ramirez for the following reason: The question is answered, right answer was accepted
Hi Davip, if you are having a problem pushing data to AstraDB using the Cassandra sink, you don't need a schema. You can write the data as key/value json.
key: {"name":"foo"}
value: {"salary":10000}
then you can map as
name=key.name,salary=value.salary
Please note, you'll need to use the 'StringCassandraSinkTask' version.
6 People are following this question.
