package proto

Get desktop application:
View/edit binary Protocol Buffers messages

• optional Instance instance = 1

• string workerId = 2

Used in: ProducerSpec

• LZ4 = 0

• NONE = 1

• ZLIB = 2

• ZSTD = 3

• SNAPPY = 4

Used in: SourceSpec

• string schemaType = 1

• string serdeClassName = 2

• bool isRegexPattern = 3

• optional ConsumerSpec.ReceiverQueueSize receiverQueueSize = 4

• map<string, string> schemaProperties = 5

• map<string, string> consumerProperties = 6

• optional CryptoSpec cryptoSpec = 7

• bool poolMessages = 8

Used in: ConsumerSpec

• int32 value = 1

Used in: ConsumerSpec, ProducerSpec

• string cryptoKeyReaderClassName = 1

• string cryptoKeyReaderConfig = 2

• repeated string producerEncryptionKeyName = 3

  key names used by producer to encrypt data

• CryptoSpec.FailureAction producerCryptoFailureAction = 4

  define the action if producer fail to encrypt data one of FAIL, SEND

• CryptoSpec.FailureAction consumerCryptoFailureAction = 5

  define the action if consumer fail to decrypt data one of FAIL, DISCARD, CONSUME

Used in: CryptoSpec

• FAIL = 0

• DISCARD = 1

• CONSUME = 2

• SEND = 10

Used in: FunctionMetaData

• bytes data = 1

  * function authentication related data that the function authentication provider needs to cache/distribute to all workers support function authentication. Depending on the function authentication provider implementation, this can be the actual auth credentials or a pointer to the auth credentials that this function should use

• string provider = 2

  * classname of the function auth provicer this data is relevant to

Used in: FunctionMetaData

• string tenant = 1

• string namespace = 2

• string name = 3

• string className = 4

• string logTopic = 5

• ProcessingGuarantees processingGuarantees = 6

• string userConfig = 7

• string secretsMap = 16

• FunctionDetails.Runtime runtime = 8

• bool autoAck = 9

  Deprecated since, see https://github.com/apache/pulsar/issues/15560

• int32 parallelism = 10

• optional SourceSpec source = 11

• optional SinkSpec sink = 12

• optional Resources resources = 13

• string packageUrl = 14

  present only if function submitted with package-url

• optional RetryDetails retryDetails = 15

• string runtimeFlags = 17

• FunctionDetails.ComponentType componentType = 18

• string customRuntimeOptions = 19

• string builtin = 20

  If specified, this will refer to an archive that is already present in the server

• bool retainOrdering = 21

• bool retainKeyOrdering = 22

• SubscriptionPosition subscriptionPosition = 23

Used in: FunctionDetails

• UNKNOWN = 0

• FUNCTION = 1

• SOURCE = 2

• SINK = 3

Used in: FunctionDetails

• JAVA = 0

• PYTHON = 1

• GO = 3

Used in: Instance

• optional FunctionDetails functionDetails = 1

• optional PackageLocationMetaData packageLocation = 2

• uint64 version = 3

• uint64 createTime = 4

• map<int32, FunctionState> instanceStates = 5

• optional FunctionAuthenticationSpec functionAuthSpec = 6

• optional PackageLocationMetaData transformFunctionPackageLocation = 7

Used in: FunctionMetaData

• RUNNING = 0

• STOPPED = 1

Used in: Assignment

• optional FunctionMetaData functionMetaData = 1

• int32 instanceId = 2

Used in: FunctionMetaData

• string packagePath = 1

• string originalFileName = 2

Used in: FunctionDetails

• ATLEAST_ONCE = 0

  [default value]

• ATMOST_ONCE = 1

• EFFECTIVELY_ONCE = 2

• MANUAL = 3

Used in: SinkSpec

• int32 maxPendingMessages = 1

• int32 maxPendingMessagesAcrossPartitions = 2

• bool useThreadLocalProducers = 3

• optional CryptoSpec cryptoSpec = 4

• string batchBuilder = 5

• CompressionType compressionType = 6

Used in: FunctionDetails

• double cpu = 1

• int64 ram = 2

• int64 disk = 3

Used in: FunctionDetails

• int32 maxMessageRetries = 1

• string deadLetterTopic = 2

Used in: FunctionDetails

• string className = 1

• string configs = 2

  map in json format

• string typeClassName = 5

• string topic = 3

  configs used only when functions output to sink

• optional ProducerSpec producerSpec = 11

• string serDeClassName = 4

• string builtin = 6

  If specified, this will refer to an archive that is already present in the server

• string schemaType = 7

  * Builtin schema type or custom schema class name

• bool forwardSourceMessageProperty = 8

• map<string, string> schemaProperties = 9

• map<string, string> consumerProperties = 10

Used in: FunctionDetails

• string className = 1

• string configs = 2

  map in json format

• string typeClassName = 5

• SubscriptionType subscriptionType = 3

  configs used only when source feeds into functions

• map<string, string> topicsToSerDeClassName = 4

  @deprecated -- use topicsToSchema

• map<string, ConsumerSpec> inputSpecs = 10

  *

• uint64 timeoutMs = 6

• string topicsPattern = 7

• string builtin = 8

  If specified, this will refer to an archive that is already present in the server

• string subscriptionName = 9

• bool cleanupSubscription = 11

• SubscriptionPosition subscriptionPosition = 12

• uint64 negativeAckRedeliveryDelayMs = 13

• bool skipToLatest = 14

Used in: FunctionDetails, SourceSpec

• LATEST = 0

• EARLIEST = 1

Used in: SourceSpec

• SHARED = 0

• FAILOVER = 1

• KEY_SHARED = 2