pyflink.datastream.connectors.pulsar.PulsarSource

class PulsarSource(j_pulsar_source)

The Source implementation of Pulsar. Please use a PulsarSourceBuilder to construct a PulsarSource. The following example shows how to create a PulsarSource emitting records of String type.

Example:

>>> source = PulsarSource() \
...     .builder() \
...     .set_topics([TOPIC1, TOPIC2]) \
...     .set_service_url(get_service_url()) \
...     .set_admin_url(get_admin_url()) \
...     .set_subscription_name("test") \
...     .set_deserialization_schema(
...         PulsarDeserializationSchema.flink_schema(SimpleStringSchema())) \
...     .set_bounded_stop_cursor(StopCursor.default_stop_cursor()) \
...     .build()

See PulsarSourceBuilder for more details.

Methods

builder()	Get a PulsarSourceBuilder to builder a PulsarSource.
get_java_function()