pulsar-flink

pulsar-flink copied to clipboard

[QUESTION] Disable flink schema upload operation

2

We are running a flink sink on topic that it does not have any pulsar schema. Basically we are publishing just json strings. If we dont add service account as...

nikolasten

[DOC] Catalog config and DDL properties in README doc is out of date

1

**Describe the bug** Catalog config and DDL properties in README doc is out of date, which usually make users confused **To Reproduce** Steps to reproduce the behavior: 1. Go to...

asagjj

[BUG] Set pulsar event time when it exceed zero.

1

**Describe the bug** A clear and concise description of what the bug is. `DynamicPulsarSerializationSchema.java` wrongly add even time when it was zero. ```java if (eventTime != null && eventTime >=...

syhily

Created by auto-release

streamnativebot

Due to the CVE: https://nvd.nist.gov/vuln/detail/CVE-2021-22569 Reference the fix in Apache Pulsar: https://github.com/apache/pulsar/pull/13695 Note: I also tried to update the protobuf plugin (com.github.os72:protoc-jar-maven-plugin), but there's no newer release other than 3.11.4...

nlu90

Avro schema is not supported in current pulsar-sink

imaffe

 producedDataType set twice, we can delete one line of it

imaffe

fix issue: #498

mmaxiaolei

**Describe the bug** Currently, the names and formats of the key values to be passed in the properties parameter to the FlinkPulsarSource and FlinkPulsarSink are unclear and undocumented. For example,...

lonerzzz

1. pulsar + debezium-json format 2. this update operation will produce two RowData, UPDATE_BEFORE and UPDATE_AFTER 3. but pulsar connector only return UPDATE_AFTER

haormj