我正在編寫 java api 來創建 kafka 消費者我有一個錯誤：Exception in thread "main" java.lang.NoSuchMethodError: org.apache.kafka.clients.consumer.Consumer.subscribe(Ljava/util/Collection;)Vat in.co.hadooptutorials.data.generator.cdr.kafkaconsumer.main(kafkaconsumer.java:38)下面是我的代碼：public class kafkaconsumer {  public static void main(String[] args) throws IOException {    String TOPIC_NAME = "test";    Properties props = new Properties();    props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG,"localhost:9092");    props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.IntegerDeserializer");    props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, "org.apache.kafka.common.serialization.StringDeserializer");    props.put(ConsumerConfig.GROUP_ID_CONFIG, "test" );    props.put("enable.auto.commit", "false");    props.put("auto.commit.interval.ms", "1000");    props.put("session.timeout.ms", "30000");    props.put("partition.assignment.strategy", "range");    Consumer<String, String> consumer = new KafkaConsumer<>.(props);    consumer.subscribe(Collections.singletonList("test"));    ConsumerRecords<String, String> records = consumer.poll(100);    System.out.println(consumer);    System.out.println(records);    consumer.close();  } }pem file:<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">  <modelVersion>4.0.0</modelVersion>  <groupId>in.co.hadooptutorials</groupId>  <artifactId>cdr-data-generator</artifactId>  <version>0.0.1-SNAPSHOT</version>  <packaging>jar</packaging>  <name>cdr-data-generator</name>  <url>http://maven.apache.org</url>我正在添加我的 pem 文件的代碼 pem 文件的完整代碼還添加了 kafka clients-2.2.0 的 jar 它是一個 cdr 數據項目，使用 kafka 將數據存儲到 cassandra 如何解決這個問題？我正在嘗試仍然收到錯誤。