issues
search
streamnative
/
pulsar-spark
Spark Connector to read and write with Pulsar
Apache License 2.0
113
stars
50
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
[BUG] Data loss and data duplication when the Pulsar reader experiences network connectivity issues
#181
neilramaswamy
opened
2 weeks ago
1
Upgrading Pulsar Version to 3.3.2
#180
ericm-db
closed
2 weeks ago
0
Bump commons-io:commons-io from 2.11.0 to 2.14.0
#179
dependabot[bot]
opened
1 month ago
0
[BUG] Pulsar Backlog Pileup - No Message Acknowledgements to Pulsar
#178
sbandaru
opened
1 month ago
0
[BUG] Exception in thread "main" java.lang.NoClassDefFoundError: scala/$less$colon$less
#177
vaibhavsw
opened
1 month ago
1
[BUG] Seeing some backlog pending on Pulsar UI even if Spark consumer has consumed all data.
#176
akshay-habbu
opened
7 months ago
7
[FEATURE] Bump the Spark version to 3.5
#175
yash2
opened
8 months ago
0
Update README.md
#174
violetkjs
closed
7 months ago
0
[FEATURE] Configuring Subscription mode to Shared
#173
moweonlee
opened
9 months ago
0
Close pulsar reader in both success and failure case
#172
chaoqin-li1123
closed
10 months ago
0
update scala version to 2.13
#171
nlu90
closed
11 months ago
0
[BUG] with maxBytesPerTrigger Spark job won't start because of ClassNotFoundException
#170
ronaldbuit
opened
1 year ago
0
fix typo of pollTimeMs
#169
chaoqin-li1123
closed
1 year ago
0
update README
#168
nlu90
closed
1 year ago
0
Add number of rows and bytes metrics for pulsar source
#167
chaoqin-li1123
closed
1 year ago
0
[FEATURE] Bump the scala version to 2.13
#166
yash2
closed
11 months ago
2
[FEATURE]How can we provide consumer subscriptiontype?
#165
Naveen-8451
opened
1 year ago
0
[FEATURE] Add support for `KEY_VALUE` Schema
#164
oneebhkhan
opened
1 year ago
0
Update pom.xml
#163
nlu90
closed
1 year ago
0
Propagate pulsar client factory class name from driver spark context to RDD
#162
chaoqin-li1123
closed
1 year ago
0
bump version 3.4.0.1
#161
nlu90
closed
1 year ago
0
Remove redundant get Stats call
#160
chaoqin-li1123
closed
1 year ago
0
Make the pulsar client creation factory pluggable
#159
chaoqin-li1123
closed
1 year ago
3
Adding PulsarAdmin configs to PulsarHelper
#158
ericm-db
closed
1 year ago
3
Exclude logging dependency of pulsar library
#157
chaoqin-li1123
closed
1 year ago
0
Fix data loss of initial batch and add available now trigger test
#156
chaoqin-li1123
closed
1 year ago
0
Fix the build failure caused by spark upgrade
#155
chaoqin-li1123
closed
1 year ago
2
Fix data duplicate and data loss
#154
chaoqin-li1123
closed
1 year ago
0
improve logging
#153
chaoqin-li1123
closed
1 year ago
0
Update ci timeout
#152
nlu90
closed
1 year ago
1
Adding maxBytesPerTrigger tag for Pulsar Admission Control
#151
ericm-db
closed
1 year ago
7
Implement Admission Control for the Pulsar-Spark connector
#150
ericm-db
closed
1 year ago
1
Fix the issue of getting initial offset with user provided start
#149
chaoqin-li1123
closed
1 year ago
1
Update CODEOWNERS
#148
nlu90
closed
1 year ago
0
bump version to 3.2.2.2
#147
nlu90
closed
1 year ago
0
Use sn-ci to import gpg key
#146
yaalsn
closed
1 year ago
0
Revert "Remove maven_profiles"
#145
yaalsn
closed
1 year ago
1
Remove maven_profiles
#144
yaalsn
closed
1 year ago
0
Remove GPG signing since there's no artifacts to upload.
#143
yaalsn
closed
1 year ago
0
Add test container testing framework and pulsar source and sink tests
#142
chaoqin-li1123
closed
1 year ago
0
bump version to 3.2.2.0
#141
nlu90
closed
1 year ago
0
stop shading pulsar client and commons
#140
nlu90
closed
1 year ago
0
Fix the null pointer exception when there is no active session in the current thread.
#139
chaoqin-li1123
closed
1 year ago
0
Shade common libraries in uber jar to avoid potential dependency conflicts.
#138
chaoqin-li1123
closed
1 year ago
0
close producer during cleanup
#137
nlu90
closed
1 year ago
0
[BUG] - Pulsar Producer leak
#136
david-streamlio
closed
1 year ago
0
Validity of Configurations for Source Connector and Availability of .nar File
#135
divya-inaza
opened
1 year ago
0
Upgrade dependency version
#134
Technoboy-
closed
1 year ago
0
Bump to Spark 3.4.0
#133
caseyrathbone
closed
1 year ago
1
[FEATURE] Support Spark 3.3+
#132
ikstewa
closed
1 year ago
3
Next