This is an automated email from the ASF dual-hosted git repository.
tzulitai pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-kafka.git
from d6525c14 [FLINK-31208][Connectors/Kafka] KafkaSourceReader overrides
meaninglessly a method(pauseOrResumeSplits)
add 818d1fde [FLINK-33017] Remove dependency on shaded guava
No new revisions were added by this update.
Summary of changes:
.../flink/tests/util/kafka/SmokeKafkaITCase.java | 5 +--
.../flink/connector/kafka/sink/KafkaWriter.java | 31 +++++++--------
.../connectors/kafka/FlinkKafkaProducer.java | 13 +++---
.../internals/FlinkKafkaInternalProducer.java | 8 ++--
.../sink/FlinkKafkaInternalProducerITCase.java | 5 +--
.../KafkaRecordSerializationSchemaBuilderTest.java | 17 ++++----
.../connector/kafka/sink/KafkaSinkITCase.java | 9 +++--
.../connector/kafka/sink/KafkaWriterITCase.java | 7 ++--
.../kafka/sink/TransactionToAbortCheckerTest.java | 46 ++++++++++++++--------
.../KafkaRecordDeserializationSchemaTest.java | 6 +--
.../kafka/FlinkKafkaInternalProducerITCase.java | 7 ++--
.../connectors/kafka/KafkaConsumerTestBase.java | 13 ++++--
.../kafka/shuffle/KafkaShuffleITCase.java | 26 ++++++------
.../kafka/table/KafkaDynamicTableFactoryTest.java | 4 +-
pom.xml | 6 ---
15 files changed, 105 insertions(+), 98 deletions(-)
