Commits

Breadcrumbs

History for

oncd8e22e

User selector

All users

Datepicker

All time

Commit History

Commits on Aug 17, 2020

• Support acknowledging a list of messages (apache#7688)

  Show description for e06e872
  315157973

  authored
  e06e872

Commits on Jun 11, 2020

• Bumped version to 2.7.0-SNAPSHOT (apache#7233)

  Show description for 81168f3
  codelipenghui

  authored
  81168f3

Commits on Jun 9, 2020

• Fix apache rat check (apache#7225)

  codelipenghui

  authored
  5d78a2d

Commits on May 19, 2020

• [Issue 4803][client] return null if the message value/data is not set by producer (apache#6379)

  Show description for d55bc00
  nlu90

  authored
  d55bc00

• [pulsar-storm] Fix: Authentication is failing with storm adapter (apache#6782)

  Show description for 1d5c418
  rdhabalia

  authored
  1d5c418

Commits on Apr 25, 2020

• Make messageReceiveTimeoutMs in the PulsarConsumerSource configurable (apache#6783)

  Show description for 47b4dd0
  zplinuxlover

  authored
  47b4dd0

Commits on Apr 9, 2020

• Update the status of pulsar-flink connector (apache#6657)

  sijie

  authored
  e2c97c0

Commits on Apr 6, 2020

• Support Consumers Set Custom Retry Delay (apache#6449)

  Show description for 30e762e
  liudezhi2098

  authored
  30e762e

Commits on Mar 26, 2020

• ISSUE-5934: Support read/write properties from/to Message in flink pulsar consumer/producer (apache#5955)

  Show description for 5ad3e02
  

  4 peopleauthored
  5ad3e02

Commits on Mar 1, 2020

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

  yjshen

  authored
  2ed2eb8

Commits on Jan 24, 2020

• Simplify templating in log messages (apache#6133)

  

  vzhikserg

  authored and

  merlimat

  committed
  abb7a50

Commits on Jan 6, 2020

• Upgrade Avro to 1.9.1 (apache#5938)

  Show description for d6f240e
  

  Masahiro Sakamoto

  authored and

  sijie

  committed
  d6f240e

Commits on Jan 3, 2020

• [pulsar-flink]Cache Pulsar client to make it shared among tasks in a process (apache#5900)

  Show description for 5c58ff4
  

  2 peopleauthored and

  wolfstudy

  committed
  5c58ff4

Commits on Dec 9, 2019

• Bump version to 2.6.0 (apache#5820)

  Show description for 702790a
  sijie

  authored
  702790a

Commits on Nov 19, 2019

• [PIP-38] Support batch receive in java client. (apache#4621)

  Show description for 56517d5
  

  codelipenghui

  authored and

  jiazhai

  committed
  56517d5

Commits on Aug 18, 2019

• expose getLastMessageId method in ConsumerImpl (apache#4911)

  Show description for 93d95c7
  

  jiazhai

  authored and

  sijie

  committed
  93d95c7

Commits on Jul 29, 2019

• Perform Checkstyle analysis in the pulsar-flink module (apache#4832)

  Show description for b0793a1
  

  vzhikserg

  authored and

  sijie

  committed
  b0793a1

Commits on Jul 25, 2019

• Test cleanup and simplification (apache#4799)

  Show description for fb6895d
  

  vzhikserg

  authored and

  merlimat

  committed
  fb6895d

Commits on Jul 10, 2019

• Upgrade to Mockito 2.x (apache#4671)

  Show description for 108780c
  

  merlimat

  authored and

  jiazhai

  committed
  108780c

Commits on Jun 25, 2019

• Bumped version to 2.5.0-SNAPSHOT (apache#4581)

  

  codelipenghui

  authored and

  sijie

  committed
  5fa6c36

Commits on Jun 6, 2019

• [Issue 4379] [Java Client] Build auth from class and params in PulsarClientImpl (apache#4381)

  Show description for 17d2b42
  

  shiv4289

  authored and

  merlimat

  committed
  17d2b42

Commits on May 29, 2019

• Add missed serialization schema argument for PulsarOutputFormat constructor (apache#4373)

  Show description for 4d1b2ff
  

  liketic

  authored and

  sijie

  committed
  4d1b2ff

Commits on May 18, 2019

• [Issue 4283][flink] construct auth when building pulsar source (apache#4284)

  Show description for 353ca73
  

  shiv4289

  authored and

  sijie

  committed
  353ca73

Commits on May 9, 2019

• [issue 3954] [flink] Use (client/consumer/producer) pojo to pass config to pulsar client (apache#4232)

  Show description for 8c59fd3
  

  shiv4289

  authored and

  jiazhai

  committed
  8c59fd3

Commits on Apr 26, 2019

• [pulsar-flink] Add subscription initial position (apache#4129)

  Show description for 4b378a2
  

  codelipenghui

  authored and

  sijie

  committed
  4b378a2

Commits on Apr 2, 2019

• issue#3939 : Allow client authentication from pulsar-flink package (apache#3949)

  Show description for 8adff85
  

  shiv4289

  authored and

  merlimat

  committed
  8adff85

• [Flink] Allow to customize PulsarProducer (apache#3955)

  Show description for 4101168
  

  casidiablo

  authored and

  sijie

  committed
  4101168

Commits on Apr 1, 2019

• Throw error explicitly on param value not in range (apache#3950)

  

  shiv4289

  authored and

  merlimat

  committed
  daa0a18

Commits on Mar 25, 2019

• [flink] Allow to specify a custom Pulsar producer (apache#3894)

  Show description for 19fd91c
  

  casidiablo

  authored and

  sijie

  committed
  19fd91c

Commits on Mar 7, 2019

• Added support for "negative acks" in Java client (apache#3703)

  Show description for 1da2161
  merlimat

  authored
  1da2161

Commits on Feb 28, 2019

• add reset cousor to a specific publish time (apache#3622)

  Show description for 1f376e1
  

  wolfstudy

  authored and

  jiazhai

  committed
  1f376e1

Commits on Feb 25, 2019

• Replace Junit with testng (apache#3675)

  Show description for fe7311c
  

  Like

  authored and

  sijie

  committed
  fe7311c

Commits on Feb 15, 2019

• Bumped version to 2.4.0-SNAPSHOT (apache#3604)

  merlimat

  authored
  53ba1a4

Commits on Jan 5, 2019

• After apache#3228, removed usages of deprecated client API (apache#3272)

  Show description for 4a85bb7
  merlimat

  authored
  4a85bb7

Commits on Dec 31, 2018

• [flink-consumer-source] fix flink streaming connector examples to be consistent with batch examples (apache#3265)

  Show description for ab39aeb
  

  ambition119

  authored and

  sijie

  committed
  ab39aeb

Pagination

PreviousNext