Class PulsarApplication

java.lang.Object

io.numaproj.pulsar.PulsarApplication

public class PulsarApplication
extends Object

Main entry point for the apache-pulsar-java container image. Runs as a Numaflow source (consumer) or sink (producer) based on which is enabled in the configuration file passed via --config=file:/path/to/application.yml.

Constructor Summary

Constructors

Constructor	Description
PulsarApplication()

Method Summary

Modifier and Type	Method	Description
static void	main(String[] args)	Loads the configuration and starts either the consumer or the producer.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

PulsarApplication

public PulsarApplication()

Method Details

main

public static void main(String[] args)
                 throws Exception

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

Parameters:

args - command-line arguments, must include --config=file:/path/to/application.yml

Throws:

Exception - if startup or the gRPC server fails