streamnative/pulsar-io-cloud-storage

Issues

• [FEATURE] Add datetime string substitutions to prefix field

  #942 opened 9 months ago by asher-goldberg
  0

• [BUG] NPE when schema not exist with useHumanReadableSchemaVersion enabled

  #842 opened a year ago by RobertIndie
  0

• [FEATURE] add configuration for including the original topic in the metadata when withMetadata is set to true

  #816 opened a year ago by nlu90
  0

• [BUG] `subscriptionPosition` or `subsPosition` doesn't work when provided in yaml config file.

  #813 opened a year ago by nlu90
  1

• Update master to JDK17

  #592 opened a year ago by alpreu
  1

• [BUG] The connector covert array json bytes failed.

  #623 opened 2 years ago by shibd
  0

• [BUG] NPE if partitionerType is not set

  #607 opened 2 years ago by nicoloboschi
  0

• [BUG] `maxTimeoutMs` should apply at the topic level

  #494 opened 2 years ago by alpreu
  0

• [BUG] Files generated per topic have fluctuating size instead of `batchSize`

  #493 opened 2 years ago by alpreu
  0

• [BUG] Sink flushes only when batchTimeMs is exceeded for large batchSize

  #491 opened 2 years ago by alpreu
  0

• [BUG] formatType not working as expected

  #488 opened 2 years ago by raviMoengage
  1

• [Doc]--cloud storage sink connector doc

  #20 opened 2 years ago by Huanli-Meng
  1

• [BUG] PR template should correctly add doc labels based on description

  #472 opened 2 years ago by alpreu
  0

• [FEATURE] Azure Blob Storage support

  #467 opened 2 years ago by alpreu
  0

• [BUG] no docs about `pathPrefix`

  #154 opened 2 years ago by freeznet
  0

• [FEATURE] Pending Queuesize default to the maxbatch size

  #446 opened 2 years ago by nlu90
  0

• [BUG] Verify the connector can interact with gcs and azure blob store correctly

  #45 opened 2 years ago by nlu90
  3

• [FEATURE] Add a new batch triggering mechanism that is based on the batch size

  #445 opened 2 years ago by nlu90
  0

• [BUG] Time Partitioner not working as expected for GCS

  #381 opened 3 years ago by shaileshjha061
  1

• [BUG] error while writing data in Parquet format using JsonSchema as schema format

  #439 opened 2 years ago by grandimk
  3

• [BUG] Connector does not create output files for each topic when reading multiple topics

  #458 opened 2 years ago by alpreu
  0

• [BUG] Java heap space error when trying to run pulsar sink

  #14 opened 2 years ago by clairexxxx
  7

• [BUG] failed to extract schema version for AVRO format and causing cast error

  #432 opened 2 years ago by freeznet
  0

• [BUG] extract schema info from messages without schema version

  #367 opened 2 years ago by freeznet
  0

• [BUG] Upgrade hadoop common to 3.3.3 to solve CVE-2022-26612

  #356 opened 3 years ago by nicoloboschi
  0

• Pulsar GCS Sink Connector not able to write as parquet when pulsar function sends data to output topic in some user defined pojo format

  #220 opened 3 years ago by mdsadimnadeem
  1

• [BUG] Pulsar cloud storage connector can't convert PROTO_NATIVE schema to Parquet schema

  #268 opened 3 years ago by sijie
  3

• [FEATURE] should write schema version in a human-readable format

  #256 opened 3 years ago by freeznet
  2

• [FEATURE] support aws native SDK

  #227 opened 3 years ago by freeznet
  0

• [BUG] Messages are ignored with "Message not exist in record" exception

  #7 opened 3 years ago by artem-garmash
  5

• GCS Sink Connector not able to write as parquet when published data using golang client for pulsar.. works fine with java client

  #196 opened 3 years ago by mdsadimnadeem
  2

• [BUG] raw format type should make the separator configurable

  #147 opened 3 years ago by freeznet
  0

• Partition for cloud io connector

  #17 opened 3 years ago by codelipenghui
  1

• [BUG] Impossible to select the partition type

  #19 opened 3 years ago by Damien137
  2

• Bump pulsar 2.9 for the master branch

  #120 opened 3 years ago by codelipenghui
  0

• topic name as a group of topic partitions in s3 path

  #29 opened 4 years ago by LVHermosa
  0

• addition of "message ID" , "properties" and "schema_version"

  #31 opened 4 years ago by LVHermosa
  0

• Release Cloud IO connector in streamnative-ci

  #13 opened 4 years ago by timmyyuan
  1

• [FEATURE] Handle raw data with the connector (topics without schema)

  #18 opened 4 years ago by Damien137
  3

• [BUG] batching does not batch

  #12 opened 4 years ago by yuvalgut
  1