Code

Merge form pulsar master#3

Code

Merged

kaynewu merged 74 commits intokaynewu:masterkaynewu/pulsar:masterfrom apache:masterapache/pulsar:masterCopy head branch name to clipboardMar 10, 2020

+5,476-2,642

Commits

Commits on Feb 16, 2020

• [Issue 5904]Support unload all partitions of a partitioned topic (#6187)

  Show description for d35e6c1
  ltamber

  authored
  d35e6c1

  Copy full SHA for d35e6c1

• [Issue 4175] [pulsar-function-go] Create integration tests for Go Functions for production-readiness (#6104)

  Show description for bf7302a
  devinbost

  authored
  bf7302a

  Copy full SHA for bf7302a

• [Issue 5999] Support create/update tenant with empty cluster (#6027)

  Show description for e9083f5
  murong00

  authored
  e9083f5

  Copy full SHA for e9083f5

• Introduce maxMessagePublishBufferSizeInMB configuration to avoid broker OOM (#6178)

  Show description for 91dfa1a
  codelipenghui

  authored
  91dfa1a

  Copy full SHA for 91dfa1a

• Enable get precise backlog and backlog without delayed messages. (#6310)

  Show description for df15210
  codelipenghui

  authored
  df15210

  Copy full SHA for df15210

Commits on Feb 17, 2020

• KeyValue schema support for pulsar sql (#6325)

  Show description for 3cf6be1
  gaoran10

  authored
  3cf6be1

  Copy full SHA for 3cf6be1

• Avoid get partition metadata while the topic name is a partition name. (#6339)

  Show description for 26d569b
  codelipenghui

  authored
  26d569b

  Copy full SHA for 26d569b

• explicit statement env 'BOOKIE_MEM' and 'BOOKIE_GC' for values-mini.yaml (#6340)

  Show description for 7d4df99
  liyuntao

  authored
  7d4df99

  Copy full SHA for 7d4df99

• Fix java doc for key shared policy. (#6341)

  Show description for 77971e4
  codelipenghui

  authored
  77971e4

  Copy full SHA for 77971e4

Commits on Feb 18, 2020

• client: make SubscriptionMode a member of ConsumerConfigurationData (#6337)

  Show description for 208af7c
  jiazhai

  authored
  208af7c

  Copy full SHA for 208af7c

• Windows CMake corrections (#6336)

  Show description for 9b9e79e
  heronr

  authored
  9b9e79e

  Copy full SHA for 9b9e79e

Commits on Feb 19, 2020

• remove future.join() from PulsarSinkEffectivelyOnceProcessor (#6361)

  nlu90

  authored
  943c903

  Copy full SHA for 943c903

Commits on Feb 21, 2020

• use checkout@v2 to avoid fatal: reference is not a tree (#6386)

  Show description for 5177bfd
  yjshen

  authored
  5177bfd

  Copy full SHA for 5177bfd

• [Pulsar-Client] Stop shade snappy-java in pulsar-client-shaded (#6375)

  Show description for 3197dcd
  yjshen

  authored
  3197dcd

  Copy full SHA for 3197dcd

Commits on Feb 22, 2020

• Fix CI not triggered (#6397)

  Show description for bb5d6fd
  yjshen

  authored
  bb5d6fd

  Copy full SHA for bb5d6fd

• [Issue 6355][HELM] autorecovery - could not find or load main class (#6373)

  Show description for af4773b
  jharris-

  authored
  af4773b

  Copy full SHA for af4773b

Commits on Feb 23, 2020

• Creating a topic does not wait for creating cursor of replicators (#6364)

  Show description for 336e971
  codelipenghui

  authored
  336e971

  Copy full SHA for 336e971

Commits on Feb 24, 2020

• [Reader] Should set either start message id or start message from roll back duration. (#6392)

  Show description for f862961
  yjshen

  authored
  f862961

  Copy full SHA for f862961

• Seek to the first one >= timestamp (#6393)

  Show description for 81f8afd
  yjshen

  authored
  81f8afd

  Copy full SHA for 81f8afd

• [Minor] Fix java code errors reported by lgtm. (#6398)

  Show description for 7fb9aff
  yjshen

  authored
  7fb9aff

  Copy full SHA for 7fb9aff

• [Java Reader Client] Start reader inside batch result in read first message in batch. (#6345)

  Show description for 63ccd43
  yjshen

  authored
  63ccd43

  Copy full SHA for 63ccd43

• Fix broker to specify a list of bookie groups. (#6349)

  Show description for e1f7505
  murong00

  authored
  e1f7505

  Copy full SHA for e1f7505

• Fixed enum package not found (#6401)

  Show description for 2f42077
  tuteng

  authored
  2f42077

  Copy full SHA for 2f42077

• removed comma from yaml config (#6402)

  

  newur

  authored
  739c0dd

  Copy full SHA for 739c0dd

• Fix broker client tls settings error (#6128)

  Show description for 1fcccd6
  jiazhai

  authored
  1fcccd6

  Copy full SHA for 1fcccd6

Commits on Feb 25, 2020

• [Issue 3762][Schema] Fix the problem with parsing of an Avro schema related to shading in pulsar-client. (#6406)

  Show description for dab14ac
  vzhikserg

  authored
  dab14ac

  Copy full SHA for dab14ac

• Remove duplicated lombok annotations in the tests module (#6412)

  vzhikserg

  authored
  49c573c

  Copy full SHA for 49c573c

• Add verification for SchemaDefinitionBuilderImpl.java (#6405)

  Show description for 848ad30
  codelipenghui

  authored
  848ad30

  Copy full SHA for 848ad30

Commits on Feb 26, 2020

• Cleanup pom files in the tests module (#6421)

  Show description for fa46693
  vzhikserg

  authored
  fa46693

  Copy full SHA for fa46693

• Update BatchReceivePolicy.java (#6423)

  Show description for 792ab17
  codelipenghui

  authored
  792ab17

  Copy full SHA for 792ab17

• Consumer received duplicated deplayed messages upon restart

  Show description for e71b9fc
  liudezhi2098

  authored
  e71b9fc

  Copy full SHA for e71b9fc

Commits on Feb 27, 2020

• Bump netty version to 4.1.45.Final (#6424)

  Show description for 760bd1a
  dzmitryk

  authored
  760bd1a

  Copy full SHA for 760bd1a

• Fix publish buffer limit does not take effect

  Show description for 75a321d
  ltamber

  authored
  75a321d

  Copy full SHA for 75a321d

Commits on Feb 28, 2020

• doc: Add on the missing right parenthesis (#6426)

  Show description for f98e092
  futeng

  authored
  f98e092

  Copy full SHA for f98e092

• Switch from deprecated MAINTAINER tag to LABEL with maintainer's info in Dockerfile (#6429)

  Show description for b2899ed
  vzhikserg

  authored
  b2899ed

  Copy full SHA for b2899ed

• Amend the default value of . (#6374)

  murong00

  authored
  39cf6c0

  Copy full SHA for 39cf6c0

Commits on Feb 29, 2020

• fix the bug of authenticationData is't initialized. (#6440)

  Show description for b8f0ca0
  bilahepan

  authored
  b8f0ca0

  Copy full SHA for b8f0ca0

• Remove duplicated test libraries in POM dependencies (#6430)

  Show description for 7f25add
  vzhikserg

  authored
  7f25add

  Copy full SHA for 7f25add

• Add a message on how to make log refresh immediately when starting a component (#6078)

  Show description for 4f461c3
  murong00

  authored
  4f461c3

  Copy full SHA for 4f461c3

• Close ZK before canceling future with exception (#6228) (#6399)

  Show description for e6a631d
  pawellozinski

  authored
  e6a631d

  Copy full SHA for e6a631d

Commits on Mar 1, 2020

• [Flink-Connector]Get PulsarClient from cache should always return an open instance (#6436)

  yjshen

  authored
  2ed2eb8

  Copy full SHA for 2ed2eb8

Commits on Mar 2, 2020

• Update sidebars.json (#6434)

  Show description for c3672a2
  slominskir

  authored
  c3672a2

  Copy full SHA for c3672a2

• [Broker] Create namespace failed when TLS is enabled in PulsarStandalone (#6457)

  Show description for 3e1b8f6
  yjshen

  authored
  3e1b8f6

  Copy full SHA for 3e1b8f6

• Update version-2.5.0-sidebars.json (#6455)

  Show description for 330e782
  slominskir

  authored
  330e782

  Copy full SHA for 330e782

• [Issue 6168] Fix Unacked Message Tracker by Using Time Partition on C++ (#6391)

  Show description for 333888a
  k2la

  authored
  333888a

  Copy full SHA for 333888a

Commits on Mar 3, 2020

• [ClientAPI]Fix hasMessageAvailable() (#6362)

  Show description for baf155f
  yjshen

  authored
  baf155f

  Copy full SHA for baf155f

• Use System.nanoTime() instead of System.currentTimeMillis() (#6454)

  Show description for 459ec6e
  racorn

  authored
  459ec6e

  Copy full SHA for 459ec6e

• Fixed the max backoff configuration for lookups (#6444)

  Show description for 6ff87ee
  merlimat

  authored
  6ff87ee

  Copy full SHA for 6ff87ee

Commits on Mar 4, 2020

• upgrade scala-maven-plugin to 4.1.0 (#6469)

  Show description for 4284e39
  sijie

  authored
  4284e39

  Copy full SHA for 4284e39

Commits on Mar 5, 2020

• [pulsar-proxy] fix logging for published messages (#6474)

  Show description for 65cc303
  sijie

  authored
  65cc303

  Copy full SHA for 65cc303

• [Issue 6394] Add configuration to disable auto creation of subscriptions (#6456)

  Show description for c3292a6
  sijie

  authored
  c3292a6

  Copy full SHA for c3292a6

• Make tests more stable by using JSONAssert equals (#6435)

  Show description for 17f71d3
  sijie

  authored
  17f71d3

  Copy full SHA for 17f71d3

• Avoid calling ConsumerImpl::redeliverMessages() when message list is empty (#6480)

  merlimat

  authored
  6604f54

  Copy full SHA for 6604f54

Commits on Mar 6, 2020

• [pulsar-client] fix deadlock on send failure (#6488)

  rdhabalia

  authored
  ad5415a

  Copy full SHA for ad5415a

• Enhance Authorization by adding TenantAdmin interface (#6487)

  Show description for f33567e
  

  srkukarni

  and

  Sanjeev Kulkarni

  authored
  f33567e

  Copy full SHA for f33567e

• Independent schema is set for each consumer generated by topic (#6356)

  Show description for 8003d08
  congbobo184

  authored
  8003d08

  Copy full SHA for 8003d08

• Fix memory leak when running topic compaction. (#6485)

  Show description for f2ec1b4
  racorn

  authored
  f2ec1b4

  Copy full SHA for f2ec1b4

• Fix create partitioned topic with a substring of an existing topic name. (#6478)

  Show description for 19ccfd5
  codelipenghui

  authored
  19ccfd5

  Copy full SHA for 19ccfd5

• Bump jcloud version to 2.2.0 and remove jcloud-shade module (#6494)

  Show description for a3e1efc
  yjshen

  authored
  a3e1efc

  Copy full SHA for a3e1efc

• Refactor tests in pulsar client tools test (#6472)

  Show description for 73e8beb
  vzhikserg

  authored
  73e8beb

  Copy full SHA for 73e8beb

• Fix Topic metrics documentation (#6495)

  Show description for ffe9a92
  ilyam8

  authored
  ffe9a92

  Copy full SHA for ffe9a92

• [pulsar-client] remove duplicate cnx method (#6490)

  Show description for f9ada10
  rdhabalia

  authored
  f9ada10

  Copy full SHA for f9ada10

• [proxy] Fix proxy routing to functions worker (#6486)

  Show description for 329e231
  addisonj

  authored
  329e231

  Copy full SHA for 329e231

• Fix some async method problems at PersistentTopicsBase. (#6483)

  codelipenghui

  authored
  47ca8e6

  Copy full SHA for 47ca8e6

Commits on Mar 8, 2020

• Instead of always using admin access for topic, use read/write/admin access for topic (#6504)

  Show description for 36ea153
  

  srkukarni

  and

  Sanjeev Kulkarni

  authored
  36ea153

  Copy full SHA for 36ea153

• [Minor]Remove unused property from pom (#6500)

  Show description for 2999000
  yjshen

  authored
  2999000

  Copy full SHA for 2999000

• [pulsar-common] Remove duplicate RestException references (#6475)

  Show description for 33b7383
  rdhabalia

  authored
  33b7383

  Copy full SHA for 33b7383

• pulsar-proxy: fix correct name for proxy thread executor name (#6460)

  Show description for 5c2c058
  rdhabalia

  authored
  5c2c058

  Copy full SHA for 5c2c058

• Add subscribe initial position for consumer cli. (#6442)

  Show description for 9fc5185
  murong00

  authored
  9fc5185

  Copy full SHA for 9fc5185

Commits on Mar 9, 2020

• [Cleanup] Log format does not match arguments (#6509)

  yjshen

  authored
  ff01b10

  Copy full SHA for ff01b10

• Start namespace service and schema registry service before start broker. (#6499)

  Show description for 5285c68
  codelipenghui

  authored
  5285c68

  Copy full SHA for 5285c68

• [pulsar-client-cpp] Fix Redelivery of Messages on UnackedMessageTracker When Ack Messages . (#6498)

  Show description for 67f8cf3
  k2la

  authored
  67f8cf3

  Copy full SHA for 67f8cf3

• [pulsar-proxy] fixing data-type of logging-level (#6476)

  Show description for de4c6a3
  rdhabalia

  authored
  de4c6a3

  Copy full SHA for de4c6a3

Commits on Mar 10, 2020

• [pulsar-broker] recover zk-badversion while updating cursor metadata (#5604)

  Show description for 2936e17
  rdhabalia

  authored
  2936e17

  Copy full SHA for 2936e17