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 1dac395 [FLINK-24741][connectors/filesystem] Deprecate
FileRecordFormat and update the javadoc appropriately.
add b367407 [FLINK-24765][kafka] Bump Kafka version to 2.8
add 4da7bde [FLINK-24765][kafka] Mark tests which are unstable in the IDE
add e61ff88 [FLINK-24765][tests] Use DockerImageVersions to reference
Kafka docker image
No new revisions were added by this update.
Summary of changes:
flink-connectors/flink-connector-kafka/pom.xml | 11 ++++++++++-
.../kafka/sink/FlinkKafkaInternalProducer.java | 7 -------
.../connectors/kafka/FlinkKafkaProducer.java | 5 ++---
.../internals/FlinkKafkaInternalProducer.java | 23 ++++++++--------------
.../metrics/KafkaMetricMutableWrapper.java | 2 +-
.../internals/metrics/KafkaMetricWrapper.java | 2 +-
.../connector/kafka/source/KafkaSourceITCase.java | 6 ++++--
.../source/enumerator/KafkaEnumeratorTest.java | 3 ++-
.../connectors/kafka/FlinkKafkaProducerITCase.java | 8 +++++++-
.../connectors/kafka/KafkaConsumerTestBase.java | 8 +++++---
.../connectors/kafka/KafkaTestEnvironmentImpl.java | 10 +---------
.../src/main/resources/META-INF/NOTICE | 2 +-
.../flink-end-to-end-tests-common-kafka/pom.xml | 2 +-
.../flink/tests/util/kafka/KafkaSourceE2ECase.java | 4 ++--
.../src/main/resources/META-INF/NOTICE | 2 +-
.../org/apache/flink/util/DockerImageVersions.java | 2 +-
16 files changed, 47 insertions(+), 50 deletions(-)
