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.

Was this helpful?

Edit this page