This is an automated email from the ASF dual-hosted git repository.
penghui pushed a change to branch branch-2.8
in repository https://gitbox.apache.org/repos/asf/pulsar.git.
from 5d52994 Bugfix: Fix rackaware placement policy init error (#12097)
new 5b993ba Fix messages in TopicPolicies will never be cleaned up
(#11928)
new 1b4b71b [pulsar-perf] Make it possible to disable poolMessages
(#12090)
new 9ccfe96 [Client] Fix ConcurrentModificationException in sendAsync
(#11884)
new bff59fd use correct line separator instead of \n (#12143)
new d5d40a2 [pulsar-functions-go] support set subscription position
(#11990)
new b3e7be9 Return the last position of the compacted data while the
original data been deleted. (#12161)
The 6 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:
.../apache/pulsar/broker/service/ServerCnx.java | 33 +++++++--
.../SystemTopicBasedTopicPoliciesService.java | 50 +++++++++----
.../systopic/TopicPoliciesSystemTopicClient.java | 19 +++++
.../apache/pulsar/compaction/CompactedTopic.java | 2 +
.../pulsar/compaction/CompactedTopicImpl.java | 12 +++
.../pulsar/broker/admin/TopicPoliciesTest.java | 79 ++++++++++++++++++++
.../pulsar/client/impl/PulsarTestClient.java | 11 ++-
.../pulsar/compaction/CompactedTopicTest.java | 56 ++++++++++++++
.../apache/pulsar/client/impl/ProducerImpl.java | 78 ++++++++++++++++++--
.../pulsar/client/impl/OpSendMsgQueueTest.java | 85 ++++++++++++++++++++++
.../apache/pulsar/common/util/FutureUtilTest.java | 4 +-
pulsar-function-go/conf/conf.go | 9 ++-
pulsar-function-go/conf/conf.yaml | 1 +
pulsar-function-go/pf/instanceConf.go | 7 +-
pulsar-function-go/pf/instanceConf_test.go | 7 +-
.../functions/instance/go/GoInstanceConfig.java | 2 +
.../pulsar/functions/runtime/RuntimeUtils.java | 2 +
.../pulsar/testclient/PerformanceConsumer.java | 4 +-
18 files changed, 415 insertions(+), 46 deletions(-)
create mode 100644
pulsar-client/src/test/java/org/apache/pulsar/client/impl/OpSendMsgQueueTest.java
