tfio.experimental.streaming.PulsarWriter

PulsarWriter

service_url A tf.string tensor containing the service url of pulsar broker. For example: "pulsar://localhost:6650".
topic A tf.string tensor containing the topic name.

Methods

flush

View source

Flush the queued messages, it will wait async write operations completed.

write

View source

Write a message to pulsar topic asynchronously

Args
value A tf.string tensor containing the value of message
key A tf.string tensor containing the key of message, if it's an empty string, the message will have no key. Default: ""