codelipenghui opened a new issue #11163:
URL: https://github.com/apache/pulsar/issues/11163
```
13:19:00.608 [ForkJoinPool.commonPool-worker-19] WARN
org.apache.pulsar.broker.service.ServerCnx -
[/127.0.0.1:49354][persistent://public/ns/__change_events][reader-2582435224]
Failed to create consumer: consumerId=0,
org.apache.avro.SchemaValidationException: Unable to read schema:
{
"type" : "record",
"name" : "PulsarEvent",
"namespace" : "org.apache.pulsar.common.events",
"fields" : [ {
"name" : "actionType",
"type" : [ "null", {
"type" : "enum",
"name" : "ActionType",
"symbols" : [ "INSERT", "DELETE", "UPDATE", "NONE" ]
} ],
"default" : null
}, {
"name" : "eventType",
"type" : [ "null", {
"type" : "enum",
"name" : "EventType",
"symbols" : [ "TOPIC_POLICY", "TRANSACTION_BUFFER_SNAPSHOT" ]
} ],
"default" : null
}, {
"name" : "topicPoliciesEvent",
"type" : [ "null", {
"type" : "record",
"name" : "TopicPoliciesEvent",
"fields" : [ {
"name" : "domain",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "namespace",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "policies",
"type" : [ "null", {
"type" : "record",
"name" : "TopicPolicies",
"namespace" : "org.apache.pulsar.common.policies.data",
"fields" : [ {
"name" : "backLogQuotaMap",
"type" : [ "null", {
"type" : "map",
"values" : {
"type" : "record",
"name" : "BacklogQuotaImpl",
"namespace" : "org.apache.pulsar.common.policies.data.impl",
"fields" : [ {
"name" : "limitSize",
"type" : "long"
}, {
"name" : "limitTime",
"type" : "int"
}, {
"name" : "policy",
"type" : [ "null", {
"type" : "enum",
"name" : "RetentionPolicy",
"namespace" :
"org.apache.pulsar.common.policies.data.BacklogQuota",
"symbols" : [ "producer_request_hold",
"producer_exception", "consumer_backlog_eviction" ]
} ],
"default" : null
} ]
}
} ],
"default" : null
}, {
"name" : "compactionThreshold",
"type" : [ "null", "long" ],
"default" : null
}, {
"name" : "deduplicationEnabled",
"type" : [ "null", "boolean" ],
"default" : null
}, {
"name" : "deduplicationSnapshotIntervalSeconds",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "delayedDeliveryEnabled",
"type" : [ "null", "boolean" ],
"default" : null
}, {
"name" : "delayedDeliveryTickTimeMillis",
"type" : [ "null", "long" ],
"default" : null
}, {
"name" : "dispatchRate",
"type" : [ "null", {
"type" : "record",
"name" : "DispatchRateImpl",
"namespace" : "org.apache.pulsar.common.policies.data.impl",
"fields" : [ {
"name" : "dispatchThrottlingRateInByte",
"type" : "long"
}, {
"name" : "dispatchThrottlingRateInMsg",
"type" : "int"
}, {
"name" : "ratePeriodInSecond",
"type" : "int"
}, {
"name" : "relativeToPublishRate",
"type" : "boolean"
} ]
} ],
"default" : null
}, {
"name" : "inactiveTopicPolicies",
"type" : [ "null", {
"type" : "record",
"name" : "InactiveTopicPolicies",
"fields" : [ {
"name" : "deleteWhileInactive",
"type" : "boolean"
}, {
"name" : "inactiveTopicDeleteMode",
"type" : [ "null", {
"type" : "enum",
"name" : "InactiveTopicDeleteMode",
"symbols" : [ "delete_when_no_subscriptions",
"delete_when_subscriptions_caught_up" ]
} ],
"default" : null
}, {
"name" : "maxInactiveDurationSeconds",
"type" : "int"
} ]
} ],
"default" : null
}, {
"name" : "maxConsumerPerTopic",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxConsumersPerSubscription",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxMessageSize",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxProducerPerTopic",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxSubscriptionsPerTopic",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxUnackedMessagesOnConsumer",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxUnackedMessagesOnSubscription",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "messageTTLInSeconds",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "offloadPolicies",
"type" : [ "null", {
"type" : "record",
"name" : "OffloadPoliciesImpl",
"fields" : [ {
"name" : "fileSystemProfilePath",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "fileSystemURI",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "gcsManagedLedgerOffloadBucket",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "gcsManagedLedgerOffloadMaxBlockSizeInBytes",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "gcsManagedLedgerOffloadReadBufferSizeInBytes",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "gcsManagedLedgerOffloadRegion",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "gcsManagedLedgerOffloadServiceAccountKeyFile",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "managedLedgerOffloadBucket",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "managedLedgerOffloadDeletionLagInMillis",
"type" : [ "null", "long" ],
"default" : null
}, {
"name" : "managedLedgerOffloadDriver",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "managedLedgerOffloadMaxBlockSizeInBytes",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "managedLedgerOffloadMaxThreads",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "managedLedgerOffloadPrefetchRounds",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "managedLedgerOffloadReadBufferSizeInBytes",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "managedLedgerOffloadRegion",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "managedLedgerOffloadServiceEndpoint",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "managedLedgerOffloadThresholdInBytes",
"type" : [ "null", "long" ],
"default" : null
}, {
"name" : "managedLedgerOffloadedReadPriority",
"type" : [ "null", {
"type" : "enum",
"name" : "OffloadedReadPriority",
"symbols" : [ "BOOKKEEPER_FIRST", "TIERED_STORAGE_FIRST" ]
} ],
"default" : null
}, {
"name" : "offloadersDirectory",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadBucket",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadCredentialId",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadCredentialSecret",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadMaxBlockSizeInBytes",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadReadBufferSizeInBytes",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadRegion",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadRole",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadRoleSessionName",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadServiceEndpoint",
"type" : [ "null", "string" ],
"default" : null
} ]
} ],
"default" : null
}, {
"name" : "persistence",
"type" : [ "null", {
"type" : "record",
"name" : "PersistencePolicies",
"fields" : [ {
"name" : "bookkeeperAckQuorum",
"type" : "int"
}, {
"name" : "bookkeeperEnsemble",
"type" : "int"
}, {
"name" : "bookkeeperWriteQuorum",
"type" : "int"
}, {
"name" : "managedLedgerMaxMarkDeleteRate",
"type" : "double"
} ]
} ],
"default" : null
}, {
"name" : "publishRate",
"type" : [ "null", {
"type" : "record",
"name" : "PublishRate",
"fields" : [ {
"name" : "publishThrottlingRateInByte",
"type" : "long"
}, {
"name" : "publishThrottlingRateInMsg",
"type" : "int"
} ]
} ],
"default" : null
}, {
"name" : "replicatorDispatchRate",
"type" : [ "null",
"org.apache.pulsar.common.policies.data.impl.DispatchRateImpl" ],
"default" : null
}, {
"name" : "retentionPolicies",
"type" : [ "null", {
"type" : "record",
"name" : "RetentionPolicies",
"fields" : [ {
"name" : "retentionSizeInMB",
"type" : "long"
}, {
"name" : "retentionTimeInMinutes",
"type" : "int"
} ]
} ],
"default" : null
}, {
"name" : "subscribeRate",
"type" : [ "null", {
"type" : "record",
"name" : "SubscribeRate",
"fields" : [ {
"name" : "ratePeriodInSecond",
"type" : "int"
}, {
"name" : "subscribeThrottlingRatePerConsumer",
"type" : "int"
} ]
} ],
"default" : null
}, {
"name" : "subscriptionDispatchRate",
"type" : [ "null",
"org.apache.pulsar.common.policies.data.impl.DispatchRateImpl" ],
"default" : null
}, {
"name" : "subscriptionTypesEnabled",
"type" : [ "null", {
"type" : "array",
"items" : {
"type" : "enum",
"name" : "SubType",
"namespace" :
"org.apache.pulsar.common.api.proto.CommandSubscribe",
"symbols" : [ "Exclusive", "Shared", "Failover",
"Key_Shared" ]
},
"java-class" : "java.util.List"
} ],
"default" : null
} ]
} ],
"default" : null
}, {
"name" : "tenant",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "topic",
"type" : [ "null", "string" ],
"default" : null
} ]
} ],
"default" : null
} ]
}
using schema:
{
"type" : "record",
"name" : "PulsarEvent",
"namespace" : "org.apache.pulsar.common.events",
"fields" : [ {
"name" : "eventType",
"type" : [ "null", {
"type" : "enum",
"name" : "EventType",
"symbols" : [ "TOPIC_POLICY" ]
} ],
"default" : null
}, {
"name" : "actionType",
"type" : [ "null", {
"type" : "enum",
"name" : "ActionType",
"symbols" : [ "INSERT", "DELETE", "UPDATE", "NONE" ]
} ],
"default" : null
}, {
"name" : "topicPoliciesEvent",
"type" : [ "null", {
"type" : "record",
"name" : "TopicPoliciesEvent",
"fields" : [ {
"name" : "domain",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "tenant",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "namespace",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "topic",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "policies",
"type" : [ "null", {
"type" : "record",
"name" : "TopicPolicies",
"namespace" : "org.apache.pulsar.common.policies.data",
"fields" : [ {
"name" : "backLogQuotaMap",
"type" : [ "null", {
"type" : "map",
"values" : {
"type" : "record",
"name" : "BacklogQuota",
"fields" : [ {
"name" : "limit",
"type" : "long"
}, {
"name" : "policy",
"type" : [ "null", {
"type" : "enum",
"name" : "RetentionPolicy",
"namespace" :
"org.apache.pulsar.common.policies.data.BacklogQuota",
"symbols" : [ "producer_request_hold",
"producer_exception", "consumer_backlog_eviction" ]
} ],
"default" : null
} ]
}
} ],
"default" : null
}, {
"name" : "persistence",
"type" : [ "null", {
"type" : "record",
"name" : "PersistencePolicies",
"fields" : [ {
"name" : "bookkeeperEnsemble",
"type" : "int"
}, {
"name" : "bookkeeperWriteQuorum",
"type" : "int"
}, {
"name" : "bookkeeperAckQuorum",
"type" : "int"
}, {
"name" : "managedLedgerMaxMarkDeleteRate",
"type" : "double"
} ]
} ],
"default" : null
}, {
"name" : "retentionPolicies",
"type" : [ "null", {
"type" : "record",
"name" : "RetentionPolicies",
"fields" : [ {
"name" : "retentionTimeInMinutes",
"type" : "int"
}, {
"name" : "retentionSizeInMB",
"type" : "long"
} ]
} ],
"default" : null
}, {
"name" : "deduplicationEnabled",
"type" : [ "null", "boolean" ],
"default" : null
}, {
"name" : "messageTTLInSeconds",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxProducerPerTopic",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxConsumerPerTopic",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxConsumersPerSubscription",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxUnackedMessagesOnConsumer",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxUnackedMessagesOnSubscription",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "delayedDeliveryTickTimeMillis",
"type" : [ "null", "long" ],
"default" : null
}, {
"name" : "delayedDeliveryEnabled",
"type" : [ "null", "boolean" ],
"default" : null
}, {
"name" : "offloadPolicies",
"type" : [ "null", {
"type" : "record",
"name" : "OffloadPolicies",
"fields" : [ {
"name" : "offloadersDirectory",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "managedLedgerOffloadDriver",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "managedLedgerOffloadMaxThreads",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "managedLedgerOffloadPrefetchRounds",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "managedLedgerOffloadThresholdInBytes",
"type" : [ "null", "long" ],
"default" : null
}, {
"name" : "managedLedgerOffloadDeletionLagInMillis",
"type" : [ "null", "long" ],
"default" : null
}, {
"name" : "managedLedgerOffloadedReadPriority",
"type" : [ "null", {
"type" : "enum",
"name" : "OffloadedReadPriority",
"namespace" :
"org.apache.pulsar.common.policies.data.OffloadPolicies",
"symbols" : [ "BOOKKEEPER_FIRST", "TIERED_STORAGE_FIRST" ]
} ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadRegion",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadBucket",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadServiceEndpoint",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadMaxBlockSizeInBytes",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadReadBufferSizeInBytes",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadRole",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "s3ManagedLedgerOffloadRoleSessionName",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "gcsManagedLedgerOffloadRegion",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "gcsManagedLedgerOffloadBucket",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "gcsManagedLedgerOffloadMaxBlockSizeInBytes",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "gcsManagedLedgerOffloadReadBufferSizeInBytes",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "gcsManagedLedgerOffloadServiceAccountKeyFile",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "fileSystemProfilePath",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "fileSystemURI",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "managedLedgerOffloadBucket",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "managedLedgerOffloadRegion",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "managedLedgerOffloadServiceEndpoint",
"type" : [ "null", "string" ],
"default" : null
}, {
"name" : "managedLedgerOffloadMaxBlockSizeInBytes",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "managedLedgerOffloadReadBufferSizeInBytes",
"type" : [ "null", "int" ],
"default" : null
} ]
} ],
"default" : null
}, {
"name" : "inactiveTopicPolicies",
"type" : [ "null", {
"type" : "record",
"name" : "InactiveTopicPolicies",
"fields" : [ {
"name" : "inactiveTopicDeleteMode",
"type" : [ "null", {
"type" : "enum",
"name" : "InactiveTopicDeleteMode",
"symbols" : [ "delete_when_no_subscriptions",
"delete_when_subscriptions_caught_up" ]
} ],
"default" : null
}, {
"name" : "maxInactiveDurationSeconds",
"type" : "int"
}, {
"name" : "deleteWhileInactive",
"type" : "boolean"
} ]
} ],
"default" : null
}, {
"name" : "dispatchRate",
"type" : [ "null", {
"type" : "record",
"name" : "DispatchRate",
"fields" : [ {
"name" : "dispatchThrottlingRateInMsg",
"type" : "int"
}, {
"name" : "dispatchThrottlingRateInByte",
"type" : "long"
}, {
"name" : "relativeToPublishRate",
"type" : "boolean"
}, {
"name" : "ratePeriodInSecond",
"type" : "int"
} ]
} ],
"default" : null
}, {
"name" : "subscriptionDispatchRate",
"type" : [ "null", "DispatchRate" ],
"default" : null
}, {
"name" : "compactionThreshold",
"type" : [ "null", "long" ],
"default" : null
}, {
"name" : "publishRate",
"type" : [ "null", {
"type" : "record",
"name" : "PublishRate",
"fields" : [ {
"name" : "publishThrottlingRateInMsg",
"type" : "int"
}, {
"name" : "publishThrottlingRateInByte",
"type" : "long"
} ]
} ],
"default" : null
}, {
"name" : "subscribeRate",
"type" : [ "null", {
"type" : "record",
"name" : "SubscribeRate",
"fields" : [ {
"name" : "subscribeThrottlingRatePerConsumer",
"type" : "int"
}, {
"name" : "ratePeriodInSecond",
"type" : "int"
} ]
} ],
"default" : null
}, {
"name" : "deduplicationSnapshotIntervalSeconds",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxMessageSize",
"type" : [ "null", "int" ],
"default" : null
}, {
"name" : "maxSubscriptionsPerTopic",
"type" : [ "null", "int" ],
"default" : null
} ]
} ],
"default" : null
} ]
} ],
"default" : null
} ]
}
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
