Commits

Branch selector

 master

User selector

MarvinCai

Datepicker

All time

Commit History

Commits on Feb 15, 2021

• [Admin CLI] Inform user when expire message request is not executed. (apache#9561)

  Show description for b4dfeee
  MarvinCai

  authored
  b4dfeee

  Copy full SHA for b4dfeee

Commits on Feb 10, 2021

• Expire message by position. (apache#9514)

  Show description for 301d42c
  MarvinCai

  authored
  301d42c

  Copy full SHA for 301d42c

Commits on Feb 9, 2021

• [Doc] Update pulsar-client cli doc with newer options. (apache#9524)

  Show description for 0f6e77e
  MarvinCai

  authored
  0f6e77e

  Copy full SHA for 0f6e77e

Commits on Feb 8, 2021

• Add subscription backlog size info for topicstats. (apache#9302)

  Show description for ab94743
  MarvinCai

  authored
  ab94743

  Copy full SHA for ab94743

Commits on Feb 6, 2021

• Try to fix flaky LeaderElection test. (apache#9443)

  Show description for a958ee9
  MarvinCai

  authored
  a958ee9

  Copy full SHA for a958ee9

Commits on Feb 2, 2021

• Add streaming dispatcher. (apache#9056)

  Show description for 8cfaf48
  MarvinCai

  authored
  8cfaf48

  Copy full SHA for 8cfaf48

• Avoid enable DLQ on Key_Shared subscription. (apache#9163)

  Show description for 9af8577
  MarvinCai

  authored
  9af8577

  Copy full SHA for 9af8577

Commits on Jan 18, 2021

• Fix locking for ConsumerImpl when creating deadLetterProducer. (apache#9166)

  Show description for b019c4b
  MarvinCai

  authored
  b019c4b

  Copy full SHA for b019c4b

Commits on Dec 14, 2020

• Support deliverAt and deliverAfter attribute for Websocket producer. (apache#8945)

  Show description for 7be1b8d
  MarvinCai

  authored
  7be1b8d

  Copy full SHA for 7be1b8d

Commits on Nov 17, 2020

• Add key-shared consumer range to internal topic stats. (apache#8567)

  Show description for 8d7dd11
  MarvinCai

  authored
  8d7dd11

  Copy full SHA for 8d7dd11

Commits on Nov 11, 2020

• [AdminCli] Add ability to examine specific message by position relative to earliest or latest message. (apache#8494)

  Show description for fdcf613
  MarvinCai

  authored
  fdcf613

  Copy full SHA for fdcf613

Commits on Oct 30, 2020

• [Websocket]Update produce request and acknowledge for WebSocket. (apache#8401)

  Show description for 7979b9c
  MarvinCai

  authored
  7979b9c

  Copy full SHA for 7979b9c

Commits on Sep 9, 2020

• Add config to lazily recover cursors when recovering a managed ledger. (apache#7858)

  Show description for 22b8923
  MarvinCai

  authored
  22b8923

  Copy full SHA for 22b8923

Commits on Sep 8, 2020

• Report compacted topic ledger info when calling get internal stats. (apache#7988)

  Show description for 97ba09e
  MarvinCai

  authored
  97ba09e

  Copy full SHA for 97ba09e

Commits on Sep 2, 2020

• [Issue 7864][docs]Update document for how to pick active consumer for failover subscription. (apache#7917)

  Show description for 6a2b574
  MarvinCai

  authored
  6a2b574

  Copy full SHA for 6a2b574

Commits on Aug 21, 2020

• Return more informative error message when trying to create subscription on non-persistent throug Rest API or pulsar-admin CLI. (apache#7831)

  Show description for 7b60e2d
  MarvinCai

  authored
  7b60e2d

  Copy full SHA for 7b60e2d

Commits on Aug 6, 2020

• Support set message TTL on topic level. (apache#7738)

  Show description for 8a763ab
  MarvinCai

  authored
  8a763ab

  Copy full SHA for 8a763ab

Commits on Nov 6, 2019

• Validate topic name before creating partition/non partition topic via admin cli. (apache#5148)

  Show description for e0ea6b5
  

  MarvinCai

  authored and

  jiazhai

  committed
  e0ea6b5

  Copy full SHA for e0ea6b5

Commits on Jun 27, 2019

• Update logic for picking active consumer for failover subscription on non-partitioned topic. (apache#4604)

  Show description for 22f1d7d
  

  MarvinCai

  authored and

  merlimat

  committed
  22f1d7d

  Copy full SHA for 22f1d7d

Commits on Jun 17, 2019

• [transaction][acknowledge] Introduce in-memory PENDING_ACK state in acknowledgement path (apache#4265)

  Show description for e66ba27
  

  MarvinCai

  authored and

  sijie

  committed
  e66ba27

  Copy full SHA for e66ba27

Commits on Jun 11, 2019

• Update readme for setting up protobuf 2.6.0 on mac. (apache#4492)

  Show description for acbf0c8
  

  MarvinCai

  authored and

  merlimat

  committed
  acbf0c8

  Copy full SHA for acbf0c8

Commits on Mar 28, 2019

• Support Kafka's ConsumerConfig.INTERCEPTOR_CLASSES_CONFIG in PulsarKafkaConsumer. (apache#3911)

  Show description for 0487804
  

  MarvinCai

  authored and

  merlimat

  committed
  0487804

  Copy full SHA for 0487804

Commits on Mar 26, 2019

• Support Kafka's ConsumerConfig.MAX_POLL_RECORDS_CONFIG to config max number of message will return in a single poll. (apache#3887)

  Show description for b42c1e5
  

  MarvinCai

  authored and

  merlimat

  committed
  b42c1e5

  Copy full SHA for b42c1e5

Commits on Mar 20, 2019

• Add a wrapper around Kafka's ProducerInterceptor to support Kafka's ProducerConfig.INTERCEPTOR_CLASSES_CONFIG. apache#1090 (apache#3843)

  Show description for e77a165
  

  MarvinCai

  authored and

  sijie

  committed
  e77a165

  Copy full SHA for e77a165

Commits on Mar 11, 2019

• Support Kafka's ProducerConfig.REQUEST_TIMEOUT_MS_CONFIG. (apache#3797)

  Show description for 117321d
  

  MarvinCai

  authored and

  sijie

  committed
  117321d

  Copy full SHA for 117321d

Commits on Mar 9, 2019

• Add support for Kafka's ProducerConfig.CONNECTIONS_MAX_IDLE_MS_CONFIG (apache#1090) (apache#3753)

  Show description for 18e3ab1
  

  MarvinCai

  authored and

  sijie

  committed
  18e3ab1

  Copy full SHA for 18e3ab1

Commits on Jan 28, 2019

• Update command usage for pulsar-perf cli command (apache#2895) (apache#3452)

  

  MarvinCai

  authored and

  merlimat

  committed
  39e0f32

  Copy full SHA for 39e0f32