Hi Jary,
Flink removed Kafka 0.10 & 0.11 connector since 1.12, because Kafka supports
bidirectional compatibility since version 0.10, which means you can use a newer
version client to communicate with your old version broker (e.g. Kafka client
2.4.1 & Kafka broker 0.11) [1]. You can try to swit
Hi, everyone
I'm using Flink 1.14 to consume Kafka data, which version is 0.11. And
there are some errors while running.
Caused by: java.lang.NoSuchMethodError:
org.apache.kafka.clients.consumer.KafkaConsumer.poll(Ljava/time/Duration;)Lorg/apache/kafka/clients/consumer/ConsumerRecords;
at
org.apa
