Release 1.12.4.6 for Flink 1.12

release-1.12.4.6

Release project, change project version to: 1.12.4.6

Release 1.12.4.5 for Flink 1.12

release-1.12.4.5

Release project, change project version to: 1.12.4.5

Release 1.12.4.4 for Flink 1.12

Feature:

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

Release 1.13.1.2 for Flink 1.13

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)

Release 1.12.4.3 for Flink 1.12

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)

Release 1.13.1.1 for Flink 1.13

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

Release 1.12.4.2 for Flink 1.12

• 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)

Release 1.11.1.4 for Flink 1.11

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>

Hotfix-2.4.28.7

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

Release 1.13.1.0 for flink 1.13.1

• 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>