Commits

Breadcrumbs

History for

on9dbc8dd

User selector

All users

Datepicker

All time

Commit History

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

  Copy full SHA for 8c59fd3

Commits on Apr 26, 2019

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

  Show description for 4b378a2
  

  codelipenghui

  authored and

  sijie

  committed
  4b378a2

  Copy full SHA for 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

  Copy full SHA for 8adff85

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

  Show description for 4101168
  

  casidiablo

  authored and

  sijie

  committed
  4101168

  Copy full SHA for 4101168

Commits on Apr 1, 2019

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

  

  shiv4289

  authored and

  merlimat

  committed
  daa0a18

  Copy full SHA for 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

  Copy full SHA for 19fd91c

Commits on Mar 7, 2019

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

  Show description for 1da2161
  merlimat

  authored
  1da2161

  Copy full SHA for 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

  Copy full SHA for 1f376e1

Commits on Feb 25, 2019

• Replace Junit with testng (apache#3675)

  Show description for fe7311c
  

  Like

  authored and

  sijie

  committed
  fe7311c

  Copy full SHA for fe7311c

Commits on Feb 15, 2019

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

  merlimat

  authored
  53ba1a4

  Copy full SHA for 53ba1a4

Commits on Jan 5, 2019

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

  Show description for 4a85bb7
  merlimat

  authored
  4a85bb7

  Copy full SHA for 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

  Copy full SHA for ab39aeb

Commits on Dec 28, 2018

• [Pulsar-Flink] Refactor Flink Batch Sink Examples (apache#3262)

  Show description for 140d375
  

  erenavsarogullari

  authored and

  sijie

  committed
  140d375

  Copy full SHA for 140d375

• Support multi-topic and pattern-topic for PulsarConsumerSource in pulsar (apache#3256)

  Show description for a010166
  

  codelipenghui

  authored and

  sijie

  committed
  a010166

  Copy full SHA for a010166

Commits on Dec 24, 2018

• [pulsar-flink] add streaming connectors as a Pulsar stream that serializes data in Avro format (apache#3231)

  Show description for 7a1a148
  

  ambition119

  authored and

  sijie

  committed
  7a1a148

  Copy full SHA for 7a1a148

Commits on Dec 21, 2018

• [issues 3232] integrate flink-json to pulsar (apache#3234)

  Show description for d9691b7
  

  ambition119

  authored and

  merlimat

  committed
  d9691b7

  Copy full SHA for d9691b7

Commits on Dec 19, 2018

• Provide a flag to ignore Json format error in pulsar flink connector (apache#3210)

  Show description for 00ae3cf
  

  CrestOfWave

  authored and

  sijie

  committed
  00ae3cf

  Copy full SHA for 00ae3cf

• fix up pulsar-flink and flink-consumer-source (apache#3212)

  Show description for 8da04cb
  

  ambition119

  authored and

  sijie

  committed
  8da04cb

  Copy full SHA for 8da04cb

Commits on Dec 18, 2018

• [pulsar-flink] Implements a batch program on Pulsar topic by writing Flink DataSet as Avro (apache#3205)

  Show description for 5493e2f
  

  ambition119

  authored and

  sijie

  committed
  5493e2f

  Copy full SHA for 5493e2f

Commits on Dec 15, 2018

• [Pulsar-Flink] Add Batch Sink Scala Examples Documentation (apache#3190)

  Show description for a3fbd2e
  

  erenavsarogullari

  authored and

  sijie

  committed
  a3fbd2e

  Copy full SHA for a3fbd2e

Commits on Dec 4, 2018

• JSONSchema fails to serialise fields on objects that are nested in a collection (apache#2969)

  Show description for dedeb33
  

  chrismiller

  authored and

  jerrypeng

  committed
  dedeb33

  Copy full SHA for dedeb33

Commits on Nov 28, 2018

• [Pulsar-Flink] Add Scala Examples (apache#3071)

  Show description for b413c19
  

  erenavsarogullari

  authored and

  merlimat

  committed
  b413c19

  Copy full SHA for b413c19

Commits on Nov 27, 2018

• [Pulsar-Flink] Extends Validations (apache#3063)

  Show description for 5438659
  

  erenavsarogullari

  authored and

  sijie

  committed
  5438659

  Copy full SHA for 5438659

Commits on Nov 25, 2018

• [Pulsar-Flink] Add Batch Json Sink Support (apache#3046)

  Show description for fe2c8ee
  

  erenavsarogullari

  authored and

  sijie

  committed
  fe2c8ee

  Copy full SHA for fe2c8ee

Commits on Nov 22, 2018

• [Pulsar-Flink] Add Batch Csv Sink Support (apache#3039)

  Show description for 182ac65
  

  erenavsarogullari

  authored and

  sijie

  committed
  182ac65

  Copy full SHA for 182ac65

Commits on Nov 16, 2018

• Add Flink - Pulsar Batch Sink Support (apache#2979)

  Show description for aefbaac
  

  erenavsarogullari

  authored and

  sijie

  committed
  aefbaac

  Copy full SHA for aefbaac

Commits on Nov 10, 2018

• Added pause and resume to Java client Consumer (apache#2961)

  Show description for c1c699f
  

  davidtinker

  authored and

  merlimat

  committed
  c1c699f

  Copy full SHA for c1c699f

Commits on Oct 31, 2018

• Issue apache#2890: Dependencies for using Pulsar in Storm topologies (apache#2893)

  Show description for e72ed35
  

  sijie

  authored and

  merlimat

  committed
  e72ed35

  Copy full SHA for e72ed35

Commits on Oct 11, 2018

• Bumped version to 2.3.0-SNAPSHOT (apache#2765)

  

  joefk

  authored and

  merlimat

  committed
  6b15a6b

  Copy full SHA for 6b15a6b

Commits on Sep 30, 2018

• Allow user to get topic from consumer message (apache#2007) (apache#2135)

  Show description for f8256e6
  

  ivankelly

  authored and

  sijie

  committed
  f8256e6

  Copy full SHA for f8256e6

Commits on Sep 25, 2018

• Removed mentions to incubator-pulsar (apache#2620)

  Show description for 96c10dc
  merlimat

  authored
  96c10dc

  Copy full SHA for 96c10dc

Commits on Sep 20, 2018

• Renamed 2.2.0-incubating-SNAPSHOT into 2.2.0-SNAPSHOT in poms (apache#2625)

  merlimat

  authored
  71b5339

  Copy full SHA for 71b5339

Commits on Sep 12, 2018

• [documentation][example] Flink Source & Sink Connector (apache#2561)

  Show description for 71003e2
  sijie

  authored
  71003e2

  Copy full SHA for 71003e2

Commits on Sep 11, 2018

• [ecosystem] Flink pulsar source connector (apache#2555)

  Show description for fc61056
  sijie

  authored
  fc61056

  Copy full SHA for fc61056

Commits on Sep 4, 2018

• Add pulsar flink sink connector (apache#2434)

  Show description for ad03a07
  

  aahmed-se

  authored and

  sijie

  committed
  ad03a07

  Copy full SHA for ad03a07

Loading