Pulsar Flink Versions Save

Feature:

• Support ProtobufNative Schema TableSource format (#249) format type: pulsar-protobuf-native

NOTE: Upgrading this version causes repeated consumption of the last message from the last task execution on the first startup if the old version uses subscription mode. For the reason, please refer to: #371

• fix #366: stream failure if the topic doesn't exist with Pulsar 2.8.0 (#369)
• fix: pulsar with flink debezium-json format bug. (#379)
• fix the submitted cursor does not meet the pulsar subscription expectations. (#370)

NOTE: Upgrading this version causes repeated consumption of the last message from the last task execution on the first startup if the old version uses subscription mode. For the reason, please refer to: #371

• fix #366: stream failure if the topic doesn't exist with Pulsar 2.8.0 (#369)
• fix: pulsar with flink debezium-json format bug. (#379)
• fix the submitted cursor does not meet the pulsar subscription expectations. (#370)

• feat #275: add ThreadSafeDeserializationSchema solve thread safe. (#365)
• fix lost first message. (#363)
• fixbug #237: NotSerializableException in submitting flink job. (#361)

• feat #275: add ThreadSafeDeserializationSchema solve thread safe. (#365)
• fix lost first messag.e (#363)
• fixbug #237: NotSerializableException in submitting flink job. (#361)
• Bump pulsar version to 2.8.0. (#359)

Fixed

• Fix the cursor of start cannot be consumed when the cursor is larger than the latest cursor. #357
  • Add option pulsar.reader.use-earliest-when-data-loss for source.
  • Change option failondataloss to pulsar.reader.fail-on-data-loss.
• fix subscriptionName. #330
• Fix getPositionFromSubscription npe when key_shared reader enabled. #336
• Bump pulsar version to 2.7.2 #340
• Fix reader new topic, the first message will be lost. #355

Dependency

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

or

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

• Fix reader new topic, the first message will be lost. #355

• require pulsar client 2.8.0 or higher version

Dependency

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

or

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