Uses of Class
io.numaproj.pulsar.config.producer.PulsarProducerProperties
Packages that use PulsarProducerProperties
-
Uses of PulsarProducerProperties in io.numaproj.pulsar.config.producer
Methods in io.numaproj.pulsar.config.producer with parameters of type PulsarProducerPropertiesModifier and TypeMethodDescriptionstatic org.apache.pulsar.client.api.Producer<byte[]> PulsarProducerConfig.create(org.apache.pulsar.client.api.PulsarClient pulsarClient, PulsarProducerProperties pulsarProducerProperties, org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin) Creates a new producer using the system environment for pod-name lookup.static org.apache.pulsar.client.api.Producer<byte[]> PulsarProducerConfig.create(org.apache.pulsar.client.api.PulsarClient pulsarClient, PulsarProducerProperties pulsarProducerProperties, org.apache.pulsar.client.admin.PulsarAdmin pulsarAdmin, EnvLookup envLookup) Creates a new producer using the given environment lookup. -
Uses of PulsarProducerProperties in io.numaproj.pulsar.producer
Constructors in io.numaproj.pulsar.producer with parameters of type PulsarProducerPropertiesModifierConstructorDescriptionPulsarSink(org.apache.pulsar.client.api.Producer<byte[]> producer, org.apache.pulsar.client.api.PulsarClient pulsarClient, PulsarProducerProperties producerProperties) Creates a new sink.