Index

A C E G I L M N P R S V
All Classes and Interfaces|All Packages

A

ack(AckRequest) - Method in class io.numaproj.pulsar.consumer.PulsarSource

Acknowledges all messages delivered in the previous read call.

C

cleanup() - Method in class io.numaproj.pulsar.consumer.PulsarConsumerManager

Closes any created consumers and the underlying Pulsar client.

cleanup() - Method in class io.numaproj.pulsar.consumer.PulsarSource

Closes the underlying Pulsar consumers, client, and admin.

cleanup() - Method in class io.numaproj.pulsar.producer.PulsarSink

Flushes buffered records and closes the producer and client.

create(PulsarAdminProperties) - Static method in class io.numaproj.pulsar.config.admin.PulsarAdminConfig

Builds a PulsarAdmin from the supplied properties.

create(PulsarClientProperties) - Static method in class io.numaproj.pulsar.config.client.PulsarClientConfig

Builds a PulsarClient from the supplied client properties.

create(PulsarClient, PulsarProducerProperties, PulsarAdmin) - Static method in class io.numaproj.pulsar.config.producer.PulsarProducerConfig

Creates a new producer using the system environment for pod-name lookup.

create(PulsarClient, PulsarProducerProperties, PulsarAdmin, EnvLookup) - Static method in class io.numaproj.pulsar.config.producer.PulsarProducerConfig

Creates a new producer using the given environment lookup.

E

EnvLookup - Interface in io.numaproj.pulsar.config

Resolves process environment variables by name.

G

get(String) - Method in interface io.numaproj.pulsar.config.EnvLookup

Returns the value of the environment variable, or null if not set.

getOrCreateBytesConsumer(long, long) - Method in class io.numaproj.pulsar.consumer.PulsarConsumerManager

Returns the byte-array consumer, creating it on first call.

getOrCreateGenericRecordConsumer(long, long) - Method in class io.numaproj.pulsar.consumer.PulsarConsumerManager

Returns the AUTO_CONSUME (GenericRecord) consumer, creating it on first call.

getPartitions() - Method in class io.numaproj.pulsar.consumer.PulsarSource

Returns partition indices across all configured topics as a flat list [0, 1, 2, ...].

getPending() - Method in class io.numaproj.pulsar.consumer.PulsarSource

Returns the total subscription backlog across all configured topics.

I

init() - Method in class io.numaproj.pulsar.config.consumer.PulsarConsumerProperties

Normalizes topicNames into a Set and fills in a default subscriptionName based on the NUMAFLOW_PIPELINE_NAME and NUMAFLOW_VERTEX_NAME environment variables.

io.numaproj.pulsar - package io.numaproj.pulsar

io.numaproj.pulsar.config - package io.numaproj.pulsar.config

io.numaproj.pulsar.config.admin - package io.numaproj.pulsar.config.admin

io.numaproj.pulsar.config.client - package io.numaproj.pulsar.config.client

io.numaproj.pulsar.config.consumer - package io.numaproj.pulsar.config.consumer

io.numaproj.pulsar.config.producer - package io.numaproj.pulsar.config.producer

io.numaproj.pulsar.consumer - package io.numaproj.pulsar.consumer

io.numaproj.pulsar.producer - package io.numaproj.pulsar.producer

L

loadConfig(InputStream) - Static method in class io.numaproj.pulsar.config.PulsarConfigLoader

Loads Pulsar config from a YAML input stream.

loadConfig(Path) - Static method in class io.numaproj.pulsar.config.PulsarConfigLoader

Loads Pulsar config from a YAML file.

LoadedPulsarConfig() - Constructor for class io.numaproj.pulsar.config.PulsarConfigLoader.LoadedPulsarConfig

M

main(String[]) - Static method in class io.numaproj.pulsar.PulsarApplication

Loads the configuration and starts either the consumer or the producer.

N

nack(NackRequest) - Method in class io.numaproj.pulsar.consumer.PulsarSource

Not yet implemented.

P

processMessages(DatumIterator) - Method in class io.numaproj.pulsar.producer.PulsarSink

Publishes every datum in the batch to Pulsar and waits for all acks before returning.

PulsarAdminConfig - Class in io.numaproj.pulsar.config.admin

Builds a PulsarAdmin from configuration.

PulsarAdminProperties - Class in io.numaproj.pulsar.config.admin

Holds the pulsar.admin configuration parsed from application.yml.

PulsarAdminProperties() - Constructor for class io.numaproj.pulsar.config.admin.PulsarAdminProperties

PulsarApplication - Class in io.numaproj.pulsar

Main entry point for the apache-pulsar-java container image.

PulsarApplication() - Constructor for class io.numaproj.pulsar.PulsarApplication

PulsarClientConfig - Class in io.numaproj.pulsar.config.client

Builds a PulsarClient from configuration.

PulsarClientProperties - Class in io.numaproj.pulsar.config.client

Holds the pulsar.client configuration parsed from application.yml.

PulsarClientProperties() - Constructor for class io.numaproj.pulsar.config.client.PulsarClientProperties

PulsarConfigLoader - Class in io.numaproj.pulsar.config

Loads and parses the application.yml configuration into typed property objects.

PulsarConfigLoader() - Constructor for class io.numaproj.pulsar.config.PulsarConfigLoader

PulsarConfigLoader.LoadedPulsarConfig - Class in io.numaproj.pulsar.config

Bundle of all four config sections parsed from application.yml.

PulsarConsumerManager - Class in io.numaproj.pulsar.consumer

Lazily creates and caches the Pulsar consumer used by PulsarSource.

PulsarConsumerManager(PulsarConsumerProperties, PulsarClient) - Constructor for class io.numaproj.pulsar.consumer.PulsarConsumerManager

Creates a new manager.

PulsarConsumerProperties - Class in io.numaproj.pulsar.config.consumer

Parsed representation of the pulsar.consumer section of application.yml.

PulsarConsumerProperties() - Constructor for class io.numaproj.pulsar.config.consumer.PulsarConsumerProperties

PulsarProducerConfig - Class in io.numaproj.pulsar.config.producer

Builds a Pulsar Producer from configuration.

PulsarProducerProperties - Class in io.numaproj.pulsar.config.producer

Parsed representation of the pulsar.producer section of application.yml.

PulsarProducerProperties() - Constructor for class io.numaproj.pulsar.config.producer.PulsarProducerProperties

PulsarSink - Class in io.numaproj.pulsar.producer

Numaflow user-defined sink that publishes messages to a Pulsar topic.

PulsarSink(Producer<byte[]>, PulsarClient, PulsarProducerProperties) - Constructor for class io.numaproj.pulsar.producer.PulsarSink

Creates a new sink.

PulsarSource - Class in io.numaproj.pulsar.consumer

Numaflow user-defined source that reads messages from one or more Pulsar topics.

PulsarSource(PulsarConsumerManager, PulsarAdmin, PulsarConsumerProperties) - Constructor for class io.numaproj.pulsar.consumer.PulsarSource

Creates a new source.

R

read(ReadRequest, OutputObserver) - Method in class io.numaproj.pulsar.consumer.PulsarSource

Reads a batch of messages from the configured Pulsar topic(s) and forwards them to Numaflow.

S

startServer() - Method in class io.numaproj.pulsar.consumer.PulsarSource

Starts the Numaflow gRPC server and blocks until it terminates.

startServer() - Method in class io.numaproj.pulsar.producer.PulsarSink

Starts the Numaflow gRPC server and blocks until it terminates.

system() - Static method in interface io.numaproj.pulsar.config.EnvLookup

Returns a lookup that reads environment variables from the current process.

V

validateConfig() - Method in class io.numaproj.pulsar.config.producer.PulsarProducerProperties

Validates the configuration to catch unsupported combinations of fields.

A C E G I L M N P R S V
All Classes and Interfaces|All Packages