Package io.numaproj.pulsar.consumer
package io.numaproj.pulsar.consumer
-
ClassesClassDescriptionLazily creates and caches the Pulsar consumer used by PulsarSource.Numaflow user-defined source that reads messages from one or more Pulsar topics.