Package io.numaproj.pulsar.consumer

package io.numaproj.pulsar.consumer

Related Packages

Package	Description
io.numaproj.pulsar
io.numaproj.pulsar.config
io.numaproj.pulsar.producer

Classes

Class	Description
PulsarConsumerManager	Lazily creates and caches the Pulsar consumer used by PulsarSource.
PulsarSource	Numaflow user-defined source that reads messages from one or more Pulsar topics.