Extract Pulsar record header values
In the Apache Pulsar™ topic mapping, you can extract values from the message properties, and write the values to a supported database table.
For example:
topic:
my_topic
my_keyspace:
my_table:
mapping: 'col1=key.f1, col2=value.f1, __ttl=value.f2, __timestamp=value.f3, col3=header.f4'Use one or more individual mapping statements to extract the desired values and have them written to the database table.
