Determine topic data structure
You can use pulsar-client to examine the structure of Apache Pulsar™ messages for a topic.
This can help you determine your field-to-column mapping.
To show Apache Pulsar messages:
bin/pulsar-client consume TOPIC_NAME -s "SUBSCRIPTION_NAME"
Replace the following:
-
TOPIC_NAME: Name of the Pulsar topic receiving the messages. -
SUBSCRIPTION_NAME: Arbitrary name for the consumer subscription.
The response is the message data when a message is received.
For example, the following response indicates a message with a key of My key and content of My content:
----- got message -----
key:[My key], properties:[], content:My content