无法创建io.vertx.kafka.client.consumer.KafkaConsumer的实例

Question

我正在将在 2.14.3.Final 上运行的 Quarkus 应用程序更新到 3.2.10.Final。

我曾经能够像这样实例化 KafkaConsumer：

io.vertx.kafka.client.consumer.KafkaConsumer.create<String, String>(
        vertx,
        mapOf(
          ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG to kafkaServers,
          ConsumerConfig.GROUP_ID_CONFIG to "test_group",
          ConsumerConfig.AUTO_OFFSET_RESET_CONFIG to "earliest",
          ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG to false.toString(),
          AbstractKafkaSchemaSerDeConfig.AUTO_REGISTER_SCHEMAS to true.toString(),
          AbstractKafkaSchemaSerDeConfig.SCHEMA_REFLECTION_CONFIG to false.toString(),
          AbstractKafkaSchemaSerDeConfig.SCHEMA_REGISTRY_URL_CONFIG to schemaRegistryUrl,
          AbstractKafkaSchemaSerDeConfig.VALUE_SUBJECT_NAME_STRATEGY to TopicNameStrategy::class.java.canonicalName,
          ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG to StringDeserializer::class.java.canonicalName,
          ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG to KafkaAvroDeserializer::class.java.canonicalName,
          KafkaAvroDeserializerConfig.SPECIFIC_AVRO_READER_CONFIG to true.toString(),
        )
      )

但现在我收到此错误：

Cannot access class 'io.vertx.kafka.client.consumer.KafkaConsumer'. Check your module classpath for missing or conflicting dependencies

我发现例如 io.vertx.kafka.client.serialization.JsonObjectDeserializer 移至 io.quarkus.kafka.client.serialization.JsonObjectDeserializer。

KafkConsumer 转移到哪里了？

提前致谢！

Answer 1

自 3.0 版 Quarkus 起，不再提供 vertx-kafka-client 依赖项。您需要自己将其添加到您的项目中。