[
https://issues.apache.org/jira/browse/FLINK-31048?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Weijie Guo updated FLINK-31048:
-------------------------------
Affects Version/s: pulsar-4.0.0
> Java doc of PulsarSourceBuilder was not updated in time
> -------------------------------------------------------
>
> Key: FLINK-31048
> URL: https://issues.apache.org/jira/browse/FLINK-31048
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: pulsar-4.0.0
> Reporter: Weijie Guo
> Assignee: Weijie Guo
> Priority: Major
>
> The java doc of `PulsarSourceBuilder` was not updated in time.
> IIUC,
> {code:java}
> setDeserializationSchema(PulsarDeserializationSchema.flinkSchema(new
> SimpleStringSchema())) {code}
> should be replaced by
> {code:java}
> setDeserializationSchema(new SimpleStringSchema()) {code}
> BTW, I also checked `pulsar.md` and luckily it was correct.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
