Examples

Publish a message

Then at some future time (even a different session):

values(dbsdk_v1.kafka_publish( TOPIC   => 'fun_facts',
                              KEY     => 'baritone43',
                              MSGDATA => 'The baritone is a very interesting musical instrument!'));

Publish a message with a per-job topic

Then at some future time (even a different session):

call dbsdk_v1.kafka_settopicforjob('fun_facts');
values(dbsdk_v1.kafka_publish( KEY     => 'baritone43',
                              MSGDATA => 'The baritone is a very interesting musical instrument!'));

Publish a message with a persistent topic

call once:

call dbsdk_v1.kafka_settopicforme('fun_facts');

Then at some future time (even a different session):

values(dbsdk_v1.kafka_publish( KEY     => 'baritone43',
                              MSGDATA => 'The baritone is a very interesting musical instrument!'));