This is an automated email from the ASF dual-hosted git repository.
lhotari pushed a change to branch branch-4.1
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from afc0823a53d [improve][broker] Cache last publish timestamp for idle
topics to reduce storage reads (#24825)
new f2233d6d851 [improve][client] PIP-420: Update the schema ID format
(#24798)
new 27cd15141a7 [fix][test] Fixed nondeterministic JSON ordering in
multiple tests (#24821)
new 53b26f7ad97 [fix] Fix mixed lookup/partition metadata requests causing
reliability issues and incorrect responses (#24832)
new 978762d4340 [fix][client] Fix getPendingQueueSize for
PartitionedTopicProducerStatsRecorderImpl: avoid NPE and implement aggregation
(#24830)
The 4 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:
pip/pip-420.md | 7 ++-
.../apache/pulsar/broker/service/ServerCnx.java | 19 ++++++--
.../apache/pulsar/schema/ExternalSchemaTest.java | 15 +++---
.../java/org/apache/pulsar/client/api/Schema.java | 4 +-
.../apache/pulsar/common/schema/SchemaIdUtil.java | 55 ++++++++++++++++++++++
.../org/apache/pulsar/client/impl/ClientCnx.java | 2 +-
.../org/apache/pulsar/client/impl/MessageImpl.java | 6 ++-
.../PartitionedTopicProducerStatsRecorderImpl.java | 8 ++++
.../client/impl/ProducerStatsRecorderImpl.java | 2 +-
.../client/impl/TypedMessageBuilderImpl.java | 8 +++-
.../apache/pulsar/client/impl/ClientCnxTest.java | 5 +-
.../client/impl/ProducerStatsRecorderImplTest.java | 25 ++++++++++
.../client/impl/schema/SchemaIdUtilTest.java | 49 +++++++++++++++++++
.../SupportVersioningKeyValueSchemaTest.java | 4 +-
pulsar-common/pom.xml | 7 +++
.../pulsar/common/protocol/PulsarDecoder.java | 5 ++
.../data/NamespaceOwnershipStatusTest.java | 8 +++-
.../impl/NamespaceIsolationPoliciesTest.java | 8 +++-
pulsar-functions/utils/pom.xml | 7 +++
.../functions/utils/FunctionConfigUtilsTest.java | 10 ++--
.../functions/utils/SinkConfigUtilsTest.java | 22 ++++++---
.../functions/utils/SourceConfigUtilsTest.java | 10 ++--
pulsar-io/elastic-search/pom.xml | 7 +++
.../io/elasticsearch/ElasticSearchExtractTest.java | 35 +++++++++++---
pulsar-io/kinesis/pom.xml | 7 +++
.../org/apache/pulsar/io/kinesis/UtilsTest.java | 20 +++++---
26 files changed, 305 insertions(+), 50 deletions(-)
create mode 100644
pulsar-client-api/src/main/java/org/apache/pulsar/common/schema/SchemaIdUtil.java
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/schema/SchemaIdUtilTest.java
