[FLINK-34192] Update flink-connector-kafka to be compatible with updated SinkV2 interfaces

• Type: Technical Debt
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: kafka-3.2.0
• Component/s: Connectors / Kafka
• Labels: pull-request-available
• Assignee: jiabao.sun
• Reporter: Martijn Visser
• Created: 22/Jan/24 08:14
• Updated: 13/Feb/24 08:45
• Resolved: 13/Feb/24 08:45

Description

Error:  /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/streaming/connectors/kafka/table/KafkaTableTestUtils.java:[101,76] incompatible types: java.util.List<org.apache.flink.types.Row> cannot be converted to java.util.List<java.lang.String>
Error:  /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[136,46] cannot find symbol
Error:    symbol:   method mock(org.apache.flink.metrics.MetricGroup,org.apache.flink.metrics.groups.OperatorIOMetricGroup)
Error:    location: class org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
Error:  /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[171,46] cannot find symbol
Error:    symbol:   method mock(org.apache.flink.metrics.MetricGroup)
Error:    location: class org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
Error:  /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[204,54] cannot find symbol
Error:    symbol:   method mock(org.apache.flink.metrics.MetricGroup)
Error:    location: class org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
Error:  /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[233,54] cannot find symbol
Error:    symbol:   method mock(org.apache.flink.metrics.MetricGroup)
Error:    location: class org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
Error:  /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[263,54] cannot find symbol
Error:    symbol:   method mock(org.apache.flink.metrics.MetricGroup)
Error:    location: class org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
Error:  /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[294,54] cannot find symbol
Error:    symbol:   method mock(org.apache.flink.metrics.MetricGroup)
Error:    location: class org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
Error:  /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[337,54] cannot find symbol
Error:    symbol:   method mock(org.apache.flink.metrics.MetricGroup)
Error:    location: class org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
Error:  /home/runner/work/flink-connector-kafka/flink-connector-kafka/flink-connector-kafka/src/test/java/org/apache/flink/connector/kafka/sink/KafkaWriterITCase.java:[525,46] cannot find symbol
Error:    symbol:   method mock(org.apache.flink.metrics.MetricGroup)
Error:    location: class org.apache.flink.runtime.metrics.groups.InternalSinkWriterMetricGroup
Error:  -> [Help 1]

https://github.com/apache/flink-connector-kafka/actions/runs/7597711401/job/20692858078#step:14:221

Issue Links

• relates to: FLINK-34337 Sink.InitContextWrapper should implement metadataConsumer method
• links to: GitHub Pull Request #84
• links to: GitHub Pull Request #86