使用自定义构造方法创建Kafka客户端实例时找不到符号

编译错误信息 #

[ERROR] Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.6.1:compile (default-compile) on project businessServer: Compilation failure
[ERROR] /C:/Users/cheny/Desktop/NewsRecommender-Main/backend/businessServer/src/main/java/com/tqz/business/utils/Configure.java:[25,44] cannot find symbol
[ERROR]   symbol:   constructor Kafka(java.lang.String,java.lang.Integer)
[ERROR]   location: class kafka.Kafka
[ERROR] 
[ERROR] -> [Help 1]

相关代码片段 #

@Bean(name = "Kafka")
public Kafka getKafkaClient() {
    return new Kafka(PropertiesFileUtils.KAFKA_HOST, PropertiesFileUtils.KAFKA_PORT);
}

使用环境 #

• Java 8
• Maven 3.5

pom.xml依赖配置 #

<dependencies>
    <!--  other dependencies -->
    <dependency>
        <groupId>org.apache.kafka</groupId>
        <artifactId>kafka_2.12</artifactId>
        <version>1.1.1</version>
    </dependency>
    <!--  other dependencies -->
</dependencies>

已尝试但无效的方案 #

• 确认Kafka依赖已正确添加到Maven项目
• 清理并重新构建项目
• 验证构造方法参数的类型和顺序与Kafka类定义匹配

解决方案 #

1. 问题根源 #

你引用的kafka.Kafka是Kafka服务端的内部类，没有接收String（主机）和Integer（端口）的构造方法，而且这个类根本不是用来创建客户端实例的。正确的Kafka客户端应该使用org.apache.kafka.clients.producer.KafkaProducer（生产者）或org.apache.kafka.clients.consumer.KafkaConsumer（消费者），它们通过Properties配置参数来初始化。

2. 修正依赖（推荐） #

当前依赖的kafka_2.12是Kafka服务端的完整包，客户端开发建议使用更轻量的kafka-clients专用依赖：

<dependency>
    <groupId>org.apache.kafka</groupId>
    <artifactId>kafka-clients</artifactId>
    <version>1.1.1</version>
</dependency>

如果项目允许，建议升级到兼容Java 8的稳定版本（比如2.8.2），获得更好的兼容性和Bug修复。

3. 替换为正确的客户端Bean #

根据你的业务需求选择生产者或消费者Bean：

生产者Bean示例

import org.apache.kafka.clients.producer.KafkaProducer;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.common.serialization.StringSerializer;
import org.springframework.context.annotation.Bean;
import java.util.Properties;

@Bean(name = "kafkaProducer")
public KafkaProducer<String, String> getKafkaProducer() {
    Properties props = new Properties();
    // 配置Kafka地址，拼接主机和端口
    props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, 
              PropertiesFileUtils.KAFKA_HOST + ":" + PropertiesFileUtils.KAFKA_PORT);
    // 配置序列化器
    props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
    props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
    
    return new KafkaProducer<>(props);
}

消费者Bean示例

import org.apache.kafka.clients.consumer.KafkaConsumer;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.springframework.context.annotation.Bean;
import java.util.Properties;

@Bean(name = "kafkaConsumer")
public KafkaConsumer<String, String> getKafkaConsumer() {
    Properties props = new Properties();
    // 配置Kafka地址
    props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, 
              PropertiesFileUtils.KAFKA_HOST + ":" + PropertiesFileUtils.KAFKA_PORT);
    // 配置消费者组ID（必填）
    props.put(ConsumerConfig.GROUP_ID_CONFIG, "news-recommender-group");
    // 配置反序列化器
    props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
    props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
    
    return new KafkaConsumer<>(props);
}

4. 注意事项 #

• 确保导入的是org.apache.kafka.clients.producer或org.apache.kafka.clients.consumer下的类，而非kafka.Kafka。
• 消费者必须配置GROUP_ID_CONFIG，否则无法初始化。

内容的提问来源于stack exchange，提问作者yue chen