apache/pulsar
Documented errors, page 15 of 16. Back to apache/pulsar
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Windowing is not supported in Go function yet | validation | error | pulsar-functions, go-runtime, windowing, unsupported-feature |
| Function parallelism must be a positive number | validation | error | pulsar-functions, validation, parallelism, configuration |
| Incompatible schema: existing schema is not in valid Avro fo | exception | error | pulsar, json-schema, avro, pip-464 |
| %s %s doesn't have instance with id %s | http | warning | rest-api, bad-request, instance-id, pulsar-functions |
| Subscription already exists for topic | http | error | |
| Create subscription on non-persistent topic can only be done | http | error | rest-api, subscription, non-persistent |
| Keys and values must be >= 0 | validation | error | java, illegal-argument, precondition |
| Package URL ${pkgLocationPath} is not valid | validation | error | pulsar-functions, worker, download, package-url, validation |
| Unauthorized to validateTopicPolicyOperation for operation [ | http | error | |
| com.google.protobuf.Message is not assignable from ${pojo.ge | exception | error | protobuf, schema, illegal-argument |
| Function class %s not found | validation | error | pulsar-functions, sink, classpath, configuration |
| Invalid format for fully qualified instance name: | validation | error | pulsar-functions, parsing, illegal-argument |
| Quota type of 'message_age' needs a time limit | validation | error | cli, parameter-validation, backlog-quota, pulsar-admin |
| Resource group already exists:${rgName} | exception | error | pulsar, admin-api, duplicate, conflict |
| Size of data received by FloatSchema is not 4 | exception | error | schema, serialization, float |
| The input schema is not of type 'org.apache.avro.Schema'. | exception | error | avro, schema, illegal-argument |
| auth plugin %s given, but authParams is empty | error_code | error | go, authentication, configuration, token |
| Input Topics cannot be altered | validation | error | pulsar-functions, immutable-field, update-validation, input-topics |
| numPartitionsLimit should be greater than or equal to 1 | validation | error | producer, router, argument-validation, configuration |
| Option --version must be greater than 0, but found %d | validation | error | cli, schema, validation |
| rack name is invalid, it should not be null, empty or '/' | validation | error | validation, illegal-argument, configuration, rack |
| Size of data received by LongSchema is not 8 | exception | error | schema, serialization, pulsar-client |
| Transform function class name must be set | validation | error | pulsar-functions, sink, service-loader, configuration |
| AutoAck cannot be altered | validation | error | pulsar, functions, deprecated-field, config-validation |
| checkHealthyIntervalMs must be larger than 0 | exception | error | pulsar-client, configuration, validation, illegal-argument |
| Failed to load the protocol handler for protocol `${protocol | exception | critical | broker, startup, protocol-handler, classloader |
| Protocol handler for `${handler}` attempts to use ${address} | exception | critical | broker, port-conflict, protocol-handler, configuration |
| the broker do not have ${advertisedListenerName} listener | exception | error | |
| From schema is not a KEY_VALUE schema. | exception | error | pulsar, key-value-schema, compatibility |
| Invalid topic domain: '${value}' | validation | error | enum, parsing, illegal-argument |
| maxConsumersPerTopic must be 0 or more | validation | error | http-412, consumers, validation, admin-api |
| Unrecognized auto_failover_policy: ${policyType} | validation | error | enum, configuration, illegal-argument, policy |
| Unsupported statsType: ${statsType} | exception | error | |
| Cannot parse sink-config | exception | error | cli, json, configuration |
| Expire message by timestamp is not supported for non-persist | exception | warning | java, broker, non-persistent, ttl, unsupported-operation |
| Invalid retention policy type '%s'. Valid options are: %s | validation | warning | cli, parameter-validation, backlog-quota, enum |
| ${name} cannot be less than <${min}>! | validation | error | cli, validation, argument, pulsar |
| unknown token format - expecting "file://" or "token:" prefi | error_code | error | go, authentication, token, configuration |
| Allowed offset for athenz role token verification must not b | console | error | athenz, authentication, configuration, validation |
| Close interrupted | exception | error | pulsar, client, close, interrupt |
| maxTopicsPerNamespace must be 0 or more | validation | error | |
| Processing Guarantees cannot be altered | validation | error | pulsar-functions, immutable-field, delivery-guarantees |
| property filter must be in the form key=value, got: ${entry} | http | warning | validation, rest-api, query-params |
| Source config is not provided | http | warning | validation, http-400, rest-api, request-body |
| Sources cannot be update between regular sources and batchso | validation | error | pulsar-functions, batch-source, update-validation |
| Topic does not exist: ${persistentBase} | http | error | rest, not-found, migration, scalable-topics, http-404 |
| Worker ${workerId} is not among the current workers in the s | http | error | rest-api, drain, invalid-parameter |
| Failed to serialize package metadata as JSON | exception | error | serialization, json, jackson, packages |
| Message payload processor class does not have constructor ac | exception | error | pulsar-functions, reflection, constructor, message-payload-processor |
| Size of data received by ByteSchema is not 1 | exception | error | pulsar, schema, int8, validation, serialization |
| Currently only AVRO and JSON record schema is supported | exception | error | schema, record, unsupported-type |
| Error creating client for HealthChecker | exception | error | java, broker, health-check, pulsar-client, startup |
| incrementUsage on tenant=%s, NS=%s: bytes (%s) or mesgs (%s) | exception | error | |
| NoSuchElementException | exception | error | java, nosuchelement, empty-collection |
| Only one of retain ordering or retain key ordering can be se | validation | error | pulsar-functions, sink, configuration, validation |
| Function config is not provided | validation | error | pulsar-functions, rest-api, validation |
| ResourceGroup does not exist | http | error | |
| Sink timeout must be a positive number | validation | error | pulsar, config-validation, timeout |
| Subscription not found on segment: ${subscription} | http | warning | rest, not-found, subscription, backlog, segment, http-404 |
| Cannot read GCS service account credentials file (wraps IOEx | validation | error | |
| Per instance CPU requested, %s, for function is less than th | validation | error | kubernetes, resources, cpu, quota, admission |
| Per instance RAM requested, %s, for function is less than th | validation | error | kubernetes, resources, memory, quota, admission |
| The adminApiUrl is empty, brokerClientTlsEnabled: ${isTlsEna | exception | error | |
| Cannot prune an active segment: ${segmentId} | validation | error | java, illegal-argument, segment-state, prune |
| Failed to delete the state value for key '%s' | exception | error | state, bookkeeper, delete, blocking-call |
| Failed to update to value:%s | exception | error | conflict, badversion, concurrency, optimistic-locking |
| If you set --clear then you should not pass any properties | validation | warning | cli, parameter-validation, mutually-exclusive-flags |
| Namespaces differ | validation | error | pulsar-functions, immutable-field, update-validation |
| ResourceGroupCreate: can't create resource group with an emp | validation | error | pulsar, admin-api, validation, illegal-argument |
| Sink parallelism must be a positive number | validation | error | pulsar, config-validation, parallelism |
| Topic was already terminated | exception | error | |
| Only one of schemaType or serdeClassName should be set in in | validation | error | pulsar, functions, schema, configuration |
| Per instance RAM requested, %s, for function is greater than | validation | error | kubernetes, resources, memory, quota, admission |
| Tenants differ | validation | error | pulsar-functions, immutable-field, update-validation |
| Termination of a non-persistent topic is not allowed | http | error | |
| end timestamp should be positive. | validation | error | cli, validation, arguments, timestamp |
| isRegexPattern for input topic cannot be altered | validation | error | pulsar, functions, config-validation, immutable-field |
| key '%s' doesn't exist. | http | warning | rest-api, not-found, state-store, functions |
| schema type must be 'bytes' or 'auto_consume' | validation | error | cli, schema, validation, auto-consume |
| Must pass one of the params: --bundle | validation | error | cli, parameter-validation, pulsar-admin, hash-positions |
| Namespace bundles do not contain the child bundle:${childBun | exception | error | |
| When effectively once processing guarantee is specified, ret | validation | error | pulsar-functions, sink, configuration, validation |
| Key is not provided | validation | error | pulsar-functions, missing-parameter, function-state, validation |
| Shadow topic [${shadowTopic}] not exists. | http | error | |
| Topic was already migrated | exception | error | |
| Data block header magic word not match. read: ${magic} expec | exception | error | |
| Invalid backlog quota type '%s'. Valid options are: %s | validation | warning | cli, parameter-validation, backlog-quota, enum |
| Namespace is not provided | validation | error | pulsar-functions, rest-api, validation |
| Resource group does not exist: ${name} | exception | error | broker, resource-group, not-found |
| Topic is temporarily unavailable | exception | error | |
| (wraps ClassNotFoundException for BrokerEntryMetadataInterce | exception | error | classpath, broker-entry-metadata, configuration, reflection |
| Class ${sinkClass} does not implement interface org.apache.p | exception | error | pulsar-io, connector, type-mismatch, sink |
| Field '${name}' cannot be null! | validation | error | config-validation, null, notnull |
| GetMessageIDByIndex is not allowed on partitioned-topic | http | error | |
| No active segments | exception | error | routing, segment-layout, illegal-state, pulsar-client |
| off=${off}, len=${len}, b.length=${b.length} | validation | error | indexoutofbounds, io, inputstream, bounds-check |
| ${paramName} cannot be less than or equal to 0! | validation | error | |
| Source archive not specified | validation | error | cli, pulsar-io, missing-argument |
| Transaction ` | exception | error | |
| Close interrupted | exception | error | pulsar, client, close, interrupt |