Package org.springframework.pulsar.function
@NonNullApi
@NonNullFields
package org.springframework.pulsar.function
Package containing support for
Pulsar Functions and
Pulsar IO Connectors.
-
ClassDescriptionRepresents a user-defined Pulsar Function backed by a
FunctionConfig
.Responsible for creating and updating any user-defined Pulsar functions, sinks, or sources.Indicates a failure of one or more function operations.Provides operations for a particular function type.The action to take on the function when the server stops.The type of function the operations handle.Represents a Pulsar Sink backed by aSinkConfig
.Represents a Pulsar Source backed by aSourceConfig
.