streamnative/pulsar-spark

Issues

• [BUG] Data loss and data duplication when the Pulsar reader experiences network connectivity issues

  #181 opened 2 months ago by neilramaswamy
  1

• [BUG] Pulsar Backlog Pileup - No Message Acknowledgements to Pulsar

  #178 opened 3 months ago by sbandaru
  0

• [BUG] Seeing some backlog pending on Pulsar UI even if Spark consumer has consumed all data.

  #176 opened 9 months ago by akshay-habbu
  7

• [BUG] Exception in thread "main" java.lang.NoClassDefFoundError: scala/$less$colon$less

  #177 opened 3 months ago by vaibhavsw
  1

• [FEATURE] Bump the Spark version to 3.5

  #175 opened 9 months ago by yash2
  0

• [FEATURE] Configuring Subscription mode to Shared

  #173 opened a year ago by moweonlee
  0

• [FEATURE] Bump the scala version to 2.13

  #166 opened a year ago by yash2
  2

• [BUG] with maxBytesPerTrigger Spark job won't start because of ClassNotFoundException

  #170 opened a year ago by ronaldbuit
  0

• [FEATURE] Support Spark 3.3+

  #132 opened a year ago by ikstewa
  3

• [FEATURE]How can we provide consumer subscriptiontype?

  #165 opened a year ago by Naveen-8451
  0

• [FEATURE] Add support for `KEY_VALUE` Schema

  #164 opened a year ago by oneebhkhan
  0

• Implement Admission Control for the Pulsar-Spark connector

  #150 opened a year ago by ericm-db
  1

• [FEATURE] maxTriggerDelay feature in Pulsar-Spark Connector

  #117 opened 2 years ago by keenborder786
  6

• [FEATURE] support pyspark

  #74 opened a year ago by caibirdme
  1

• [BUG] - Pulsar Producer leak

  #136 opened a year ago by david-streamlio
  0

• [BUG] Spark StreamNative Driver should not require Admin URL

  #113 opened 2 years ago by vikram-narayan
  7

• Validity of Configurations for Source Connector and Availability of .nar File

  #135 opened 2 years ago by divya-inaza
  0

• [FEATURE] Do Scala Style via CI workflow by GitHub Actions

  #128 opened 2 years ago by nlu90
  1

• [FEATURE] Expose Pulsar-Client Metrics with Prometheus

  #79 opened 3 years ago by nlu90
  11

• [FEATURE] Add SimpleTableProvider support to PulsarProvider

  #102 opened 2 years ago by syhily
  1

• [Bug] Same named durable subscription created when using custom subscription name via readerconfig

  #112 opened 2 years ago by grssam
  1

• [BUG] Durable subscription created, and not able to delete the subscription on the partitioned topic

  #108 opened 2 years ago by yangou
  4

• [BUG] Incorrect subscription name used by PulsarProvider when reader subscription name is provided already

  #107 opened 2 years ago by grssam
  6

• [BUG] Failed to get the subscription indicator information related to Spark's consumption of Pulsar

  #104 opened 2 years ago by yebai1105
  2

• [FEATURE] Allow configure the connector to wait indefinitely if topic not exists

  #86 opened 2 years ago by nlu90
  0

• [BUG] Error: Writing to a topic which have incompatible schema - even with same Schema Type Pulsar.STRING

  #114 opened 2 years ago by JTBS
  2

• Pulsar-spark connector for Spark Streaming.

  #75 opened 2 years ago by aditiwari01
  2

• [FEATURE] Provides configuration instructions for pulsar subscriptions

  #103 opened 2 years ago by yebai1105
  2

• [BUG] A persistent random subscription is created each time consumption is started

  #105 opened 2 years ago by yebai1105
  1

• [BUG] Mismatch type - logicaltype

  #68 opened 2 years ago by mnit016
  2

• [BUG] Incorrect string deserialization in pulsar-spark_2.11-2.4.5

  #40 opened 2 years ago by szimon
  1

• [BUG] unnecessary subscription created when processing batches

  #44 opened 2 years ago by hanguyen6
  1

• [BUG] 500 Internal Server Error (Failed to get schema information) when trying to connect to the pulsar cluster

  #46 opened 2 years ago by codelipenghui
  4

• add auth token ,error: illegal cyclic reference involving object InterfaceAudience

  #51 opened 2 years ago by mdz-doit
  1

• [FEATURE] Can I have one topic for each subscription name

  #85 opened 2 years ago by xiongmozhou
  2

• [BUG] The requirements of pulsar-spark with token release

  #53 opened 2 years ago by mdz-doit
  2

• [BUG] Current Pulsar Client is not shutting down `EventLoopGroup` properly

  #87 opened 2 years ago by alexeykudinkin
  1

• [BUG] The subscriptionPrefix parameter does not take effect

  #100 opened 2 years ago by obobj
  0

• [FEATURE] Bump spark to 3.2.0 with custom monitor metrics support.

  #90 opened 2 years ago by syhily
  0

• [BUG] Spark can't start read stream- NullPointerException in pulsar-spark-connector V3.1.1.2

  #70 opened 2 years ago by AshiSaraswat
  2

• [BUG] Using the connector produces a scala.reflect.internal.Symbols$CyclicReference exception

  #92 opened 2 years ago by honderdzevenduuzend
  1

• [BUG]write data into pulsar, Literal must have a corresponding value to string, but class String found

  #60 opened 2 years ago by chlyzzo
  14

• Need a newer pulsar-spark version with pulsar-cient version 2.9+

  #91 opened 2 years ago by grssam
  2

• [FEATURE] Add endingtime feature

  #96 opened 2 years ago by obobj
  0

• Need a newer pulsar-spark version with pulsar-cient version 2.9+

  #88 opened 2 years ago by grssam
  4

• [FEATURE] upgrade Spark DataSource V2 APIs for unify streaming and batch

  #43 opened 2 years ago by jiazhai
  3

• [FEATURE] Upgrade Pulsar client lib version to 2.9.2

  #81 opened 3 years ago by nlu90
  0

• [FEATURE] Allow configure predefined subscription for metadata reader

  #80 opened 3 years ago by nlu90
  0

• [Release] The requirements of pulsar-spark release

  #52 opened 3 years ago by timmyyuan
  2

• [FEATURE] Support set authentication configurations to connect to a Pulsar cluster

  #45 opened 3 years ago by codelipenghui
  3