This is an automated email from the ASF dual-hosted git repository.
arvid pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b00d158 [FLINK-23473][runtime] Do not create transaction in
TwoPhaseCommitSinkFunction after finish (#16768)
add 5cffdbe [hotfix][connectors/kafka] Make
KafkaSinkBuilder#setDeliveryGuarantee public
add 457e39f [hotfix][connectors/kafka] Disable logging
add 0a09089 [hotfix][connectors/kafka] Warn if transaction cancellation
on startup fails
add 5c58fab [hotfix][connectors/kafka] Expose KafkaSinkContext in
KafkaRecordSerializationSchema#open
add 7e93b09 [hotfix][connectors/base] Implement DescribedEnum with
DeliveryGuarantee to use it as Table API configuration
add 1948446 [FLINK-23639][connectors/kafka] Migrate Table API Kafka
connector to use FLIP-143 KafkaSink
add c605ce4 [FLINK-23639][docs] Update Kafka SQL connector docs to
reflect new configuration
No new revisions were added by this update.
Summary of changes:
docs/content/docs/connectors/table/kafka.md | 16 ++-
.../flink/connector/base/DeliveryGuarantee.java | 42 +++++-
.../kafka/sink/KafkaRecordSerializationSchema.java | 5 +-
.../connectors/kafka/sink/KafkaSinkBuilder.java | 2 +-
.../connectors/kafka/sink/KafkaTransactionLog.java | 5 +-
.../connectors/kafka/sink/KafkaWriter.java | 21 ++-
.../kafka/table/BufferedUpsertSinkFunction.java | 2 +-
... => DynamicKafkaRecordSerializationSchema.java} | 146 +++++++++------------
.../table/DynamicKafkaSerializationSchema.java | 19 +--
.../kafka/table/KafkaConnectorOptions.java | 67 +++-------
.../kafka/table/KafkaConnectorOptionsUtil.java | 12 ++
.../connectors/kafka/table/KafkaDynamicSink.java | 145 +++++++++++++-------
.../kafka/table/KafkaDynamicTableFactory.java | 50 +++++--
.../table/UpsertKafkaDynamicTableFactory.java | 8 +-
.../kafka/table/KafkaDynamicTableFactoryTest.java | 126 ++++++++++++++----
.../table/UpsertKafkaDynamicTableFactoryTest.java | 31 +++--
.../src/test/resources/log4j2-test.properties | 2 +-
17 files changed, 440 insertions(+), 259 deletions(-)
copy
flink-connectors/flink-connector-kafka/src/main/java/org/apache/flink/streaming/connectors/kafka/table/{DynamicKafkaSerializationSchema.java
=> DynamicKafkaRecordSerializationSchema.java} (64%)
