tfio.experimental.streaming.PulsarWriter

PulsarWriter

tfio.experimental.streaming.PulsarWriter(
    service_url, topic
)

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()

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

write

View source

write(
    value, key=''
)

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: ""