This repository was archived by the owner on Dec 14, 2022. It is now read-only.
[BUG] Set pulsar event time when it exceed zero. #537
Description
Describe the bug
A clear and concise description of what the bug is. DynamicPulsarSerializationSchema.java wrongly add even time when it was zero.
if (eventTime != null && eventTime >= 0) {This is not allowed in Pulsar's TypedMessageBuilderImpl.java.
checkArgument(timestamp > 0, "Invalid timestamp : '%s'", timestamp);