This is an automated email from the ASF dual-hosted git repository.
zhaijia pushed a change to branch branch-2.5
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 2b5cc0d Remove problematic semicolon from conf (#6303)
new 76dfd14 Creating a topic does not wait for creating cursor of
replicators (#6364)
new df8dd62 [Minor] Fix java code errors reported by lgtm. (#6398)
new 8a64dc6 [Java Reader Client] Start reader inside batch result in read
first message in batch. (#6345)
new f2a4a8d Add verification for SchemaDefinitionBuilderImpl.java (#6405)
new 377948c Update BatchReceivePolicy.java (#6423)
new 14508a6 Consumer received duplicated deplayed messages upon restart
new 41d91c8 Bump netty version to 4.1.45.Final (#6424)
new db14c79 fix the bug of authenticationData is't initialized. (#6440)
new 30b1818 Close ZK before canceling future with exception (#6228)
(#6399)
new 462453b [Flink-Connector]Get PulsarClient from cache should always
return an open instance (#6436)
new 0e9d448 [Broker] Create namespace failed when TLS is enabled in
PulsarStandalone (#6457)
new f6ce0ea Use System.nanoTime() instead of System.currentTimeMillis()
(#6454)
new d8c9a24 Fixed the max backoff configuration for lookups (#6444)
new 481c744 [pulsar-proxy] fix logging for published messages (#6474)
new de174aa Avoid calling ConsumerImpl::redeliverMessages() when message
list is empty (#6480)
new 1ca5822 [pulsar-client] fix deadlock on send failure (#6488)
new 27b369b Independent schema is set for each consumer generated by
topic (#6356)
The 17 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
distribution/server/src/assemble/LICENSE.bin.txt | 32 ++---
.../bookkeeper/mledger/impl/ManagedCursorImpl.java | 9 +-
.../mledger/impl/ManagedLedgerOfflineBacklog.java | 2 +-
.../bookkeeper/mledger/util/CallbackMutex.java | 2 +-
pom.xml | 2 +-
.../java/org/apache/pulsar/PulsarStandalone.java | 32 +++--
.../pulsar/broker/admin/impl/BrokersBase.java | 2 +-
.../pulsar/broker/service/AbstractReplicator.java | 38 +++---
.../nonpersistent/NonPersistentReplicator.java | 5 +
.../service/persistent/PersistentReplicator.java | 71 ++++++++++-
.../broker/service/persistent/PersistentTopic.java | 37 ++----
.../schema/JsonSchemaCompatibilityCheckTest.java | 5 +
.../client/api/SimpleProducerConsumerTest.java | 71 +++++++++--
.../apache/pulsar/client/api/TopicReaderTest.java | 74 +++++++++--
.../java/org/apache/pulsar/schema/SchemaTest.java | 136 +++++++++++++++++++++
.../pulsar/schema/{compatibility => }/Schemas.java | 2 +-
.../SchemaCompatibilityCheckTest.java | 22 ++--
.../pulsar/client/admin/internal/BaseResource.java | 2 +-
.../pulsar/client/api/BatchReceivePolicy.java | 7 +-
.../java/org/apache/pulsar/client/api/Schema.java | 9 +-
pulsar-client-cpp/lib/NegativeAcksTracker.cc | 4 +-
.../client/kafka/compat/PulsarKafkaSchema.java | 5 +
.../client/kafka/compat/PulsarKafkaSchema.java | 5 +
.../client/impl/BinaryProtoLookupService.java | 2 +-
.../apache/pulsar/client/impl/ConsumerBase.java | 11 +-
.../apache/pulsar/client/impl/ConsumerImpl.java | 41 +++++--
.../client/impl/MultiTopicsConsumerImpl.java | 9 +-
.../apache/pulsar/client/impl/ProducerImpl.java | 35 +++---
.../pulsar/client/impl/PulsarClientImpl.java | 29 +++--
.../pulsar/client/impl/schema/AbstractSchema.java | 5 +
.../client/impl/schema/AutoConsumeSchema.java | 14 +++
.../client/impl/schema/AutoProduceBytesSchema.java | 5 +
.../pulsar/client/impl/schema/AvroSchema.java | 10 ++
.../pulsar/client/impl/schema/KeyValueSchema.java | 5 +
.../client/impl/schema/KeyValueSchemaInfo.java | 5 +
.../impl/schema/SchemaDefinitionBuilderImpl.java | 9 ++
.../impl/schema/generic/GenericAvroSchema.java | 10 ++
.../impl/schema/generic/GenericSchemaImpl.java | 1 -
...dTest.java => SchemaDefinitionBuilderTest.java} | 33 +++--
.../pulsar/common/policies/data/Policies.java | 2 +-
.../apache/pulsar/common/sasl/KerberosName.java | 2 +-
.../connectors/pulsar/CachedPulsarClient.java | 8 +-
.../connectors/pulsar/CachedPulsarClientTest.java | 25 ++++
.../pulsar/functions/source/SerDeSchema.java | 4 +
.../pulsar/proxy/server/ParserProxyHandler.java | 2 +-
.../pulsar/proxy/server/ProxyConnection.java | 1 +
.../server/ProxyConnectionThrottlingTest.java | 2 +-
.../proxy/server/ProxyLookupThrottlingTest.java | 4 +-
pulsar-sql/presto-distribution/LICENSE | 30 ++---
.../zookeeper/ZookeeperBkClientFactoryImpl.java | 1 +
50 files changed, 687 insertions(+), 192 deletions(-)
create mode 100644
pulsar-broker/src/test/java/org/apache/pulsar/schema/SchemaTest.java
rename pulsar-broker/src/test/java/org/apache/pulsar/schema/{compatibility =>
}/Schemas.java (97%)
copy
pulsar-client/src/test/java/org/apache/pulsar/client/api/{MessageIdTest.java =>
SchemaDefinitionBuilderTest.java} (57%)
