kafka配置类怎么写

Kafka配置类可以使用Java的Properties类或者Kafka提供的配置类来实现。以下是使用Kafka提供的配置类实现的示例：

import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.common.serialization.StringDeserializer;
import org.apache.kafka.common.serialization.StringSerializer;
import java.util.Properties;

public class KafkaConfig {

    public static Properties getProducerConfig() {
        Properties props = new Properties();
        props.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        props.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        props.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        return props;
    }

    public static Properties getConsumerConfig() {
        Properties props = new Properties();
        props.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "localhost:9092");
        props.put(ConsumerConfig.GROUP_ID_CONFIG, "test-group");
        props.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
        props.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class.getName());
        return props;
    }
}

在上面的代码中，我们定义了一个KafkaConfig类，其中包含了getProducerConfig()和getConsumerConfig()两个静态方法，分别用于获取生产者和消费者的配置信息。在这里，我们使用了Kafka提供的配置类ProducerConfig和ConsumerConfig，通过设置不同的属性来配置生产者和消费者。例如，我们使用BOOTSTRAP_SERVERS_CONFIG属性来指定Kafka集群的地址，使用KEY_SERIALIZER_CLASS_CONFIG和VALUE_SERIALIZER_CLASS_CONFIG属性来指定键和值的序列化方式等。通过使用配置类来配置Kafka，我们可以方便地进行统一的配置管理和维护。