Pulsar Spark Versions Save

What's Changed

• close reader in all case by @chaoqin-li1123 in #172

Full Changelog: https://github.com/streamnative/pulsar-spark/compare/release-3.4.1.0...release-3.4.1.1

What's Changed

• update scala version to 2.13 by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/171

• Added message properties serialization to Pulsar write task by @jsteggink in #131
• add source metrics by @chaoqin-li1123 in #167
• update README by @nlu90 in #168
• typo fix by @chaoqin-li1123 in #169

Full Changelog: https://github.com/streamnative/pulsar-spark/compare/release-3.4.0.2...release-3.4.0.3

• Propagate pulsar client factory class name from driver spark context to RDD by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/162

Full Changelog: https://github.com/streamnative/pulsar-spark/compare/release-3.4.0.1...release-3.4.0.2

What's Changed

• ci: Enable GitHub Actions workflow by @tisonkun in https://github.com/streamnative/pulsar-spark/pull/129
• close producer during cleanup by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/137
• Shade common libraries in uber jar to avoid potential dependency conflicts. by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/138
• Fix the null pointer exception when there is no active session in the current thread. by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/139
• stop shading pulsar client and commons by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/140
• bump version to 3.2.2.0 by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/141
• Remove GPG signing since there's no artifacts to upload. by @yaalsn in https://github.com/streamnative/pulsar-spark/pull/143
• Remove maven_profiles by @yaalsn in https://github.com/streamnative/pulsar-spark/pull/144
• Revert "Remove maven_profiles" by @yaalsn in https://github.com/streamnative/pulsar-spark/pull/145
• Use sn-ci to import gpg key by @yaalsn in https://github.com/streamnative/pulsar-spark/pull/146
• bump version to 3.2.2.2 by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/147
• Update CODEOWNERS by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/148
• Update ci timeout by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/152
• Fix data duplicate and data loss by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/154
• Fix the issue of getting initial offset with user provided start by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/149
• Add test container testing framework and pulsar source and sink tests by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/142
• Bump to Spark 3.4.0 by @caseyrathbone in https://github.com/streamnative/pulsar-spark/pull/133
• Fix the build failure caused by spark upgrade by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/155
• Exclude logging dependency of pulsar library by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/157
• improve logging by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/153
• Fix data loss of initial batch and add available now trigger test by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/156
• Adding maxBytesPerTrigger tag for Pulsar Admission Control by @ericm-db in https://github.com/streamnative/pulsar-spark/pull/151
• Adding PulsarAdmin configs to PulsarHelper by @ericm-db in https://github.com/streamnative/pulsar-spark/pull/158
• Make the pulsar client creation factory pluggable by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/159
• Remove redundant get Stats call by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/160
• bump version 3.4.0.1 by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/161

New Contributors

• @tisonkun made their first contribution in https://github.com/streamnative/pulsar-spark/pull/129
• @chaoqin-li1123 made their first contribution in https://github.com/streamnative/pulsar-spark/pull/138
• @caseyrathbone made their first contribution in https://github.com/streamnative/pulsar-spark/pull/133
• @ericm-db made their first contribution in https://github.com/streamnative/pulsar-spark/pull/151

Full Changelog: https://github.com/streamnative/pulsar-spark/compare/release-3.2.0.2...release-3.4.0.1

What's Changed

• ci: Enable GitHub Actions workflow by @tisonkun in https://github.com/streamnative/pulsar-spark/pull/129
• close producer during cleanup by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/137
• Shade common libraries in uber jar to avoid potential dependency conflicts. by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/138
• Fix the null pointer exception when there is no active session in the current thread. by @chaoqin-li1123 in https://github.com/streamnative/pulsar-spark/pull/139
• stop shading pulsar client and commons by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/140
• bump version to 3.2.2.0 by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/141

New Contributors

• @tisonkun made their first contribution in https://github.com/streamnative/pulsar-spark/pull/129
• @chaoqin-li1123 made their first contribution in https://github.com/streamnative/pulsar-spark/pull/138

Full Changelog: https://github.com/streamnative/pulsar-spark/compare/release-3.2.0.2...release-3.2.2.2

What's Changed

• fix: the subscriptionPrefix parameter does not take effect by @obobj in https://github.com/streamnative/pulsar-spark/pull/101
• Update README.md by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/110
• feat: hang on non-existed topics by @amehochan in https://github.com/streamnative/pulsar-spark/pull/111
• Expose some monitor metrics by @amehochan in https://github.com/streamnative/pulsar-spark/pull/106
• [Improve] clean PulsarMetadataReader by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/116
• Reader need closed when exception by @obobj in https://github.com/streamnative/pulsar-spark/pull/115
• [Improve] replace admin calls with client or consumer calls in PulsarHelper by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/118
• [Improve] remove admin url from source related components by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/120
• [Improve] simplify sink schema check by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/121
• [Improve] remove admin parameter from sinks and admin options from config by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/122
• Revert "Expose some monitor metrics (#106)" by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/119
• clean initial offset setup by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/123
• remove continous streaming support by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/124
• Update README by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/125
• bump version to 3.2.0.2 by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/126
• [imporve] fix scalastyle issues by @nlu90 in https://github.com/streamnative/pulsar-spark/pull/127

Full Changelog: https://github.com/streamnative/pulsar-spark/compare/release-3.2.0.1...release-3.2.0.2