Code

[pull] master from apache:master#27

Code

Merged

nodece merged 78 commits intonodece:masternodece/pulsar:masterfrom apache:masterapache/pulsar:masterCopy head branch name to clipboardFeb 27, 2024

+12,152-6,946

Commits

Commits on Jan 19, 2024

• [fix][fn] Throw 404 RestException when state key not found (#21921)

  jiangpengcheng

  authored
  0f2523f

  Copy full SHA for 0f2523f

• [fix][broker] Fix getMessageById throws 500 (#21919)

  Show description for 55520bd
  nodece

  authored
  55520bd

  Copy full SHA for 55520bd

• [improve][ml] Filter out deleted entries before read entries from ledger. (#21739)

  dao-jun

  authored
  c66167b

  Copy full SHA for c66167b

• [fix][broker] Fix leader broker cannot be determined when the advertised address and advertised listeners are configured (#21894)

  lhotari

  authored
  3158fd3

  Copy full SHA for 3158fd3

• [improve][misc] Upgrade Netty version to 4.1.105.Final (#21923)

  Technoboy-

  authored
  74f1cd5

  Copy full SHA for 74f1cd5

Commits on Jan 20, 2024

• [fix][broker] Fix issue with GetMessageIdByTimestamp can't find match messageId from compacted ledger (#21600)

  coderzc

  authored
  5cb12a5

  Copy full SHA for 5cb12a5

Commits on Jan 21, 2024

• [fix] [broker] Fix write all compacted out entry into compacted topic (#21917)

  thetumbled

  authored
  40eebc0

  Copy full SHA for 40eebc0

• [improve] [broker] PIP-299-part-5: Add namespace-level policy: dispatcherPauseOnAckStatePersistent (#21926)

  Technoboy-

  authored
  17bb322

  Copy full SHA for 17bb322

• [fix][broker] Restore the broker id to match the format used in existing Pulsar releases (#21937)

  lhotari

  authored
  6347315

  Copy full SHA for 6347315

Commits on Jan 22, 2024

• [fix][broker] Unify topic-level policies enable judgment conditions (#19501)

  Show description for 153cd5e
  

  aloyszhang

  and

  Technoboy-

  authored
  153cd5e

  Copy full SHA for 153cd5e

• [fix][broker] Fix deadlock while skip non-recoverable ledgers. (#21915)

  Show description for 5a65e98
  

  4 peopleauthored
  5a65e98

  Copy full SHA for 5a65e98

• [fix] [broker] correct compaction phase one timeout meaning (#21908)

  Show description for 3fa85f0
  thetumbled

  authored
  3fa85f0

  Copy full SHA for 3fa85f0

• [feat][admin] PIP-330: getMessagesById gets all messages (#21918)

  Show description for 22f7323
  nodece

  authored
  22f7323

  Copy full SHA for 22f7323

• [fix] [test] Fix test code create namespace conflict (#21941)

  thetumbled

  authored
  b14fcb4

  Copy full SHA for b14fcb4

Commits on Jan 23, 2024

• [improve][pip] PIP-321 Introduce allowed-cluster at the namespace level (#21648)

  Show description for 480a229
  liangyepianzhou

  authored
  480a229

  Copy full SHA for 480a229

Commits on Jan 24, 2024

• [improve][broker] Reduce ResourceGroup log (#21957)

  Show description for 1b5550d
  nodece

  authored
  1b5550d

  Copy full SHA for 1b5550d

• [fix] Restored method as deprecated in AbstractMetadataStore (#21950)

  Show description for 4198ed2
  

  merlimat

  and

  Technoboy-

  authored
  4198ed2

  Copy full SHA for 4198ed2

Commits on Jan 25, 2024

• [fix][build] Fix potential insufficient protostuff-related configs (#21629)

  equanz

  authored
  de4edd0

  Copy full SHA for de4edd0

• [fix] [broker] Replication stopped due to unload topic failed (#21947)

  Show description for 200c5f4
  poorbarcode

  authored
  200c5f4

  Copy full SHA for 200c5f4

• [cleanup] [broker] fix doc for TransactionBuffer#isTxnAborted (#21956)

  Show description for 434da8b
  thetumbled

  authored
  434da8b

  Copy full SHA for 434da8b

Commits on Jan 26, 2024

• [fix][broker] Avoid consumers receiving acknowledged messages from compacted topic after reconnection (#21187)

  coderzc

  authored
  e81a20d

  Copy full SHA for e81a20d

• [improve][broker] PIP-315: Configurable max delay limit for delayed delivery (#21798)

  Show description for d37d31f
  

  3 peopleauthored
  d37d31f

  Copy full SHA for d37d31f

Commits on Jan 27, 2024

• [fix][test] Make base test class method protected so that it passes ReportUnannotatedMethods validation (#21976)

  lhotari

  authored
  67354b1

  Copy full SHA for 67354b1

• [improve][ci] Upgrade GitHub Actions versions to fix deprecation warning (#21978)

  lhotari

  authored
  bd913b5

  Copy full SHA for bd913b5

• [fix][fn] Add missing version field back to querystate API (#21966)

  jiangpengcheng

  authored
  48e64b3

  Copy full SHA for 48e64b3

Commits on Jan 28, 2024

• [fix][build] Remove duplicate mapping key in docker-compose yaml file (#21979)

  Denovo1998

  authored
  8a18043

  Copy full SHA for 8a18043

Commits on Jan 29, 2024

• [improve] [bk] Upgrade BookKeeper dependency to 4.16.4 (#21983)

  hangc0276

  authored
  ae272a5

  Copy full SHA for ae272a5

Commits on Jan 30, 2024

• [fix][broker] Fix schema deletion error when deleting a partitioned topic with many partitions and schema (#21977)

  heesung-sn

  authored
  1b4127a

  Copy full SHA for 1b4127a

• [fix][client] Fix ConsumerBuilderImpl#subscribe silent stuck when using pulsar-client:3.0.x with jackson-annotations prior to 2.12.0 (#21985)

  Show description for 63f0168
  Shawyeok

  authored
  63f0168

  Copy full SHA for 63f0168

• [improve] [proxy] Add a check for brokerServiceURL that does not support multi uri yet (#21972)

  Show description for 1952f94
  poorbarcode

  authored
  1952f94

  Copy full SHA for 1952f94

• [fix] [broker] add timeout for health check read. (#21990)

  thetumbled

  authored
  925bf2e

  Copy full SHA for 925bf2e

• [fix] [broker] Fix reader stuck when read from compacted topic with read compact mode disable (#21969)

  thetumbled

  authored
  09559c5

  Copy full SHA for 09559c5

• [improve][pip] PIP-329: Strategy for maintaining the latest tag to Pulsar docker images (#21872)

  RobertIndie

  authored
  9636613

  Copy full SHA for 9636613

• [fix][client] Fix multi-topics consumer could receive old messages after seek (#21945)

  BewareMyPower

  authored
  fce0717

  Copy full SHA for fce0717

Commits on Jan 31, 2024

• [improve] [test] Remove redudant test code (#21999)

  thetumbled

  authored
  a702e5a

  Copy full SHA for a702e5a

• [fix][fn] Use unified PackageManagement service to download packages (#21955)

  jiangpengcheng

  authored
  d3b7ca5

  Copy full SHA for d3b7ca5

• [improve][broker] Include runtime dependencies in server distribution (#22001)

  dragosvictor

  authored
  57025bc

  Copy full SHA for 57025bc

Commits on Feb 2, 2024

• [improve][broker] Do not close the socket if lookup failed due to LockBusyException (#21993)

  BewareMyPower

  authored
  e7c2a75

  Copy full SHA for e7c2a75

Commits on Feb 4, 2024

• [fix] [test] Fix flaky test testPerTopicExpiredStat (#22018)

  315157973

  authored
  5dfdcb7

  Copy full SHA for 5dfdcb7

Commits on Feb 5, 2024

• [improve][client] Mention partitioning in failover priorityLevel javaDoc (#21980)

  Show description for 9c7716c
  

  mwhipple

  and

  merlimat

  authored
  9c7716c

  Copy full SHA for 9c7716c

Commits on Feb 6, 2024

• [improve][broker] Do not retain the data in the system topic (#22022)

  Show description for 5df97b4
  liangyepianzhou

  authored
  5df97b4

  Copy full SHA for 5df97b4

• [cleanup] [broker] fix return value of TransactionTimeoutTrackerImpl#addTransaction (#22020)

  Show description for 0dabc97
  thetumbled

  authored
  0dabc97

  Copy full SHA for 0dabc97

Commits on Feb 7, 2024

• [improve] Added CodeQL static scanner (#22037)

  merlimat

  authored
  a77fb6e

  Copy full SHA for a77fb6e

• [feat] PIP-335: Oxia metadata plugin (#22009)

  Show description for 1c5b4b8
  

  merlimat

  and

  zbentley

  authored
  1c5b4b8

  Copy full SHA for 1c5b4b8

• [feat] PIP-335: Add support Oxia as a metadata store (#22007)

  merlimat

  authored
  a83e9ed

  Copy full SHA for a83e9ed

Commits on Feb 9, 2024

• [fix][broker] Sanitize values before logging in apply-config-from-env.py script (#22044)

  lhotari

  authored
  3036783

  Copy full SHA for 3036783

• [improve] PIP-335: Pulsar with Oxia integration test (#22045)

  merlimat

  authored
  2b75ca0

  Copy full SHA for 2b75ca0

• [feat][misc] PIP-320: Add OpenTelemetry scaffolding (#22010)

  Show description for 8957e35
  

  dragosvictor

  and

  merlimat

  authored
  8957e35

  Copy full SHA for 8957e35

Commits on Feb 10, 2024

• [fix] Bump org.apache.solr:solr-core from 8.11.1 to 8.11.3 in /pulsar-io/solr (#22047)

  Show description for 7a90426
  dependabot[bot]

  authored
  7a90426

  Copy full SHA for 7a90426

Commits on Feb 13, 2024

• [feat][io] AzureDataExplorer/Kusto Sink for Pulsar (#22006)

  Show description for beed0cf
  

  asaharn

  and

  ag-ramachandran

  authored
  beed0cf

  Copy full SHA for beed0cf

Commits on Feb 15, 2024

• [fix][broker] Fix hash collision when using a consumer name that ends with a number (#22053)

  lhotari

  authored
  7e73967

  Copy full SHA for 7e73967

• [fix] Fixed implicit conversions from long -> int (#22055)

  merlimat

  authored
  fc2e314

  Copy full SHA for fc2e314

Commits on Feb 18, 2024

• [improve][broker] Add an error log to troubleshoot the failure of starting broker registry. (#22065)

  liangyepianzhou

  authored
  baddda5

  Copy full SHA for baddda5

• [improve] [broker] Do not print an Error log when responding to HTTP-404 when calling Admin API and the topic does not exist. (#21995)

  poorbarcode

  authored
  48b4481

  Copy full SHA for 48b4481

• [fix][broker]Support setting autoSkipNonRecoverableData dynamically in expiryMon… (#21991)

  Show description for 220a3d6
  chenhongSZ

  authored
  220a3d6

  Copy full SHA for 220a3d6

• [fix] [broker] Subscription stuck due to called Admin API analyzeSubscriptionBacklog (#22019)

  poorbarcode

  authored
  825e997

  Copy full SHA for 825e997

Commits on Feb 19, 2024

• [fix] [broker] Fix can not subscribe partitioned topic with a suffix-matched regexp (#22025)

  poorbarcode

  authored
  b375e86

  Copy full SHA for b375e86

• [fix][test] Fix Thread.getThreadGroup().getName() NPE (#22070)

  Technoboy-

  authored
  0b6bd70

  Copy full SHA for 0b6bd70

Commits on Feb 21, 2024

• [fix][broker] Support running docker container with gid != 0 (#22081)

  lhotari

  authored
  4097ddd

  Copy full SHA for 4097ddd

• [fix][sec] Upgrade commons-compress to 1.26.0 (#22086)

  massakam

  authored
  613a771

  Copy full SHA for 613a771

Commits on Feb 22, 2024

• [fix] [txn] Get previous position by managed ledger. (#22024)

  thetumbled

  authored
  1f72817

  Copy full SHA for 1f72817

• [fix] [broker] Expire messages according to ledger close time to avoid client clock skew (#21940)

  315157973

  authored
  861618a

  Copy full SHA for 861618a

• [improve][ci] Upgrade Gradle Enterprise maven extension version (#22096)

  lhotari

  authored
  08058b9

  Copy full SHA for 08058b9

• [fix][build] Fix building java-test-image without setting IMAGE_JDK_MAJOR_VERSION (#22095)

  lhotari

  authored
  48c85ab

  Copy full SHA for 48c85ab

• [fix][broker] Set ServiceUnitStateChannel topic compaction threshold explicitly, improve getOwnerAsync, and fix other bugs (#22064)

  heesung-sn

  authored
  5a614e9

  Copy full SHA for 5a614e9

Commits on Feb 23, 2024

• [improve][admin] Expose the offload threshold in seconds to the amdin (#22101)

  zymap

  authored
  48c7e32

  Copy full SHA for 48c7e32

• [improve] [broker] Do not try to open ML when the topic meta does not exist and do not expect to create a new one. #21995 (#22004)

  Show description for 1c652f5
  

  poorbarcode

  and

  Technoboy-

  authored
  1c652f5

  Copy full SHA for 1c652f5

Commits on Feb 24, 2024

• [improve][broker] Cache the internal writer when sent to system topic. (#22099)

  Technoboy-

  authored
  8607905

  Copy full SHA for 8607905

Commits on Feb 25, 2024

• [fix][fn] Prevent create state table from API calls for non-exists instances (#22107)

  freeznet

  authored
  5c44e1b

  Copy full SHA for 5c44e1b

Commits on Feb 26, 2024

• [fix] [broker] Enabling batch causes negative unackedMessages due to ack and delivery concurrency (#22090)

  poorbarcode

  authored
  1b1cfb5

  Copy full SHA for 1b1cfb5

• [improve][fn] Optimize Function Worker startup by lazy loading and direct zip/bytecode access (#22122)

  lhotari

  authored
  bbc6224

  Copy full SHA for bbc6224

• [fix] [client] fix huge permits if acked a half batched message (#22091)

  poorbarcode

  authored
  0c49cac

  Copy full SHA for 0c49cac

• [fix][sec] Add a check for the input time value (#22023)

  liangyepianzhou

  authored
  31ed115

  Copy full SHA for 31ed115

• [fix][test] Fix test testTransactionBufferMetrics (#22117)

  liangyepianzhou

  authored
  0fc9f44

  Copy full SHA for 0fc9f44

• [improve][ci] Upgrade codecov-action version (#22123)

  lhotari

  authored
  ae050a1

  Copy full SHA for ae050a1

Commits on Feb 27, 2024

• [bug][fn] Prevent putstate uses empty values (#22127)

  freeznet

  authored
  430f4ff

  Copy full SHA for 430f4ff

• [fix][test] fix test testSyncNormalPositionWhenTBRecover (#22120)

  Show description for 3013496
  liangyepianzhou

  authored
  3013496

  Copy full SHA for 3013496

• [fix][test] Fix test testAsyncFunctionMaxPending (#22121)

  liangyepianzhou

  authored
  91de98a

  Copy full SHA for 91de98a