This is an automated email from the ASF dual-hosted git repository.
ayegorov pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
from 07acdbc8541 [fix][sec] Fix transitive critical CVEs in file-system
tiered storage (#19957)
add 55523ac8f31 [improve][io] KCA: flag to force optional primitive
schemas (#19951)
No new revisions were added by this update.
Summary of changes:
.../pulsar/io/kafka/connect/KafkaConnectSink.java | 16 ++-
.../connect/PulsarKafkaConnectSinkConfig.java | 6 +
.../connect/schema/PulsarSchemaToKafkaSchema.java | 55 +++++++-
.../io/kafka/connect/KafkaConnectSinkTest.java | 41 ++++--
.../connect/PulsarSchemaToKafkaSchemaTest.java | 149 +++++++++++++++------
5 files changed, 203 insertions(+), 64 deletions(-)