[Issue 11007] Schema.NATIVE_AVRO: add a version of AUTO_PRODUCE_BYTES that doesn't validate the message in `encode` #11238

Zhen-hao · 2021-07-06T15:44:28Z

(If this PR fixes a github issue, please add Fixes #<xyz>.)

Motivation

When ingesting event/message data from external systems such as Kafka and Cassandra, the events very often are already serialized with Avro with the schemas also available. In such cases, a Pulsar producer doesn't need to perform the validation step again when sending the events to a topic.

Modifications

Introduce a new class AutoProduceValidatedAvroBytesSchema that ~~extends AutoProduceBytesSchema~~ implements Schema<byte[]>.

~~TODO: make the public AutoProduceValidatedAvroBytesSchema(org.apache.avro.Schema schema) constructor accessible to the client.~~

Add NATIVE_AVRO method to org.apache.pulsar.client.api.Schema which calls AutoProduceValidatedAvroBytesSchema's constructor via reflection.

Verifying this change

Make sure that the change passes the CI checks.

(Please pick either of the following options)

This change is a trivial rework / code cleanup without any test coverage.

(or)

This change is already covered by existing tests, such as (please describe tests).

(or)

This change added tests and can be verified as follows:

(example:)

Added integration tests for end-to-end deployment with large payloads (10MB)
Extended integration test for recovery after broker failure

Does this pull request potentially affect one of the following parts:

If yes was chosen, please highlight the changes

Dependencies (does it add or upgrade a dependency): (yes / no)
The public API: (yes / no)
The schema: (yes / no / don't know)
The default values of configurations: (yes / no)
The wire protocol: (yes / no)
The rest endpoints: (yes / no)
The admin cli options: (yes / no)
Anything that affects deployment: (yes / no / don't know)

Documentation

Does this pull request introduce a new feature? (yes / no)
If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented)
If a feature is not applicable for documentation, explain why?
If a feature is not documented yet in this PR, please create a followup issue for adding the documentation

eolivelli

thank you for sharing this work.
I left one comment

pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Schema.java

Anonymitaet · 2021-07-07T02:00:35Z

@Zhen-hao thanks for your contribution. For this PR, do we need to update docs?

Zhen-hao · 2021-07-07T07:03:35Z

@Zhen-hao thanks for your contribution. For this PR, do we need to update docs?

I think so. Maybe next to that of AUTO_PRODUCE_BYTES?

I need to figure out why the build is failing and where to add tests.
Any guidance is welcome!

.../src/main/java/org/apache/pulsar/client/impl/schema/AutoProduceValidatedAvroBytesSchema.java

pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Schema.java

Zhen-hao · 2021-07-08T06:54:09Z

@Anonymitaet I see site2/docs/io-develop.md, site2/website/versioned_docs/version-2.8.0/io-develop.md, and site2/website/versioned_docs/version-2.8.1/io-develop.md.
Are the latter two manually maintained?

Should I only change site2/docs/io-develop.md?

Zhen-hao · 2021-07-08T06:55:13Z

how often does the CI run? I find the feedback loop too long.

Anonymitaet · 2021-07-08T07:12:14Z

@Anonymitaet I see site2/docs/io-develop.md, site2/website/versioned_docs/version-2.8.0/io-develop.md, and site2/website/versioned_docs/version-2.8.1/io-develop.md.
Are the latter two manually maintained?

Should I only change site2/docs/io-develop.md?

They are updated manually. If the doc changes apply to several versions, we need to update them all.
But we can update one version first, after the contents get approved, then copy them to the rest versions.

Would you like to add docs accordingly? Then you can ping me to review, thanks

Zhen-hao · 2021-07-08T07:29:49Z

I don't understand why the build is failing with

Error:  Medium: Unread field: org.apache.pulsar.client.impl.schema.AutoProduceValidatedAvroBytesSchema.schema [org.apache.pulsar.client.impl.schema.AutoProduceValidatedAvroBytesSchema] At AutoProduceValidatedAvroBytesSchema.java:[line 43] URF_UNREAD_FIELD

In AutoProduceValidatedAvroBytesSchema's super class AutoProduceBytesSchema, the schema field is used in

@Override
    public SchemaInfo getSchemaInfo() {
        ensureSchemaInitialized();

        return schema.getSchemaInfo();
    }

eolivelli · 2021-07-08T08:39:23Z

I don't understand why the build is failing with

Error:  Medium: Unread field: org.apache.pulsar.client.impl.schema.AutoProduceValidatedAvroBytesSchema.schema [org.apache.pulsar.client.impl.schema.AutoProduceValidatedAvroBytesSchema] At AutoProduceValidatedAvroBytesSchema.java:[line 43] URF_UNREAD_FIELD

In AutoProduceValidatedAvroBytesSchema's super class AutoProduceBytesSchema, the schema field is used in

@Override
    public SchemaInfo getSchemaInfo() {
        ensureSchemaInitialized();

        return schema.getSchemaInfo();
    }

AutoProduceBytesSchema already has a "schema" field, and you are adding a new field that hides the inherited one

Zhen-hao · 2021-07-08T08:52:06Z

AutoProduceBytesSchema already has a "schema" field, and you are adding a new field that hides the inherited one

OK. I think the easiest to do is copy the same code to the new class.

Zhen-hao · 2021-07-08T08:53:42Z

OK. I think the easiest to do is copy the same code to the new class.

~~Or, only use super.schema in the new class.~~
Never mind. schema in the super class is private...

eolivelli

In my opinion we are on our way.
We have to add tests.
You can find examples like SimpleSchemaTest or SchemaTest....

@sijie is current approach following your expectations?

Tagging @codelipenghui @congbobo184 @gaoran10

.../src/main/java/org/apache/pulsar/client/impl/schema/AutoProduceValidatedAvroBytesSchema.java

Zhen-hao · 2021-07-09T07:52:44Z

In my opinion we are on our way.
We have to add tests.
You can find examples like SimpleSchemaTest or SchemaTest....

@sijie is current approach following your expectations?

Tagging @codelipenghui @congbobo184 @gaoran10

I will find time over the weekend to add the tests.

eolivelli

Very good!

I left one last comment about getNativeSchema

eolivelli · 2021-07-10T13:22:36Z

pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/NativeAvroBytesSchema.java

+
+    @Override
+    public Optional<Object> getNativeSchema() {
+        return Optional.ofNullable(schema);


Here you have to return the original org.apache.avro.Schema object.

this comment looks not addressed yet

Zhen-hao · 2021-07-14T08:53:31Z

there is one test error I can't figure out:

org.apache.pulsar.client.api.SchemaSerializationException: java.io.EOFException
        at org.apache.pulsar.client.impl.schema.reader.AvroReader.read(AvroReader.java:82)
        at org.apache.pulsar.client.api.schema.SchemaReader.read(SchemaReader.java:41)
        at org.apache.pulsar.client.api.SimpleSchemaTest.newNativeAvroProducerForMessageSchemaWithBatch(SimpleSchemaTest.java:597)
        at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
        at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
        at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.base/java.lang.reflect.Method.invoke(Method.java:566)
        at org.testng.internal.MethodInvocationHelper.invokeMethod(MethodInvocationHelper.java:132)
        at org.testng.internal.InvokeMethodRunnable.runOne(InvokeMethodRunnable.java:45)
        at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:73)
        at org.testng.internal.InvokeMethodRunnable.call(InvokeMethodRunnable.java:11)
        at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
        at java.base/java.lang.Thread.run(Thread.java:834)
Caused by: java.io.EOFException
        at org.apache.avro.io.BinaryDecoder.ensureBounds(BinaryDecoder.java:542)
        at org.apache.avro.io.BinaryDecoder.readInt(BinaryDecoder.java:173)
        at org.apache.avro.io.BinaryDecoder.readIndex(BinaryDecoder.java:493)
        at org.apache.avro.io.ResolvingDecoder.readIndex(ResolvingDecoder.java:282)
        at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:187)
        at org.apache.avro.reflect.ReflectDatumReader.readField(ReflectDatumReader.java:291)
        at org.apache.avro.generic.GenericDatumReader.readRecord(GenericDatumReader.java:247)
        at org.apache.avro.specific.SpecificDatumReader.readRecord(SpecificDatumReader.java:123)
        at org.apache.avro.generic.GenericDatumReader.readWithoutConversion(GenericDatumReader.java:179)
        at org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:160)
        at org.apache.avro.generic.GenericDatumReader.read(GenericDatumReader.java:153)
        at org.apache.pulsar.client.impl.schema.reader.AvroReader.read(AvroReader.java:80)
        ... 14 more

from this code

what am I missing here? @eolivelli

eolivelli

Did you try to use the debugger with a break point in that point ? probably you have not overridden every method in the Schema interface.

by the way I believe that your new NativeAvroBytesSchema is useful only for the Producer.
if you want to read raw bytes you simply do not set a Schema in the consumer or you use Schema.BYTES.

NativeAvroBytesSchemadoes not perform validation and it does not decode the payload, so it is not worth to be used on the Consumer side.

I suggest you to:

throw UnsupportedOperationException in all "decode" methods of NativeAvroBytesSchema
write explicitly in the Javadoc that this is a Schema to be used on the Producer side
use Schema.BYTES (or no Schema) in the Consumer in your test

eolivelli · 2021-07-14T09:00:46Z

pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/NativeAvroBytesSchema.java

+
+    @Override
+    public Optional<Object> getNativeSchema() {
+        return Optional.ofNullable(this.nativeSchema);


it cannot be null

eolivelli · 2021-07-14T09:01:09Z

pulsar-client/src/main/java/org/apache/pulsar/client/impl/schema/NativeAvroBytesSchema.java

+
+    @Override
+    public Schema<byte[]> clone() {
+        return new AutoProduceBytesSchema<>(schema.clone());


return new NativeAvroBytesSchema(nativeSchema)

Zhen-hao · 2021-07-14T11:38:13Z

Did you try to use the debugger with a break point in that point ? probably you have not overridden every method in the Schema interface.

by the way I believe that your new NativeAvroBytesSchema is useful only for the Producer.
if you want to read raw bytes you simply do not set a Schema in the consumer or you use Schema.BYTES.

NativeAvroBytesSchemadoes not perform validation and it does not decode the payload, so it is not worth to be used on the Consumer side.

I suggest you to:

throw UnsupportedOperationException in all "decode" methods of NativeAvroBytesSchema

write explicitly in the Javadoc that this is a Schema to be used on the Producer side

use Schema.BYTES (or no Schema) in the Consumer in your test

You are right. I've made the changes as you suggested.

eolivelli

LGTM

@sijie can you take another look please ?

eolivelli · 2021-07-14T12:34:40Z

@Zhen-hao I believe you can remove the "draft" flag from this PR

Zhen-hao · 2021-07-14T12:45:41Z

@Zhen-hao I believe you can remove the "draft" flag from this PR

Cool. I still need to update some documentation page before we can merge.

eolivelli · 2021-07-14T12:48:11Z

Cool. I still need to update some documentation page before we can merge.

where do you want to add docs apart from the JavaDocs ?

Zhen-hao · 2021-07-14T12:55:35Z

I see site2/docs/io-develop.md has a section Handle schema information which mentions AUTO_PRODUCE_BYTES.
I'm thinking of adding some words about NATIVE_AVRO.

maybe @Anonymitaet knows better if this is necessary.

eolivelli · 2021-07-14T12:57:19Z

it is a good idea, btw we can separate code changes from documentation changes. you can follow up with a separate PR.

Zhen-hao · 2021-07-14T13:33:57Z

it is a good idea, btw we can separate code changes from documentation changes. you can follow up with a separate PR.

If other reviewers agree, I don't mind doing that;)

sijie · 2021-07-20T03:28:05Z

@Zhen-hao looks good to me!

…te the message in `encode` (apache#11238) Fixes apache#11007 ### Motivation When ingesting event/message data from external systems such as Kafka and Cassandra, the events very often are already serialized with Avro with the schemas also available. In such cases, a Pulsar producer doesn't need to perform the validation step again when sending the events to a topic. ### Modifications Introduce a new class `AutoProduceValidatedAvroBytesSchema` that ~~extends `AutoProduceBytesSchema`~~ implements `Schema<byte[]>`. ~~TODO: make the `public AutoProduceValidatedAvroBytesSchema(org.apache.avro.Schema schema)` constructor accessible to the client.~~ Add `NATIVE_AVRO` method to `org.apache.pulsar.client.api.Schema` which calls `AutoProduceValidatedAvroBytesSchema`'s constructor via reflection.

Anonymitaet · 2021-08-04T02:14:19Z

@Zhen-hao thanks for your great work. Would you like to add docs accordingly? Then you can ping me to review, thanks

Zhen-hao · 2021-08-04T07:26:57Z

@Zhen-hao thanks for your great work. Would you like to add docs accordingly? Then you can ping me to review, thanks

That's the plan. I was overwhelmed by work. I will find time later this week or next week to make a new PR.

Anonymitaet · 2021-08-17T00:32:23Z

@Zhen-hao thanks for your great work. Would you like to add docs accordingly? Then you can ping me to review, thanks

That's the plan. I was overwhelmed by work. I will find time later this week or next week to make a new PR.

Hi @Zhen-hao any progress on the docs? Thanks

Zhen-hao · 2021-08-18T19:38:35Z

@Anonymitaet unfortunately, I haven't got to it yet. but it is on my list...

Anonymitaet · 2021-08-19T00:40:09Z

@Zhen-hao thanks for your feedback. Please do not forget to add docs to let users know the changes.

…te the message in `encode` (apache#11238) Fixes apache#11007 ### Motivation When ingesting event/message data from external systems such as Kafka and Cassandra, the events very often are already serialized with Avro with the schemas also available. In such cases, a Pulsar producer doesn't need to perform the validation step again when sending the events to a topic. ### Modifications Introduce a new class `AutoProduceValidatedAvroBytesSchema` that ~~extends `AutoProduceBytesSchema`~~ implements `Schema<byte[]>`. ~~TODO: make the `public AutoProduceValidatedAvroBytesSchema(org.apache.avro.Schema schema)` constructor accessible to the client.~~ Add `NATIVE_AVRO` method to `org.apache.pulsar.client.api.Schema` which calls `AutoProduceValidatedAvroBytesSchema`'s constructor via reflection. (cherry picked from commit a78b029)

…te the message in `encode` (apache#11238) Fixes apache#11007 When ingesting event/message data from external systems such as Kafka and Cassandra, the events very often are already serialized with Avro with the schemas also available. In such cases, a Pulsar producer doesn't need to perform the validation step again when sending the events to a topic. Introduce a new class `AutoProduceValidatedAvroBytesSchema` that ~~extends `AutoProduceBytesSchema`~~ implements `Schema<byte[]>`. ~~TODO: make the `public AutoProduceValidatedAvroBytesSchema(org.apache.avro.Schema schema)` constructor accessible to the client.~~ Add `NATIVE_AVRO` method to `org.apache.pulsar.client.api.Schema` which calls `AutoProduceValidatedAvroBytesSchema`'s constructor via reflection. (cherry picked from commit a78b029)

…te the message in `encode` (apache#11238) Fixes apache#11007 ### Motivation When ingesting event/message data from external systems such as Kafka and Cassandra, the events very often are already serialized with Avro with the schemas also available. In such cases, a Pulsar producer doesn't need to perform the validation step again when sending the events to a topic. ### Modifications Introduce a new class `AutoProduceValidatedAvroBytesSchema` that ~~extends `AutoProduceBytesSchema`~~ implements `Schema<byte[]>`. ~~TODO: make the `public AutoProduceValidatedAvroBytesSchema(org.apache.avro.Schema schema)` constructor accessible to the client.~~ Add `NATIVE_AVRO` method to `org.apache.pulsar.client.api.Schema` which calls `AutoProduceValidatedAvroBytesSchema`'s constructor via reflection. (cherry picked from commit a78b029) (cherry picked from commit f4ef4f3)

…te the message in `encode` (apache#11238) Fixes apache#11007 ### Motivation When ingesting event/message data from external systems such as Kafka and Cassandra, the events very often are already serialized with Avro with the schemas also available. In such cases, a Pulsar producer doesn't need to perform the validation step again when sending the events to a topic. ### Modifications Introduce a new class `AutoProduceValidatedAvroBytesSchema` that ~~extends `AutoProduceBytesSchema`~~ implements `Schema<byte[]>`. ~~TODO: make the `public AutoProduceValidatedAvroBytesSchema(org.apache.avro.Schema schema)` constructor accessible to the client.~~ Add `NATIVE_AVRO` method to `org.apache.pulsar.client.api.Schema` which calls `AutoProduceValidatedAvroBytesSchema`'s constructor via reflection.

Zhen-hao added 2 commits July 6, 2021 17:37

add class AutoProduceValidatedAvroBytesSchema

544c228

add AUTO_PRODUCE_VALIDATED_AVRO_BYTES client API

c16bb2f

Zhen-hao changed the title ~~Issue 11007~~ [Issue 11007] add a version of AUTO_PRODUCE_BYTES that doesn't validate message in encode Jul 6, 2021

Zhen-hao changed the title ~~[Issue 11007] add a version of AUTO_PRODUCE_BYTES that doesn't validate message in encode~~ [Issue 11007] add a version of AUTO_PRODUCE_BYTES that doesn't validate the message in encode Jul 6, 2021

eolivelli requested changes Jul 6, 2021

View reviewed changes

pulsar-client-api/src/main/java/org/apache/pulsar/client/api/Schema.java Outdated Show resolved Hide resolved

fix constructor bug

1a0192c

eolivelli requested changes Jul 7, 2021

View reviewed changes

Zhen-hao added 2 commits July 7, 2021 19:13

address code review comments from eolivelli

9e741fe

update AutoProduceValidatedAvroBytesSchema comment

4e8a70b

Anonymitaet added the doc-required Your PR changes impact docs and you will update later. label Jul 8, 2021

Anonymitaet added this to the 2.9.0 milestone Jul 8, 2021

remove the inheritance

3860e94

Zhen-hao mentioned this pull request Jul 8, 2021

add a producer that sends already serialized Avro message with the schema CleverCloud/pulsar4s#328

Closed

update comment for NATIVE_AVRO

bc8d05e

eolivelli reviewed Jul 8, 2021

View reviewed changes

sijie reviewed Jul 8, 2021

View reviewed changes

.../src/main/java/org/apache/pulsar/client/impl/schema/AutoProduceValidatedAvroBytesSchema.java Outdated Show resolved Hide resolved

Zhen-hao added 2 commits July 10, 2021 11:45

rename class

0962a9e

update SimpleSchemaTest for native avro

3da471d

eolivelli requested changes Jul 10, 2021

View reviewed changes

add more tests

8091151

return native schema from NativeAvroBytesSchema

6dfdc51

eolivelli requested changes Jul 14, 2021

View reviewed changes

disable decode in NativeAvroBytesSchema

fccabfd

eolivelli approved these changes Jul 14, 2021

View reviewed changes

Zhen-hao marked this pull request as ready for review July 14, 2021 12:44

Zhen-hao requested a review from sijie July 16, 2021 06:41

sijie approved these changes Jul 20, 2021

View reviewed changes

sijie merged commit a78b029 into apache:master Jul 22, 2021

Zhen-hao mentioned this pull request Aug 26, 2021

[docs] add documentation for Schema.NATIVE_AVRO #11801

Merged

eolivelli changed the title ~~[Issue 11007] add a version of AUTO_PRODUCE_BYTES that doesn't validate the message in encode~~ [Issue 11007] Schema.NATIVE_AVRO: add a version of AUTO_PRODUCE_BYTES that doesn't validate the message in encode Sep 23, 2021

Anonymitaet removed the doc-required Your PR changes impact docs and you will update later. label Oct 14, 2021

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

[Issue 11007] Schema.NATIVE_AVRO: add a version of AUTO_PRODUCE_BYTES that doesn't validate the message in `encode` #11238

[Issue 11007] Schema.NATIVE_AVRO: add a version of AUTO_PRODUCE_BYTES that doesn't validate the message in `encode` #11238

Zhen-hao commented Jul 6, 2021 •

edited

Loading

eolivelli left a comment

Anonymitaet commented Jul 7, 2021

Zhen-hao commented Jul 7, 2021

Zhen-hao commented Jul 8, 2021

Zhen-hao commented Jul 8, 2021

Anonymitaet commented Jul 8, 2021

Zhen-hao commented Jul 8, 2021

eolivelli commented Jul 8, 2021

Zhen-hao commented Jul 8, 2021

Zhen-hao commented Jul 8, 2021 •

edited

Loading

eolivelli left a comment

Zhen-hao commented Jul 9, 2021

eolivelli left a comment

eolivelli Jul 10, 2021

eolivelli Jul 14, 2021

Zhen-hao commented Jul 14, 2021

eolivelli left a comment

eolivelli Jul 14, 2021

eolivelli Jul 14, 2021

Zhen-hao commented Jul 14, 2021

eolivelli left a comment

eolivelli commented Jul 14, 2021

Zhen-hao commented Jul 14, 2021

eolivelli commented Jul 14, 2021

Zhen-hao commented Jul 14, 2021

eolivelli commented Jul 14, 2021

Zhen-hao commented Jul 14, 2021 •

edited

Loading

sijie commented Jul 20, 2021

Anonymitaet commented Aug 4, 2021

Zhen-hao commented Aug 4, 2021

Anonymitaet commented Aug 17, 2021

Zhen-hao commented Aug 18, 2021

Anonymitaet commented Aug 19, 2021

[Issue 11007] Schema.NATIVE_AVRO: add a version of AUTO_PRODUCE_BYTES that doesn't validate the message in encode #11238

[Issue 11007] Schema.NATIVE_AVRO: add a version of AUTO_PRODUCE_BYTES that doesn't validate the message in encode #11238

Conversation

Zhen-hao commented Jul 6, 2021 • edited Loading

Motivation

Modifications

Verifying this change

Does this pull request potentially affect one of the following parts:

Documentation

eolivelli left a comment

Choose a reason for hiding this comment

Anonymitaet commented Jul 7, 2021

Zhen-hao commented Jul 7, 2021

Zhen-hao commented Jul 8, 2021

Zhen-hao commented Jul 8, 2021

Anonymitaet commented Jul 8, 2021

Zhen-hao commented Jul 8, 2021

eolivelli commented Jul 8, 2021

Zhen-hao commented Jul 8, 2021

Zhen-hao commented Jul 8, 2021 • edited Loading

eolivelli left a comment

Choose a reason for hiding this comment

Zhen-hao commented Jul 9, 2021

eolivelli left a comment

Choose a reason for hiding this comment

eolivelli Jul 10, 2021

Choose a reason for hiding this comment

eolivelli Jul 14, 2021

Choose a reason for hiding this comment

Zhen-hao commented Jul 14, 2021

eolivelli left a comment

Choose a reason for hiding this comment

eolivelli Jul 14, 2021

Choose a reason for hiding this comment

eolivelli Jul 14, 2021

Choose a reason for hiding this comment

Zhen-hao commented Jul 14, 2021

eolivelli left a comment

Choose a reason for hiding this comment

eolivelli commented Jul 14, 2021

Zhen-hao commented Jul 14, 2021

eolivelli commented Jul 14, 2021

Zhen-hao commented Jul 14, 2021

eolivelli commented Jul 14, 2021

Zhen-hao commented Jul 14, 2021 • edited Loading

sijie commented Jul 20, 2021

Anonymitaet commented Aug 4, 2021

Zhen-hao commented Aug 4, 2021

Anonymitaet commented Aug 17, 2021

Zhen-hao commented Aug 18, 2021

Anonymitaet commented Aug 19, 2021

[Issue 11007] Schema.NATIVE_AVRO: add a version of AUTO_PRODUCE_BYTES that doesn't validate the message in `encode` #11238

[Issue 11007] Schema.NATIVE_AVRO: add a version of AUTO_PRODUCE_BYTES that doesn't validate the message in `encode` #11238

Zhen-hao commented Jul 6, 2021 •

edited

Loading

Zhen-hao commented Jul 8, 2021 •

edited

Loading

Zhen-hao commented Jul 14, 2021 •

edited

Loading