Commits

Breadcrumbs

History for

on300f736

User selector

All users

Datepicker

All time

Commit History

Commits on Jul 13, 2018

• Added optional key in pulsar IO (apache#2116)

  Show description for ea6eae7
  merlimat

  authored
  ea6eae7

Commits on Jul 12, 2018

• add flatbuffer option to serialize kinesis-message in KinesisSink (apache#2108)

  Show description for 2a6d195
  rdhabalia

  authored
  2a6d195

Commits on Jul 7, 2018

• Load connectors from NAR archives (apache#2102)

  Show description for 2bf2568
  merlimat

  authored
  2bf2568

• Add context to source and sink (apache#2098)

  Show description for 423a9af
  jerrypeng

  authored
  423a9af

Commits on Jul 6, 2018

• Kinesis sink publish full json message (apache#2079)

  Show description for da8981c
  rdhabalia

  authored
  da8981c

Commits on Jul 3, 2018

• Pass encryption-context to pulsar-sink if source receive encrypted message (apache#2068)

  Show description for 5e4579d
  rdhabalia

  authored
  5e4579d

Commits on Jul 2, 2018

• Package Pulsar IO connectors into separate tgz in form of nar archives (apache#2054)

  Show description for b22e883
  

  merlimat

  authored and

  sijie

  committed
  b22e883

Commits on Jul 1, 2018

• Pulsar Kinesis-sink upgrade aws-sdk version (apache#2058)

  Show description for 89c7b65
  rdhabalia

  authored
  89c7b65

Commits on Jun 26, 2018

• Bump Pulsar version to 2.2.0-incubating (apache#2027)

  Show description for 8b2929b
  sijie

  authored
  8b2929b

Commits on Jun 22, 2018

• Remove pulsar-common dependency from pulsar-io-core module and cleanup pulsar-common dependency references (apache#2020)

  Show description for 7c3a324
  sijie

  authored
  7c3a324

Commits on Jun 18, 2018

• Add documentation and flexible aws-credential plugin to support aws-role (apache#1972)

  Show description for 8ba8acd
  rdhabalia

  authored
  8ba8acd

Commits on Jun 8, 2018

• Added a bunch of concrete sources/sinks so that they are usable without having to write code (apache#1934)

  Show description for 1950538
  

  srkukarni

  authored and

  sijie

  committed
  1950538

Commits on Jun 7, 2018

• The check should be for null (apache#1932)

  srkukarni

  authored
  4beb677

• Introduce kinesis sink on function (apache#1904)

  Show description for 4b37fda
  rdhabalia

  authored
  4b37fda

Commits on Jun 3, 2018

• Simplify PushSource (apache#1898)

  Show description for 54cc1c3
  

  srkukarni

  authored and

  sijie

  committed
  54cc1c3

Commits on Jun 2, 2018

• When fetching from kafka, specify to get the earliest of messages (apache#1896)

  

  srkukarni

  authored and

  jerrypeng

  committed
  577e579

Commits on May 24, 2018

• Make the KakfaSource abstract by allowing users to implement method to extract value (apache#1842)

  

  srkukarni

  authored and

  sijie

  committed
  e249493

• Check if producer is not null before closing (apache#1839)

  

  srkukarni

  authored and

  hrsakai

  committed
  c4d1ed9

Commits on May 21, 2018

• Make the current reference sinks usable (apache#1814)

  Show description for 481f69e
  

  srkukarni

  authored and

  sijie

  committed
  481f69e

Commits on May 17, 2018

• Remove old comment (apache#1803)

  

  jerrypeng

  authored and

  merlimat

  committed
  f09eb3c

• Modifying sink interface to be generic (apache#1792)

  

  jerrypeng

  authored and

  merlimat

  committed
  5e4f2bb

Commits on May 14, 2018

• Implementing PushSource on top of Source (apache#1766)

  Show description for 0f84222
  

  jerrypeng

  authored and

  sijie

  committed
  0f84222

Commits on May 8, 2018

• Pulsar IO rename (apache#1747)

  Show description for 17f7415
  

  lucperkins

  authored and

  merlimat

  committed
  17f7415

Loading