Zhanpeng Wu
Zhanpeng Wu
**Describe the bug** The class and schema is not match for byte array in `PulsarPrimitiveSchema`. https://github.com/apache/pulsar/blob/0bc45b54f29c5ffa1918e49aa4a341f70679162a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/BytesSchema.java#L50-L53 The return type of method `decode` is `byte[]`, but the class name in `PulsarPrimitiveSchema`...
Fixes #491
## Motivations When I tried to create `FlinkPulsarSource` in the following way, ```java props.setProperty(PulsarOptions.AUTH_PLUGIN_CLASSNAME_KEY, "org.apache.pulsar.client.impl.auth.AuthenticationToken"); props.setProperty(PulsarOptions.AUTH_PARAMS_KEY, "token:abcdefghijklmn"); FlinkPulsarSource(adminUrl, clientConf, pulsarDeserializationSchema, props); ``` I found my flink job was failed and...
Descriptions of the changes in this PR: ### Motivation In our practice, when the throughput becomes larger, the trigger frequency of compaction will also increase, so that the scanning of...
BP-49 design proposal markdown document. Master issue: https://github.com/apache/bookkeeper/issues/3085