Skip to content
This repository has been archived by the owner on Apr 1, 2024. It is now read-only.

Bump pulsar version to 3.1.0-SNAPSHOT #6040

Draft
wants to merge 254 commits into
base: master
Choose a base branch
from
Draft
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
254 commits
Select commit Hold shift + click to select a range
8d89904
[fix][build] Fix generating javadoc issue (#20922)
Technoboy- Aug 3, 2023
868ed0b
[fix][broker] Fix incorrect number of read compacted entries (#20978)
coderzc Aug 14, 2023
2dc14d4
[fix][broker] Fix message loss during topic compaction (#20980)
coderzc Aug 14, 2023
4b944a7
Revert "[fix][broker] Fix message loss during topic compaction (#20980)"
coderzc Aug 15, 2023
0c50394
[fix][broker] Fix message loss during topic compaction (#20980)
coderzc Aug 14, 2023
faa7172
[fix][io] Update test certs for Elasticsearch (#21001)
michaeljmarshall Aug 16, 2023
77dc425
[fix][broker] Fix get outdated compactedTopicContext after compaction…
coderzc Aug 16, 2023
fc0cc11
[fix][client] Fix perf-producer get OOM with high publish latency (#2…
codelipenghui Aug 3, 2023
368bee4
[fix] [admin] Fix get topic stats fail if a subscription catch up con…
poorbarcode Aug 20, 2023
4cccfab
[fix][broker] Fix compaction subscription delete by inactive subscrip…
lifepuzzlefun Aug 21, 2023
01c4655
[fix][broker] Fix incorrect unack msk count when dup ack a message (#…
Technoboy- Aug 18, 2023
cd8f7ca
[fix][meta] Fix deadlock in AutoRecovery. (#21010)
horizonzy Aug 21, 2023
399e711
[fix][client] Fix RawReader hasMessageAvailable returns true when no …
Technoboy- Aug 20, 2023
487fc76
[fix][broker] fix ModularLoadManagerImpl always delete active bundle-…
lifepuzzlefun Aug 21, 2023
fd6c4f8
[improve][proxy] Support disabling metrics endpoint (#21031)
michaeljmarshall Aug 19, 2023
c27beca
[fix][broker] Use MessageDigest.isEqual when comparing digests (#21061)
Crispy-fried-chicken Aug 24, 2023
2df8853
[fix][broker] Fix can't stop phase-two of compaction even though mess…
coderzc Aug 22, 2023
f6d2071
[fix][broker] Make sure all inflight writes have finished before com…
coderzc Aug 28, 2023
906fbba
[fix][client] Fix consumer can't consume resent chunked messages (#21…
RobertIndie Aug 29, 2023
4503540
[fix][client] Fix cannot retry chunk messages and send to DLQ (#21048)
RobertIndie Aug 30, 2023
f1d6a15
[improve] [ml] Persist mark deleted ops to ZK if create cursor ledger…
poorbarcode Aug 31, 2023
e4a71ef
[fix][broker]Fix chunked messages will be filtered by duplicating (#2…
liangyepianzhou Aug 31, 2023
95a7a09
[fix][fn] Fix ProducerConfig cannot update error (#21037)
jiangpengcheng Aug 31, 2023
06e4147
[fix][broker] Fix potential case cause retention policy not working o…
Technoboy- Aug 22, 2023
d02ae45
[fix][misc] Bump GRPC version to 1.55.3 to fix CVE (#21057)
mattisonchao Aug 29, 2023
c2d4a8e
[fix][io] Fix --retain[-key]-ordering not working error for sink (#21…
jiangpengcheng Aug 31, 2023
e36db0c
[fix][misc] Bump broker okio version to 3.4.0 (#21064)
mattisonchao Aug 28, 2023
b2c7052
[improve][broker] Make read compacted entries support maxReadSizeByte…
coderzc Sep 1, 2023
59ca24a
[fix] [broker] remove bundle-data in local metadata store. (#21078)
thetumbled Aug 31, 2023
b9051c6
[fix][broker] Fix write duplicate entries into the compacted ledger a…
coderzc Sep 4, 2023
12fd09d
[fix][broker] Cleanup correctly heartbeat bundle ownership when handl…
Demogorgon314 Sep 4, 2023
89b5675
[fix][broker] Avoid splitting one batch message into two entries in S…
Demogorgon314 Sep 4, 2023
67f34a8
[fix][client] Fix logging problem in pulsar client (#21094)
Shawyeok Aug 31, 2023
8e51da1
[fix][broker] Fix unsubscribe non-durable subscription error (#21099)
Technoboy- Sep 1, 2023
f779a19
[fix][client] Avoid ack hole for chunk message (#21101)
liangyepianzhou Sep 4, 2023
db6c7e1
[improve][meta] Improve fault tolerance of blocking calls by supporti…
mattisonchao Aug 21, 2023
e714940
[fix][auto-recovery] Improve to the ReplicaitonWorker performance by …
horizonzy Aug 31, 2023
f5e6feb
[improve][bk] Improve getIsolationGroup by avoid creating arrayList (…
AnonHxy Aug 12, 2023
153840c
[fix] [broker] Fix isolated group not work problem. (#21096)
horizonzy Sep 5, 2023
ebb1c4a
[fix][fn] Fix the --batch-builder not working error for functions (#2…
jiangpengcheng Sep 5, 2023
402e131
[fix][client] Fix repeat consume when using n-ack and batched message…
poorbarcode Sep 5, 2023
3897c4b
[fix] [broker] consider iowait as idle. (#19110)
thetumbled Aug 31, 2023
9f33650
[fix][broker] Fix deleting topic not delete the related topic policy …
Technoboy- Sep 1, 2023
d896814
[fix][broker] revert remove duplicate topics name when deleteNamespac…
TakaHiR07 Sep 5, 2023
702ee73
[improve][broker] Upgrade bookkeeper to 4.16.3 (#21146)
zymap Sep 11, 2023
52a7fb6
[improve] [broker] Improve logs for troubleshooting (#21141)
poorbarcode Sep 6, 2023
87062a5
[fix][broker] Fix web tls url null cause NPE (#21137)
Technoboy- Sep 7, 2023
ec0aa2a
[fix][broker] Fix unack count when mixing non batch index and batch i…
erobot Sep 11, 2023
1b9ff60
[fix][proxy] Fix Proxy 502 gateway error when it is configured with K…
Apurva007 Sep 5, 2023
6a605c8
[fix] [client] fix same producer/consumer use more than one connectio…
poorbarcode Sep 11, 2023
40740c4
[fix][ci] Enable CI for branch-3.1 (#21184)
Technoboy- Sep 14, 2023
5da5b14
[fix][broker] Backport fix UniformLoadShedder selecet wrong overloadb…
aloyszhang Sep 15, 2023
d656cb5
[fix][broker] fix bug caused by optimistic locking (#18390)
thetumbled Sep 15, 2023
ad1a6ee
[fix] [bookie] Fix RocksDB configuration (#21157)
hangc0276 Sep 13, 2023
68a6609
[fix][auto-recovery] Fix metadata store deadlock due to BookkeeperInt…
horizonzy Sep 17, 2023
4139291
[improve] [broker] disable balancing based on DirectMemory. (#21168)
thetumbled Sep 14, 2023
ad69dec
[fix][broker] Fix PulsarService.getLookupServiceAddress returns wron…
Technoboy- Sep 18, 2023
9828326
[fix] [auto-recovery] Fix PulsarLedgerUnderreplicationManager notify …
horizonzy Sep 18, 2023
1212c77
[fix] [auto-recovery] Fix pulsar ledger auditor dead lock problem. (#…
horizonzy Sep 19, 2023
0da5e46
Revert "[fix][broker] Fix PulsarService.getLookupServiceAddress retu…
Technoboy- Sep 21, 2023
0eb1267
[fix][broker] replicator leak when removeReplicator in NonPersistentT…
hanmz Sep 21, 2023
b442cae
[fix][broker] Fixed reset for AggregatedNamespaceStats (#21225)
asafm Sep 24, 2023
c8b8639
[fix][broker]Fixed produce and consume when anonymousUserRole enabled…
tuteng Sep 24, 2023
72c6308
[fix][fn] fix functions_log4j2.xml delete strategy config (#21215)
hanmz Sep 25, 2023
a514a1f
[improve] [client] Merge lookup requests for the same topic (#21232)
poorbarcode Sep 22, 2023
31880ec
[fix][txn] fix the consumer stuck due to deduplicated messages in pen…
hrzzzz Sep 27, 2023
80fb390
Release 3.1.1
Technoboy- Sep 27, 2023
efc4bf3
[fix][sec] Add OWASP Dependency Check suppressions (#21281)
lhotari Sep 30, 2023
9cd2f9e
[fix][build] Upgrade Lombok to 1.18.30 to support compiling with JDK2…
lhotari Sep 30, 2023
5900635
[fix][ml] Fix thread safe issue with RangeCache.put and RangeCache.cl…
lhotari Oct 7, 2023
33553cc
[fix][test] Fix flaky test NarUnpackerTest (#21328)
lhotari Oct 9, 2023
8e3f68f
[fix][test] Fix flaky CompactionTest.testDispatcherMaxReadSizeBytes (…
lhotari Oct 9, 2023
031809e
[fix][broker]Check that the super user role is in the MultiRolesToken…
tuteng Aug 11, 2023
25c84dd
[fix][sec] Fix MultiRoles token provider when using anonymous clients…
merlimat Oct 10, 2023
c98a019
[fix] [broker] fix flaky test PatternTopicsConsumerImplTest (#21222)
poorbarcode Sep 23, 2023
b38c563
[improve] [auto-recovery] [branch-3.1] Migrate the replication testin…
horizonzy Oct 11, 2023
50eb846
[fix] [metadata] Fix zookeeper related flacky test (#21310)
horizonzy Oct 8, 2023
a88fe1f
[fix][broker][branch-3.1] Fix inconsistent topic policy (#21255)
mattisonchao Oct 14, 2023
27f13a1
[fix][ci] Fix docker image building by releasing more disk space befo…
lhotari Oct 14, 2023
662130f
[fix] [broker] Make specified producer could override the previous on…
poorbarcode Sep 13, 2023
baca9a9
[fix][test] Fix a resource leak in ClusterMigrationTest (#21366)
lhotari Oct 16, 2023
ebc79f2
[feat][sql] Support UUID for json and avro (#21267)
liangyepianzhou Oct 9, 2023
d5edbbf
[fix][test] Fix some resource leaks in compaction tests (#21374)
lhotari Oct 17, 2023
f5baebf
[fix][test] Fix resource leaks with Pulsar Functions tests (#21378)
lhotari Oct 17, 2023
0454410
[fix][broker][branch-3.1] Fix lookup heartbeat and sla namespace bund…
Demogorgon314 Oct 18, 2023
9c467bb
[improve][ci] Add new CI unit test group "Broker Group 4" with cluste…
lhotari Oct 18, 2023
dfc2084
[fix][broker] rackaware policy is ineffective when delete zk rack inf…
TakaHiR07 Oct 7, 2023
2ed9a76
[fix][broker] Fix inconsistent topic policy (#21231)
mattisonchao Sep 26, 2023
aba4764
[fix][broker] Fix heartbeat namespace create transaction internal top…
TakaHiR07 Oct 19, 2023
7d097f7
[fix][broker] Fix heartbeat namespace create event topic and cannot d…
TakaHiR07 Oct 19, 2023
5fda6ad
[fix] [bk-client] Fix bk client MinNumRacksPerWriteQuorum and Enforc…
horizonzy Oct 11, 2023
a9e58b1
[improve][broker] use ConcurrentHashMap in ServiceUnitStateChannel an…
heesung-sn Oct 11, 2023
2b2b83d
[fix][broker] Fix unload operation stuck when use ExtensibleLoadManag…
Demogorgon314 Oct 19, 2023
8e5f00e
[fix][sec] Upgrade snappy-java to 1.1.10.5 (#21280)
lhotari Oct 3, 2023
1496925
[fix][proxy] Move status endpoint out of auth coverage (#21428)
mattisonchao Oct 24, 2023
a790d7f
[fix][sec] Upgrade Jetty to 9.4.53 to address CVE-2023-44487 (#21395)
lhotari Oct 19, 2023
6d8e17f
[fix][sec] Upgrade Netty to 4.1.100 to address CVE-2023-44487 (#21397)
lhotari Oct 19, 2023
119b832
Bump version to 3.1.2-SNAPSHOT
lhotari Oct 26, 2023
ce322f0
[fix][sec] Upgrade Zookeeper to 3.8.3 to address CVE-2023-44981 (#21398)
lhotari Oct 19, 2023
9919a37
[fix][broker] Fix MultiRoles token provider NPE when using anonymous …
Technoboy- Oct 25, 2023
7a2e3f6
[fix][broker] Ignore individual acknowledgment for CompactorSubscript…
coderzc Oct 25, 2023
bd9e42b
[fix][build] Fix apt download issue in building the docker image (#21…
lhotari Oct 31, 2023
b71fedc
[fix][txn] Ack all message ids when ack chunk messages with transacti…
liangyepianzhou Nov 8, 2023
c46ed2d
[fix][client] Avert extensive time consumption during table view cons…
liangyepianzhou Nov 6, 2023
c5b4af3
[fix][test] Fix LocalBookkeeperEnsemble resource leak in tests (#21407)
lhotari Oct 23, 2023
7bc4956
[fix][txn] OpRequestSend reuse problem cause tbClient commitTxnOnTopi…
TakaHiR07 Nov 3, 2023
47232c7
[fix][broker] Avoid pass null role in MultiRolesTokenAuthorizationPro…
mattisonchao Nov 2, 2023
80f921a
[fix][broker] Fix issue with consumer read uncommitted messages from …
coderzc Nov 3, 2023
e3cd354
[fix][broker] Fix PulsarService/BrokerService shutdown when brokerShu…
lhotari Nov 1, 2023
d39482f
[fix][broker] Fix namespace bundle stuck in unloading status (#21445)
mattisonchao Nov 8, 2023
af65e30
[fix][broker] Fix create topic with different auto creation strategie…
mattisonchao Nov 10, 2023
bf361fc
[fix][broker] Fix the deadlock when using BookieRackAffinityMapping w…
erobot Nov 10, 2023
8b1a90b
[fix][broker] Fix failure while creating non-durable cursor with inac…
rdhabalia Nov 4, 2023
515cf1d
[fix][client] Fix print error log 'Auto getting partitions failed' wh…
hanmz Nov 11, 2023
d386d14
[fix][ml] Fix unfinished callback when deleting managed ledger (#21530)
mattisonchao Nov 10, 2023
467e9c0
[fix] [broker] Fix thousands orphan PersistentTopic caused OOM (#21540)
poorbarcode Nov 11, 2023
cf78b71
[fix] [ml] Fix orphan scheduled task for ledger create timeout check …
poorbarcode Nov 11, 2023
ceafb3b
Revert "[fix][client] Avert extensive time consumption during table v…
liangyepianzhou Nov 13, 2023
c616deb
Revert "[fix][broker] Fix issue with consumer read uncommitted messag…
coderzc Nov 13, 2023
a303bd1
[fix][broker][branch-3.1] Fix issue with consumer read uncommitted me…
coderzc Nov 13, 2023
5f0a160
[fix][broker] Duplicate LedgerOffloader creation when namespace/topic…
shibd Nov 20, 2023
6ddf83d
[improve][broker] Support not retaining null-key message during topic…
coderzc Nov 22, 2023
4f7d084
[fix] [broker] Delete topic timeout due to NPE (#21595)
poorbarcode Nov 21, 2023
d735346
[fix][broker] Fix setReplicatedSubscriptionStatus incorrect behavior …
liudezhi2098 Nov 12, 2023
a6df6b9
[fix][broker] Do not write replicated snapshot marker when the topic …
liangyepianzhou Nov 14, 2023
3657ee1
[fix][broker] Fix resource_quota_zpath (#21461)
AnonHxy Nov 16, 2023
a8b311f
[cleanup][client] Fix inconsistent API annotations of `getTopicName` …
liangyepianzhou Nov 27, 2023
e6bebab
[fix][sec] Upgrade rabbitmq client to address CVE-2023-46120 (#21619)
liangyepianzhou Nov 27, 2023
372b443
[fix] [build] rename schema_example.conf to schema_example.json (#21447)
poorbarcode Oct 27, 2023
9bc415d
[improve] [broker] Let the producer request success at the first time…
poorbarcode Nov 2, 2023
1ab10da
[fix] [log] fix the vague response if topic not found (#20932)
poorbarcode Nov 28, 2023
9f11039
Release 3.1.2
AnonHxy Nov 30, 2023
0970471
[fix][build] Fix Stage Docker images fail on M1 Mac (#21659)
AnonHxy Dec 2, 2023
80ac009
[improve][admin] Add clusters check when set replication clusters (#2…
Technoboy- Dec 2, 2023
8fc56f0
[fix][broker] Fix memory leak during topic compaction (#21647)
coderzc Dec 2, 2023
78a3964
[fix][broker] Fix lookupRequestSemaphore leak when topic not found (#…
pengxiangrui127 Dec 4, 2023
2eb5423
[fix][admin] Fix KeyValue schema compatibility check caused OOM (#21645)
Technoboy- Nov 30, 2023
4aabd42
[fix][broker] Fixed getting incorrect KeyValue schema version (#21632)
Technoboy- Nov 29, 2023
d458b80
[fix][broker] Fix incorrect unack count when using shared subscriptio…
1Jack2 Nov 30, 2023
a614aad
[improve][build] Upgrade Apache ZooKeeper to 3.9.1 (#20933)
eolivelli Nov 29, 2023
16e6c46
[fix][offload] Don't cleanup data when offload met MetaStore exceptio…
zymap Dec 7, 2023
89b56a1
[fix][broker] Fix typo in the config key (#21690)
coderzc Dec 7, 2023
2393ca7
[improve][broker] Print recoverBucketSnapshot log if cursorProperties…
coderzc Dec 4, 2023
c4196fb
[fix][broker] Record GeoPersistentReplicator.msgOut before producer#s…
nodece Dec 8, 2023
23bf51a
[fix][sec] Bump avro version to 1.11.3 for CVE-2023-39410 (#21341)
tisonkun Oct 17, 2023
9a655b6
[fix] [broker] network package lost if enable haProxyProtocolEnabled …
poorbarcode Dec 8, 2023
309cf4b
[fix][sec] Upgrade org.bouncycastle:bc-fips to 1.0.2.4 (#21730)
Dec 15, 2023
3b51b6c
[improve][broker] Avoid record inactiveproducers when deduplication i…
lifepuzzlefun Dec 21, 2023
30fe564
[fix][broker] Fixed ServiceUnitStateChannel monitor to tombstone only…
heesung-sn Dec 14, 2023
b403f3c
[fix][broker] Skip topic auto-creation for ExtensibleLoadManager inte…
heesung-sn Dec 15, 2023
49490b3
[fix][broker] Fix the issue of topics possibly being deleted. (#21704)
crossoverJie Dec 14, 2023
04ed338
[fix][client] Fix producer thread block forever on memory limit contr…
wenbingshen Dec 26, 2023
d276550
Fix testNoCleanupOffloadLedgerWhenMetadataExceptionHappens
Technoboy- Dec 27, 2023
39b69a3
[fix][broker] Fixed the ExtensibleLoadManagerImpl internal system get…
heesung-sn Dec 27, 2023
b0e8b5a
Upgrade OWASP dependency check maven plugin version
lhotari Jan 2, 2024
fea34d9
[improve][proxy] Fix comment about enableProxyStatsEndpoints (#21757)
lhotari Dec 20, 2023
174e76b
[fix][broker] Fix TableViewLoadDataStoreImpl NPE (#21777)
Demogorgon314 Dec 25, 2023
b7d3a9c
[improve][broker] cleanup the empty subscriptionAuthenticationMap in …
TakaHiR07 Dec 13, 2023
e7e7d3a
[fix][test] Fix PerformanceProducer send count error (#21706)
Technoboy- Dec 12, 2023
ac11655
[fix][fn] Fix Deadlock in Functions Worker LeaderService (#21711)
Technoboy- Dec 12, 2023
1f99568
[fix][broker] Avoid compaction task stuck when the last message to co…
coderzc Dec 20, 2023
1c8aeba
[fix][broker] Delete compacted ledger when topic is deleted (#21745)
coderzc Dec 29, 2023
c55df07
[improve][io] Make connectors load sensitive fields from secrets (#21…
jiangpengcheng Dec 11, 2023
19c9e7f
[fix] [broker] Update topic policies as much as possible when some ex…
poorbarcode Jan 3, 2024
fe1d9ef
[improve][broker] defer the ownership checks if the owner is inactive…
heesung-sn Jan 5, 2024
11eee3c
[fix] [ml] Fix retry mechanism of deleting ledgers to invalidate (#21…
poorbarcode Jan 9, 2024
d9029c6
[fix][broker] Fix compaction/replication data loss when expire messag…
coderzc Jan 11, 2024
84a4885
[improve][broker] Don't rollover empty ledgers based on inactivity (#…
lhotari Jan 15, 2024
3fc7cb4
[fix] [client] Messages lost due to TopicListWatcher reconnect (#21853)
poorbarcode Jan 8, 2024
ce8c291
[fix] [broker] Fix break change: could not subscribe partitioned top…
poorbarcode Jan 15, 2024
c92c485
[improve][build] Add a default username in the image (#21695)
zymap Dec 18, 2023
434b2c3
[fix][broker]Fix NonPersistentDispatcherMultipleConsumers ArrayIndexO…
Technoboy- Jan 8, 2024
d3dee51
[fix][broker] fix the wrong value of BrokerSrevice.maxUnackedMsgsPerD…
aloyszhang Jan 5, 2024
a90e1f1
[fix][client] Fix messages in the batch container timed out unexpecte…
BewareMyPower Jan 16, 2024
4806281
[improve] [client] Prevent reserve memory with a negative memory size…
poorbarcode Dec 26, 2023
2c383a1
[fix][sec] Exclude avro from hadoop-client (#21719)
liangyepianzhou Dec 13, 2023
ea7e978
[improve][broker] Skip loading the NAR packages if not configured (#2…
BewareMyPower Jan 10, 2024
99cab24
[fix][txn] Fix getting last message ID when there are ongoing transac…
liangyepianzhou Dec 13, 2023
7c448fe
[improve][broker] Improve NamespaceUnloadStrategy error message (#21880)
Technoboy- Jan 16, 2024
91e073d
[fix][broker] Fix returns wrong webServiceUrl when both webServicePor…
coderzc Dec 5, 2023
5e0b424
Revert "[fix][broker] Fix returns wrong webServiceUrl when both webSe…
lhotari Jan 25, 2024
628e79d
[fix][broker] Fix PulsarService.getLookupServiceAddress returns wron…
Technoboy- Sep 18, 2023
ba1f8a1
[fix][broker] Fix returns wrong webServiceUrl when both webServicePor…
coderzc Dec 5, 2023
8620610
[fix][broker] Fix returns wrong webServiceUrl when both webServicePor…
Technoboy- Jan 3, 2024
358d122
[fix][broker] Fix leader broker cannot be determined when the adverti…
lhotari Jan 19, 2024
89f722f
[fix][broker] Restore the broker id to match the format used in exist…
lhotari Jan 21, 2024
c315c7b
[fix][test] Make base test class method protected so that it passes R…
lhotari Jan 27, 2024
afabcc2
[improve] [bk] Upgrade BookKeeper dependency to 4.16.4 (#21983)
hangc0276 Jan 29, 2024
fabcc99
[fix] [broker] add timeout for health check read. (#21990)
thetumbled Jan 30, 2024
327b973
[fix][client] Fix ConsumerBuilderImpl#subscribe silent stuck when usi…
Shawyeok Jan 30, 2024
cc22c87
[fix][broker] Correct schema deletion for parititioned topic (#21574)
poorbarcode Nov 21, 2023
75e2142
[fix][broker] Fix schema deletion error when deleting a partitioned t…
heesung-sn Jan 30, 2024
8a56873
[improve] [proxy] Add a check for brokerServiceURL that does not supp…
poorbarcode Jan 30, 2024
313eae5
[fix] [broker] Fix reader stuck when read from compacted topic with r…
thetumbled Jan 30, 2024
dc1b107
[fix][client] Fix multi-topics consumer could receive old messages af…
BewareMyPower Jan 30, 2024
6f7b9d9
[fix][broker] Fix getMessageById throws 500 (#21919)
nodece Jan 19, 2024
37fc40c
[fix][broker] Fix deadlock while skip non-recoverable ledgers. (#21915)
hrzzzz Jan 22, 2024
291bbb5
[fix] [broker] Replication stopped due to unload topic failed (#21947)
poorbarcode Jan 25, 2024
e7f1d03
[fix] [broker] Fix write all compacted out entry into compacted topic…
thetumbled Jan 21, 2024
24d8d9a
[fix][broker] Avoid consumers receiving acknowledged messages from co…
coderzc Jan 26, 2024
b5e4c36
[fix][broker] Fix issue with GetMessageIdByTimestamp can't find match…
coderzc Jan 20, 2024
65ce9d6
[improve][ci] Upgrade pulsar-client-python to 3.4.0 to avoid CVE-2023…
BewareMyPower Jan 16, 2024
e53c19a
Revert "[fix][broker] Fix issue with GetMessageIdByTimestamp can't fi…
coderzc Jan 31, 2024
5bb2264
[fix][broker] Fix issue with GetMessageIdByTimestamp can't find match…
coderzc Jan 20, 2024
84ed73e
[improve][ml] Filter out deleted entries before read entries from led…
dao-jun Jan 19, 2024
9a8761e
[fix][broker] Sanitize values before logging in apply-config-from-env…
lhotari Feb 9, 2024
8cce14c
[fix][broker][branch-3.1] Avoid PublishRateLimiter use an already clo…
coderzc Feb 19, 2024
831f77e
[fix][broker] Support running docker container with gid != 0 (#22081)
lhotari Feb 21, 2024
e896023
[fix][sec] Upgrade commons-compress to 1.26.0 (#22086)
massakam Feb 21, 2024
3d3606b
[improve][fn] Optimize Function Worker startup by lazy loading and di…
lhotari Feb 26, 2024
a13326b
Fix byte-buddy version in presto LICENSE
lhotari Feb 26, 2024
9e8cf15
[fix] [bk] Fix the BookKeeper license (#22000)
hangc0276 Jan 31, 2024
c36da81
[fix] Bump org.apache.solr:solr-core from 8.11.1 to 8.11.3 in /pulsar…
dependabot[bot] Feb 10, 2024
4ca7b78
[improve][ci] Exclude jose4j to avoid CVE-2023-31582 (#21791)
Technoboy- Dec 27, 2023
b10f9c8
[fix][test] Fix test testTransactionBufferMetrics (#22117)
liangyepianzhou Feb 26, 2024
4da9a20
Bump version to 3.1.3-SNAPSHOT
lhotari Feb 27, 2024
6e8ad69
[improve][broker] Cache the internal writer when sent to system topic…
Technoboy- Feb 24, 2024
1fe3853
[improve][admin] Expose the offload threshold in seconds to the amdin…
zymap Feb 23, 2024
aa3f53b
[fix] [broker] Enabling batch causes negative unackedMessages due to …
poorbarcode Feb 26, 2024
b42787b
[fix] [client] fix huge permits if acked a half batched message (#22091)
poorbarcode Feb 26, 2024
ae2299c
[fix][broker] Fix hash collision when using a consumer name that ends…
lhotari Feb 15, 2024
2a6b644
[fix][test] fix test testSyncNormalPositionWhenTBRecover (#22120)
liangyepianzhou Feb 27, 2024
4e97827
[improve][broker] Do not retain the data in the system topic (#22022)
liangyepianzhou Feb 6, 2024
5ab1c05
[improve] [broker] Do not print an Error log when responding to `HTTP…
poorbarcode Feb 18, 2024
2045c5f
[fix] [broker] Subscription stuck due to called Admin API analyzeSubs…
poorbarcode Feb 18, 2024
ad09f78
[fix] [broker] Fix can not subscribe partitioned topic with a suffix-…
poorbarcode Feb 19, 2024
16349e6
[improve] [broker] Not close the socket if lookup failed caused by bu…
poorbarcode Sep 27, 2023
bf5639f
[improve][broker] Do not close the socket if lookup failed due to Loc…
BewareMyPower Feb 2, 2024
98ce27e
[fix] [txn] Get previous position by managed ledger. (#22024)
thetumbled Feb 22, 2024
60fed0d
[fix][sec] Add a check for the input time value (#22023)
liangyepianzhou Feb 26, 2024
d18831f
[improve] [broker] Do not try to open ML when the topic meta does not…
poorbarcode Feb 23, 2024
750547b
[fix][ml] Make mlOwnershipChecker asynchronous so that it doesn't blo…
lhotari Oct 11, 2023
71022f5
[improve][broker] Add an error log to troubleshoot the failure of sta…
liangyepianzhou Feb 18, 2024
6d2ce89
[fix][broker][branch-3.0] Set ServiceUnitStateChannel topic compactio…
heesung-sn Feb 29, 2024
58a45aa
[fix][broker][branch-3.0] Return getOwnerAsync without waiting on sou…
heesung-sn Feb 29, 2024
4f2e4c8
[improve][broker] Add fine-grain authorization to retention admin API…
mattisonchao Feb 29, 2024
69dcf37
Revert "[improve][admin] Expose the offload threshold in seconds to t…
gaoran10 Mar 4, 2024
5808edb
[fix][build][branch-3.1] Fix compile issue in test (#22187)
gaoran10 Mar 4, 2024
fee3a33
[fix] [broker] Expire messages according to ledger close time to avoi…
315157973 Feb 22, 2024
d58d598
[fix][fn] Use unified PackageManagement service to download packages …
jiangpengcheng Jan 31, 2024
09cb541
[fix][broker]Support setting `autoSkipNonRecoverableData` dynamically…
chenhongSZ Feb 18, 2024
7eec36e
[fix] [client] Do no retrying for error subscription not found when d…
zifengmo Feb 26, 2024
c9ecd52
[fix][test] Fix test testAsyncFunctionMaxPending (#22121)
liangyepianzhou Feb 27, 2024
93a4457
[fix][sec] Upgrade Jetty to 9.4.54.v20240208 to address CVE-2024-2220…
lhotari Feb 28, 2024
c6b4887
[fix][txn]Fix TopicTransactionBuffer potential thread safety issue (#…
dao-jun Feb 29, 2024
bbbd1ef
[fix] [broker] print non log when delete partitioned topic failed (#2…
poorbarcode Feb 29, 2024
62de4a5
[fix][offload] Fix Offload readHandle cannot close multi times. (#22162)
dao-jun Feb 29, 2024
b183492
[improve][fn] Add configuration for connector & functions package url…
lhotari Mar 4, 2024
0aff256
Release 3.1.3
gaoran10 Mar 4, 2024
6b4c60d
Release 3.1.0-SNAPSHOT
streamnativebot Mar 4, 2024
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
2 changes: 1 addition & 1 deletion .github/actions/clean-disk/action.yml
Original file line number Diff line number Diff line change
Expand Up @@ -31,7 +31,7 @@ runs:
directories=(/usr/local/lib/android /opt/ghc)
if [[ "${{ inputs.mode }}" == "full" ]]; then
# remove these directories only when mode is 'full'
directories+=(/usr/share/dotnet)
directories+=(/usr/share/dotnet /opt/hostedtoolcache/CodeQL)
fi
emptydir=/tmp/empty$$/
mkdir $emptydir
Expand Down
15 changes: 15 additions & 0 deletions .github/workflows/pulsar-ci.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -22,6 +22,7 @@ on:
pull_request:
branches:
- master
- branch-3.1
schedule:
- cron: '0 12 * * *'
workflow_dispatch:
Expand Down Expand Up @@ -189,6 +190,8 @@ jobs:
group: BROKER_GROUP_2
- name: Brokers - Broker Group 3
group: BROKER_GROUP_3
- name: Brokers - Broker Group 4
group: BROKER_GROUP_4
- name: Brokers - Client Api
group: BROKER_CLIENT_API
- name: Brokers - Client Impl
Expand Down Expand Up @@ -746,6 +749,8 @@ jobs:

- name: Clean Disk
uses: ./.github/actions/clean-disk
with:
mode: full

- name: Cache local Maven repository
uses: actions/cache@v3
Expand Down Expand Up @@ -861,6 +866,7 @@ jobs:

- name: Pulsar IO
group: PULSAR_IO
clean_disk: true

- name: Sql
group: SQL
Expand All @@ -872,6 +878,10 @@ jobs:
- name: Tune Runner VM
uses: ./.github/actions/tune-runner-vm

- name: Clean Disk when needed
if: ${{ matrix.clean_disk }}
uses: ./.github/actions/clean-disk

- name: Setup ssh access to build runner VM
# ssh access is enabled for builds in own forks
if: ${{ github.repository != 'apache/pulsar' && github.event_name == 'pull_request' }}
Expand Down Expand Up @@ -1072,6 +1082,7 @@ jobs:

- name: Pulsar IO - Oracle
group: PULSAR_IO_ORA
clean_disk: true

steps:
- name: checkout
Expand All @@ -1080,6 +1091,10 @@ jobs:
- name: Tune Runner VM
uses: ./.github/actions/tune-runner-vm

- name: Clean Disk when needed
if: ${{ matrix.clean_disk }}
uses: ./.github/actions/clean-disk

- name: Setup ssh access to build runner VM
# ssh access is enabled for builds in own forks
if: ${{ github.repository != 'apache/pulsar' && github.event_name == 'pull_request' }}
Expand Down
28 changes: 14 additions & 14 deletions .idea/vcs.xml

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

5 changes: 2 additions & 3 deletions .mvn/extensions.xml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
<?xml version="1.0" encoding="UTF-8"?>
<?xml version='1.0' encoding='UTF-8'?>
<!--
Licensed to the Apache Software Foundation (ASF) under one
Expand All @@ -19,8 +19,7 @@
under the License.
-->
<extensions xmlns="http://maven.apache.org/EXTENSIONS/1.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/EXTENSIONS/1.0.0 http://maven.apache.org/xsd/core-extensions-1.0.0.xsd">
<extensions xmlns="http://maven.apache.org/EXTENSIONS/1.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/EXTENSIONS/1.0.0 http://maven.apache.org/xsd/core-extensions-1.0.0.xsd">
<extension>
<groupId>com.gradle</groupId>
<artifactId>gradle-enterprise-maven-extension</artifactId>
Expand Down
6 changes: 2 additions & 4 deletions .mvn/gradle-enterprise.xml
Original file line number Diff line number Diff line change
@@ -1,4 +1,4 @@
<?xml version="1.0" encoding="UTF-8" standalone="yes" ?>
<?xml version='1.0' encoding='UTF-8'?>
<!--
Licensed to the Apache Software Foundation (ASF) under one
Expand All @@ -19,9 +19,7 @@
under the License.
-->
<gradleEnterprise
xmlns="https://www.gradle.com/gradle-enterprise-maven" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="https://www.gradle.com/gradle-enterprise-maven https://www.gradle.com/schema/gradle-enterprise-maven.xsd">
<gradleEnterprise xmlns="https://www.gradle.com/gradle-enterprise-maven" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="https://www.gradle.com/gradle-enterprise-maven https://www.gradle.com/schema/gradle-enterprise-maven.xsd">
<server>
<url>https://ge.apache.org</url>
<allowUntrusted>false</allowUntrusted>
Expand Down
14 changes: 3 additions & 11 deletions bouncy-castle/bc/pom.xml
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
<?xml version='1.0' encoding='UTF-8'?>
<!--

Licensed to the Apache Software Foundation (ASF) under one
Expand All @@ -18,44 +19,36 @@
under the License.

-->
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<parent>
<groupId>org.apache.pulsar</groupId>
<groupId>io.streamnative</groupId>
<artifactId>bouncy-castle-parent</artifactId>
<version>3.1.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>

<artifactId>bouncy-castle-bc</artifactId>
<name>Apache Pulsar :: Bouncy Castle :: BC</name>

<dependencies>
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>pulsar-common</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>

<dependency>
<groupId>org.bouncycastle</groupId>
<artifactId>bcpkix-jdk18on</artifactId>
<version>${bouncycastle.version}</version>
</dependency>

<dependency>
<groupId>org.bouncycastle</groupId>
<artifactId>bcprov-ext-jdk18on</artifactId>
<version>${bouncycastle.version}</version>
</dependency>
</dependencies>

<build>
<plugins>

<!-- build a `jar in jar` to avoid break bc signature-->
<plugin>
<groupId>de.ntcomputer</groupId>
Expand All @@ -73,7 +66,6 @@
</execution>
</executions>
</plugin>

<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-checkstyle-plugin</artifactId>
Expand Down
12 changes: 3 additions & 9 deletions bouncy-castle/bcfips-include-test/pom.xml
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
<?xml version='1.0' encoding='UTF-8'?>
<!--

Licensed to the Apache Software Foundation (ASF) under one
Expand All @@ -18,28 +19,24 @@
under the License.

-->
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.pulsar</groupId>
<groupId>io.streamnative</groupId>
<artifactId>bouncy-castle-parent</artifactId>
<version>3.1.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>

<artifactId>bcfips-include-test</artifactId>
<name>Pulsar Bouncy Castle FIPS Test</name>
<description> Broker and client runs auth include BC FIPS verison</description>

<dependencies>
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>testmocks</artifactId>
<version>${project.version}</version>
<scope>test</scope>
</dependency>

<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>pulsar-broker</artifactId>
Expand All @@ -53,7 +50,6 @@
<type>test-jar</type>
<scope>test</scope>
</dependency>

<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>pulsar-broker</artifactId>
Expand All @@ -66,15 +62,13 @@
</exclusions>
<scope>test</scope>
</dependency>

<!--exclude bouncy castle, then load fips version-->
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>bouncy-castle-bcfips</artifactId>
<version>${project.version}</version>
<classifier>pkg</classifier>
</dependency>

</dependencies>
<build>
<plugins>
Expand Down
12 changes: 3 additions & 9 deletions bouncy-castle/bcfips/pom.xml
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
<?xml version='1.0' encoding='UTF-8'?>
<!--

Licensed to the Apache Software Foundation (ASF) under one
Expand All @@ -18,41 +19,34 @@
under the License.

-->
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>

<parent>
<groupId>org.apache.pulsar</groupId>
<groupId>io.streamnative</groupId>
<artifactId>bouncy-castle-parent</artifactId>
<version>3.1.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>

<artifactId>bouncy-castle-bcfips</artifactId>
<name>Apache Pulsar :: Bouncy Castle :: BC-FIPS</name>

<dependencies>
<dependency>
<groupId>${project.groupId}</groupId>
<artifactId>pulsar-common</artifactId>
<version>${project.version}</version>
<scope>provided</scope>
</dependency>

<dependency>
<groupId>org.bouncycastle</groupId>
<artifactId>bc-fips</artifactId>
<version>${bouncycastle.bc-fips.version}</version>
</dependency>

<dependency>
<groupId>org.bouncycastle</groupId>
<artifactId>bcpkix-fips</artifactId>
<version>${bouncycastle.bcpkix-fips.version}</version>
</dependency>
</dependencies>

<build>
<plugins>
<!-- build a `jar in jar` to avoid break bc signature-->
Expand Down
10 changes: 3 additions & 7 deletions bouncy-castle/pom.xml
Original file line number Diff line number Diff line change
@@ -1,3 +1,4 @@
<?xml version='1.0' encoding='UTF-8'?>
<!--

Licensed to the Apache Software Foundation (ASF) under one
Expand All @@ -18,17 +19,15 @@
under the License.

-->
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<packaging>pom</packaging>
<parent>
<groupId>org.apache.pulsar</groupId>
<groupId>io.streamnative</groupId>
<artifactId>pulsar</artifactId>
<version>3.1.0-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>

<build>
<pluginManagement>
<plugins>
Expand All @@ -42,16 +41,13 @@
</plugins>
</pluginManagement>
</build>

<artifactId>bouncy-castle-parent</artifactId>
<name>Apache Pulsar :: Bouncy Castle :: Parent</name>

<!--make it easy for user to load Bouncy Castle and Bouncy Castle FIPS-->
<modules>
<!--2 module for nar-->
<module>bc</module>
<module>bcfips</module>

<!--2 module for fips version test-->
<module>bcfips-include-test</module>
</modules>
Expand Down
4 changes: 4 additions & 0 deletions build/run_unit_group.sh
Original file line number Diff line number Diff line change
Expand Up @@ -87,6 +87,10 @@ function test_group_broker_group_3() {
mvn_test -pl pulsar-broker -Dgroups='broker-admin'
}

function test_group_broker_group_4() {
mvn_test -pl pulsar-broker -Dgroups='cluster-migration'
}

function test_group_broker_client_api() {
mvn_test -pl pulsar-broker -Dgroups='broker-api'
}
Expand Down
Loading
Loading