ErrLookup › apache/pulsar
apache/pulsar
Apache Pulsar - distributed pub-sub messaging system · Java · 2,748 source files
Analyzed at 820761864e on 2026-09-06. 1587 documented errors.
| Code / Message | Type | Severity | Tags |
|---|---|---|---|
| Invalid version type, expected it to be LongVersion | exception | error | bookkeeper, metadata-store, cookie, version-mismatch, optimistic-concurrency |
| Either a Java jar or a Python file or a Go executable binary | validation | error | cli, validation, pulsar-functions |
| Failed to write cookie for bookie ${bookieId} | exception | error | bookkeeper, metadata-store, cookie, connectivity, zookeeper |
| Failed to check exist ${POLICIES_READONLY_FLAG_PATH} | exception | error | metadata-store, zookeeper, timeout, broker-startup |
| Entry-bucket subscription must declare the segment's bucket | validation | error | pulsar, key-shared, entry-bucket, subscription-config |
| Error during schema compatibility check with strategy ${stra | exception | error | java, schema, avro, compatibility-check |
| Exception while resuming auto ledger re-replication | exception | error | metadata-store, zookeeper, timeout, bookkeeper-replication |
ERROR_RETRIEVING_PUBLIC_KEY No JWK found for Key ID | exception | error | jwt, jwks, oidc, key-rotation, authentication |
INVALID_JWT_CLAIM JWT contains invalid claim: | exception | error | auth, oidc, jwt, claims |
| Failed to get schema ledger for${key} | exception | error | java, ioexception, bookkeeper, schema-storage |
| Unexpected metadata type: ${className} | exception | error | java, deserialization, serialization, package-management |
| Local cluster is not part of replicate cluster list | http | error | pulsar, geo-replication, rest-api, configuration |
| The BCFIPS provider is registered but its DEFAULT SP 800-90A | exception | critical | fips, bouncycastle, secure-random, cryptography, class-initialization |
| Illegal syntax: <uri> | validation | error | java, uri, input-validation |
| Interrupted writing cookie for bookie ${bookieId} | exception | warning | bookkeeper, metadata-store, cookie, interrupted, shutdown |
| Authentication has not completed | exception | error | authentication, oidc, lifecycle, java |
| When effectively once processing guarantee is specified, ret | validation | error | pulsar-functions, config-validation, illegal-argument |
| ${fieldName} must use the broker binary protocol (pulsar:// | exception | error | configuration, url, client-builder, validation |
| Error contacting with metadata store | exception | error | metadata-store, zookeeper, timeout, bookkeeper |
| Configured truststore 'trustStorePath' holds no X.509 certif | exception | critical | tls, security, keystore, configuration |
| TlsPolicy field '${field}' is set but is not valid for forma | validation | error | tls, configuration, validation, pem, keystore |
| Failed to compute configuration overrides | exception | error | java, reflection, configuration, pulsar |
| Unable to find EC Parameter for the given curve oid: ${ecOID | exception | error | crypto, ecdsa, pem, key-parsing, bouncycastle |
| Entry-bucket boundaries must be ascending, contiguous and st | validation | error | pulsar, key-shared, entry-bucket, validation |
| Transaction pending ack replay error with illegal state : | validation | error | transaction, replay, illegal-state |
| Window function must take a collection as input | exception | error | pulsar-functions, windowing, type-mismatch |
| error while booting GSSAPI client | exception | error | kerberos, gssapi, sasl, jvm, configuration |
| Failed to create instance for key reader class | exception | error | reflection, instantiation, crypto, configuration |
| Partitioned topic is not available in effectively_once mode. | exception | error | python, pulsar-functions, effectively-once, partitioned-topic |
| Error while getting ReplicationWorkerId rereplicating Ledger | exception | error | zookeeper, metadata-store, ledger-lock, bookkeeper |
| The retention time must > the backlog quota limit time, but | validation | error | broker, configuration, startup, backlog-quota, retention |
| Failed to add schema to an active topic with empty(BYTES) sc | exception | error | pulsar, broker, schema, incompatible-schema, topic |
| ${fieldName} must use the broker binary protocol (pulsar:// | exception | error | pulsar, configuration, service-url, protocol, validation |
| brokerCloseInactiveTopicsEnabled only supports brokerDeleteI | validation | error | broker, configuration, startup, topics, conflicting-flags |
| Interrupted deleting cookie for bookie ${bookieId} | exception | warning | bookkeeper, metadata-store, cookie, interrupted, decommission |
| Window function must take a collection as input | validation | error | function-config, windowing, type-mismatch, validation |
| Cursor %s mark-delete position %s is ahead of the last posit | validation | error | io, corruption, offload, bookkeeper |
| error writing discovered task to intermediate topic | exception | critical | pulsar-functions, batch-source, producer, intermediate-topic |
| GenericSchema interface implementation class must rewrite th | exception | error | generic-schema, interface-static, unsupported-operation |
| The retention size must > the backlog quota limit size, but | validation | error | broker, configuration, startup, backlog-quota, retention |
| ${e.getCause()} | exception | error | consumer, subscription, builder |
| Failed to decode message from topic ${topic} with schemaId $ | exception | error | pulsar, schema, deserialization, client |
| failed to initialize %s field while setting value %s | exception | error | reflection, config, offload |
| Another partition exists for [${topicName}]. | exception | error | pulsar, broker, topic-deletion, partitioned-topic, unsupported-operation |
| Failed to open state table for function ${tenant}/${namespac | exception | error | state, bookkeeper, timeout, table-service, runtime-exception |
| Cannot use receive() when a listener has been set | exception | error | pulsar, configuration, consumer, invalid-configuration |
| Error caching authentication data for %s %s:- %s | http | error | rest-api, internal-server-error, authentication, pulsar-functions |
| The topic has a max partition index of %d, the number of par | http | error | pulsar, broker, rest-conflict, partitioned-topic |
UNSUPPORTED_ISSUER Issuer not allowed: | exception | error | oidc, issuer-validation, kubernetes, configuration, authentication |
| Built-in ${componentType} is not available | validation | error | pulsar-functions, builtin-connector, configuration |
| Failed to acquire TLS material for purpose ${purpose} | exception | critical | tls, ssl, keystore, jetty, pulsar |
| SHA-256 algorithm not found | exception | error | java, security, crypto, configuration |
| (wraps subscribeAsync failure cause) | exception | error | subscription, pulsar-client, async, wrapped-exception |
| The driver %s is not supported, (Possible values: %s). | validation | error | cli, configuration, offload, pulsar-admin |
| the PulsarTlsFactory passed to tlsFactory(...) has already b | exception | error | pulsar, tls, lifecycle, illegal-state, builder-reuse |
| Sliding interval must be positive [${slidingIntervalCount}] | validation | error | pulsar-functions, configuration, windowing, validation |
| Unauthorized to validateClusterOperation for originalPrincip | http | error | authorization, rest-api, admin, clusters |
| Invalid authentication token | exception | error | sasl, token, parsing, authentication |
| Number of transaction coordinators should be more than the c | http | warning | pulsar, admin-api, transactions, rest-exception, idempotency |
| RestException(e) | exception | error | rest-api, metadata-store, resourcegroups, update-failed |
| Error while parsing ZK data of lock | exception | error | data-corruption, parse-error, zookeeper, ledger-lock, compatibility |
| Different MessageId in Map get different compare result | exception | warning | pulsar, messageid, partitioned, compareto, illegal-argument, ordering |
| delete mode can only be set to delete_when_no_subscriptions | validation | error | cli, enum-value, pulsar-admin |
| RestException(conversionError) | exception | error | pulsar, schema-registry, rest-api, json, key-value-schema |
| The message payload processor class %s does not implement th | validation | error | java, pulsar-functions, configuration, constructor-validation |
| The PIP-337 '${key}' client configuration key is removed in | validation | error | client-configuration, tls, upgrade, removed-api |
| Authentication state is not initialized | exception | error | authentication, broker, state |
| KubernetesSecretsProviderConfigurator should only be setup f | exception | error | kubernetes, pulsar-functions, secrets, configuration |
| Ranges must be [0, 65535] but provided range is | validation | error | keyshared, hash-range, illegal-argument, client-config |
| %s Package is not provided | exception | error | rest-api, validation, pulsar-functions, sink, bad-request |
| Cannot delete non empty namespace | http | error | pulsar, rest-api, namespace-deletion, conflict |
| reconsumeLater method not supported because retryEnabled is | exception | error | pulsar, retry, configuration, reconsume-later |
| Timeout during reset cursor | exception | error | io, eof, truncation, offload |
| Cannot load Pulsar Client Implementation: | exception | critical | classpath, reflection, dependency-missing, startup |
| e | http | error | rest-api, metadata-store, resourcegroups, internal-server-error |
| Segment not found | validation | error | java, illegal-argument, segment-not-found, segment-layout |
| The record returned by the source cannot be null | validation | error | java, pulsar-functions, source, null-check |
| The supplied python file does not exist | validation | error | pulsar-functions, config-validation, filesystem, builtin |
| Cannot create JVM SASL Client | exception | error | sasl, kerberos, jvm, security-provider |
| Failed to encode to json | exception | error | jackson, json-serialization, config |
| Unauthorized to validateBothSuperuserAndClusterOperation for | http | error | authorization, unauthorized, superuser, cluster-admin, security |
| User class must have a no-arg constructor | exception | error | pulsar-functions, windowing, reflection, access-modifier |
| Failed to parse tlsFactoryConfig as a JSON object | validation | error | configuration, tls, json, broker |
| fromIndex < 0: <fromIndex> | validation | error | java, bitset, index-out-of-bounds |
| Per instance cpu requested, %s, for function should be posit | validation | error | pulsar-functions, kubernetes, resource-validation, configuration |
| Need to specify either enable-delete-while-inactive or disab | validation | error | cli, parameter-validation, pulsar-admin |
| the `advertisedListeners` configuration does not contain an | validation | error | configuration, advertised-listeners, multi-listener, broker |
| Cannot create ${narExtractionTempDirectory} | exception | error | filesystem, io, nar |
| ${e.getMessage()} | exception | error | authentication, configuration, plugin |
| No extension is found for extension name `${extensionName}`. | exception | error | proxy, configuration, extension, nar, startup |
| Error contacting metadata store | exception | error | metadata-store, delete-failed, zookeeper, bookkeeper |
| Failed to get cluster instance id | exception | error | zookeeper, bookie-registration, metadata-store, timeout |
| Package Management Service is not enabled in the broker. | exception | error | broker, configuration, packages, unsupported-operation |
| Transaction recover tracker` | validation | error | transaction, recovery, replay, invalid-status |
| Failed to check if ledger is beinge replicated | exception | error | metadata-store, zookeeper, ledger-replication, timeout |
| Invalid key-shared mode: ${keySharedMode} | validation | error | pulsar, key-shared, enum, protocol-compatibility |
| Invalid short topic name '${completeTopicName}', it should b | validation | error | java, illegal-argument, topic-name, pulsar |
| User class must either be Function or java.util.Function | exception | critical | pulsar-functions, function-api, class-loading, configuration |
| ${cause} | exception | error | pulsar, producer, async, exception-wrapping |
| e.getMessage() | http | error | rest-api, schema, functions, serialization |