Pulsar Flink Connector

[John Morrow <jo...@hotmail.com>]

Hi Pulsar Users,

I'm trying to get pulsar & flink working together. I read on the pulsar blog about version 2.5.0 of the pulsar-flink connector being released:

https://streamnative.io/blog/release/2020-09-17-pulsar-flink-connector-250

...but when I look on https://dl.bintray.com/streamnative/maven/io/streamnative/connectors/pulsar-flink-connector_2.12/ the latest version I see is 2.4.28.1 and I don't see RecordSchemaType in that jar which is mentioned in the README.md and referenced in https://github.com/streamnative/pulsar-flink/pull/116/files


A few questions:

  *   Is there a 2.5.x version of the pulsar-flink-connector somewhere else I should be using?
  *   Are there a new equivalent of the old pulsar-flink examples at https://github.com/apache/pulsar/tree/master/pulsar-flink using the new connector?
  *   If I want to send a string to a FlinkPulsarSink, do I need to create a POJO with a string field, or is it possible to do something like this with String.class? - trying this gives me an error in FlinkPulsarSinkBase.uploadSchema() -> FlinkPulsarSink.getPulsarSchema() -> return Schema.AVRO(java.lang.String)

                stream.addSink(new FlinkPulsarSink<>(
                                brokerServiceUrl,
                                adminServiceUrl,
                                Optional.of(outputTopic),
                                new Properties(),
                                TopicKeyExtractor.NULL,
                                String.class
                ));



Thanks,
John