Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
pulsar-4.0.0
Description
The java doc of `PulsarSourceBuilder` was not updated in time.
IIUC,
setDeserializationSchema(PulsarDeserializationSchema.flinkSchema(new SimpleStringSchema()))
should be replaced by
setDeserializationSchema(new SimpleStringSchema())
BTW, I also checked `pulsar.md` and luckily it was correct.
Attachments
Issue Links
- links to