We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 4de4199 commit 5a467d1Copy full SHA for 5a467d1
src/main/java/io/streamnative/flink/java/dynamic/DynamicDeserializationSchema.java
@@ -21,8 +21,7 @@
21
import static org.apache.flink.connector.pulsar.common.config.PulsarClientFactory.createClient;
22
23
/**
24
- * Query the schema by schema version. This should only be applied to a topic with
25
- * {@code Schema.AUTO_PRODUCE(Schema.AVRO(Class))} producer.
+ * Query the schema by schema version. This should only be applied to a topic with {@code Schema.AVRO} producer.
26
*/
27
public class DynamicDeserializationSchema implements PulsarDeserializationSchema<LoadCreatedEvent> {
28
private static final long serialVersionUID = 3320218454364912622L;
0 commit comments