This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.
from cdec22e [FLINK-22927][python] Fix the bug of JobStatus
add 5bafade [FLINK-21229][avro-confluent-registry] Add Confluent schema
registry SSL support
add a21baa4 [FLINK-21229][docs] Update avro-confluent docs
No new revisions were added by this update.
Summary of changes:
.../dev/table/connectors/formats/avro-confluent.md | 98 +++++++++++---
.../table/connectors/formats/avro-confluent.zh.md | 98 +++++++++++---
docs/dev/table/connectors/formats/debezium.md | 98 +++++++++++---
docs/dev/table/connectors/formats/debezium.zh.md | 98 +++++++++++---
.../confluent/CachedSchemaCoderProvider.java | 21 ++-
...ConfluentRegistryAvroDeserializationSchema.java | 110 ++++++++++++++--
.../ConfluentRegistryAvroSerializationSchema.java | 65 +++++++--
.../confluent/RegistryAvroFormatFactory.java | 77 ++++++++++-
.../registry/confluent/RegistryAvroOptions.java | 62 ++++++++-
.../confluent/CachedSchemaCoderProviderTest.java | 145 +++++++++++++++++++++
.../confluent/RegistryAvroFormatFactoryTest.java | 92 +++++++++++++
.../src/test/resources/test-keystore.jks | Bin 0 -> 2327 bytes
12 files changed, 845 insertions(+), 119 deletions(-)
create mode 100644
flink-formats/flink-avro-confluent-registry/src/test/java/org/apache/flink/formats/avro/registry/confluent/CachedSchemaCoderProviderTest.java
create mode 100644
flink-formats/flink-avro-confluent-registry/src/test/resources/test-keystore.jks
