Pulsar Flink Versions Save

Feature

• external-sub support consuming from earliest offset (#349)
• support sink table api delay message (#350)
• sink support delay message (#342)

Fixed

• fix the cursor of start cannot be consumed when the cursor is larger than the latest cursor. (#357)
• fix flink sql properties key style (#329)

Dependency

<dependency>
    <groupId>io.streamnative.connectors</groupId>
    <artifactId>pulsar-flink-connector_2.11</artifactId>
    <version>1.12.4.1</version>
</dependency>

or

<dependency>
    <groupId>io.streamnative.connectors</groupId>
    <artifactId>pulsar-flink-connector_2.12</artifactId>
    <version>1.12.4.1</version>
</dependency>

add option pulsar.reader.useearliestwhendataloss for source.

fix Data Loss #354