如何将 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("\nReceived metadata" + " Topic:" + recordMetadata.topic() + " Partition: " + recordMetadata.partition() + " Offset: " + recordMetadata.offset() + " Time: " + recordMetadata.timestamp() + "\n");
} 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屋!