如何将 KAFKA 的属性外部化为不同的类并将其调用到主类? [英] How do I externalize the properties of KAFKA into a different class and call it to the main class?

问题描述

我一直在尝试使用抽象 OOP 来外部化属性代码，这样我就可以将它调用到生产者类，但我似乎无法调用它.这是代码，任何帮助将不胜感激.

I've been trying to use abstraction OOP in order to externalize the properties code, so that I could just call it to the producer class but I can't seem to call it. Here's the code, any help would be appreciated.

public class Producer{

    private static final Logger logger = LogManager.getLogger(Producer.class);
    public static void main(String[] args) {
        logger.info("Creating Kafka Producer...");

        KafkaProducer<Integer, String> producer = new KafkaProducer<>(PropConfigs().prodProps());

        logger.info("Start sending messages...");

        for (int i = 1; i <= AppConfigs.numEvents; i++) {
            producer.send(new ProducerRecord<>(AppConfigs.topicName, i, "Message " + i + " Test"), new Callback() {
                @Override
                public void onCompletion(RecordMetadata recordMetadata, Exception e) {
                    if(e == null){
                        logger.info("
Received metadata" + " Topic:" + recordMetadata.topic() + " Partition: " + recordMetadata.partition() + " Offset: " + recordMetadata.offset() + " Time: " + recordMetadata.timestamp() + "
");
                    } else {
                        logger.error("Error", e);
                    }
                }
            });
        }

        logger.info("Finished - Closing Kafka Producer.");
        producer.flush();
        producer.close();

    }
}

我想将所有 props.setProperty 转移到不同的类，然后将其调用到生产者类.这就是我想做的:

I would like to transfer all of the props.setProperty to a different class then call it to the producer class. This is what I would like to do:

package org.timothy.producer.common;

import org.apache.kafka.clients.producer.ProducerConfig;
import org.apache.kafka.common.serialization.IntegerSerializer;
import org.apache.kafka.common.serialization.StringSerializer;

import java.util.Properties;

public class PropConfigs {

    public static Properties prodProps(){
        Properties props = new Properties();
        props.setProperty(ProducerConfig.CLIENT_ID_CONFIG, AppConfigs.applicationID);
        props.setProperty(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, AppConfigs.bootstrapServers);
        props.setProperty(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, IntegerSerializer.class.getName());
        props.setProperty(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
        props.setProperty(ProducerConfig.ACKS_CONFIG, "all");
        props.setProperty(ProducerConfig.RETRIES_CONFIG, "3");
        props.setProperty(ProducerConfig.MAX_IN_FLIGHT_REQUESTS_PER_CONNECTION, "5");

        return new Properties(props);
    }

}

如何将其调用到主类?或者也许将其应用于:Properties props = new Properties();KafkaProducer<整数，字符串>生产者 = 新的 KafkaProducer<>(props);

How can I call this to the main class? Or maybe apply it to: Properties props = new Properties(); KafkaProducer<Integer, String> producer = new KafkaProducer<>(props);

推荐答案

 KafkaProducer<Integer, String> producer = new KafkaProducer<>((new PropConfigs()).prodProps()); 

或者将它们设为静态...

Or make them static...

 KafkaProducer<Integer, String> producer = new KafkaProducer<>(PropConfigs.prodProps()); 

https:///github.com/apache/kafka/blob/trunk/examples/src/main/java/kafka/examples/Producer.java

这篇关于如何将 KAFKA 的属性外部化为不同的类并将其调用到主类?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！