pulsar-spark

pulsar-spark copied to clipboard

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

6

**Describe the bug** when write data in pulsar,,use the follow code: ```scala def main(args: Array[String]): Unit = { val sparkSession = SparkSession.builder().appName("test-pulsar").master("local").getOrCreate() val startingOffsets = topicOffsets(Map("persistent://public/default/my-topic" -> MessageId.fromByteArray(Array(8,33,16,8)))) import sparkSession.implicits._...

chlyzzo

**Describe the bug** While we're testing our integration with Pulsar Spark Connector, we found out that while shutting down `PulsarClientImpl` doesn't shutdown `EventLoopGroup` properly (which is seems to be addressed...

alexeykudinkin

[FEATURE] Expose Pulsar-Client Metrics with Prometheus

11

**Is your feature request related to a problem? Please describe.** A clear and concise description of what the problem is. Ex. I'm always frustrated when \[...] **Describe the solution you'd...

nlu90

**Is your feature request related to a problem? Please describe.** A clear and concise description of what the problem is. Ex. I'm always frustrated when \[...] **Describe the solution you'd...

nlu90

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

1

**Is your feature request related to a problem? Please describe.** A clear and concise description of what the problem is. Ex. I'm always frustrated when \[...] **Describe the solution you'd...

xiongmozhou

[BUG] Failed to create producer: Namespace is being unloaded, cannot add topic

5

**Describe the bug** A running Spark application stopped working after a microbatch execution failed (HTTP 500 error from Pulsar), after the failure, the Spark Application seems to try to reconnect...

mathieudruart

Here is the template https://streamnative.slab.com/posts/repository-release-template-prb0lvyt If you have any questions about the release doc template, please **leave your comment** on it, **do not edit it directly**.

zymap

add: parameters to control number and the distribution of messages in a micro-batch

7

If we have a considerably large backlog for one or more topics that are read by the connector, then using the current implementation we cannot really place an upper limit...

atezs82

We publish artifacts into maven central now instead of bintary. So remove the bintary related documentation.

nlu90

We already have spark structured streaming based pulsar connector. However I am unable to find any DStream based pulsar connector for Spark streaming. Is it possible today with streamnative? Is...

aditiwari01