We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Since there is a continious demand for it, just an overview for current state of Support for Apache Pulsar:
when looking into beams i/o connector matrix pulsar is not listed yet: https://beam.apache.org/documentation/io/connectors/
but there is a sdk package Package org.apache.beam.sdk.io.pulsar https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/pulsar/package-summary.html
in v2.39 of beam a relatively basic pulsar io was introduced: Implemented Apache PulsarIO https://beam.apache.org/blog/beam-2.39.0/ for details see: https://issues.apache.org/jira/browse/BEAM-8218
there are some open issues in beam for pulsar: https://github.com/apache/beam/issues?q=is%3Aissue+pulsar+is%3Aopen
there were also some non merged pull request marked as stale and automatically closed, which may be worth to have a look on https://github.com/apache/beam/pulls?q=is%3Apr+pulsar+is%3Aclosed+label%3Astale
in general it would be a good longterm target, to reach the same quality of integration in Beam as there is for Kafka
The text was updated successfully, but these errors were encountered:
regarding the beginning of pulsar integration from https://www.youtube.com/watch?v=L_Pm2yKgA6g
Sorry, something went wrong.
No branches or pull requests
Since there is a continious demand for it,
just an overview for current state of Support for Apache Pulsar:
when looking into beams i/o connector matrix pulsar is not listed yet:
https://beam.apache.org/documentation/io/connectors/
but there is a sdk package
Package org.apache.beam.sdk.io.pulsar
https://beam.apache.org/releases/javadoc/current/org/apache/beam/sdk/io/pulsar/package-summary.html
in v2.39 of beam a relatively basic pulsar io was introduced:
Implemented Apache PulsarIO https://beam.apache.org/blog/beam-2.39.0/
for details see:
https://issues.apache.org/jira/browse/BEAM-8218
there are some open issues in beam for pulsar:
https://github.com/apache/beam/issues?q=is%3Aissue+pulsar+is%3Aopen
there were also some non merged pull request marked as stale and automatically closed, which may be worth to have a look on
https://github.com/apache/beam/pulls?q=is%3Apr+pulsar+is%3Aclosed+label%3Astale
in general it would be a good longterm target, to reach the same quality of integration in Beam as there is for Kafka
The text was updated successfully, but these errors were encountered: