Как получить свойства KafkaProducer / KafkaConsumer на Java? - PullRequest
Новая
       40

Как получить свойства KafkaProducer / KafkaConsumer на Java?

0 голосов
/ 10 октября 2019

Я устанавливаю новый сервер весенней загрузки с kafka, и создаю KafkaProducer / KafkaConsumer с помощью конструктора со свойствами из внешнего класса, пытаюсь получить свойства (включая ключ / значения по умолчанию в kafka) в другом потоке.

Это в JDK8, подпружиненная загрузка 2.1.5.RELEASE, kafka-clients 2.0.1. 

<!-- language: java -->
//input the properties in one web page
public class InputController {
    @PostMapping(...) 
    public void create(@RequestBody String properties) {
        Properties props = convertStringToMap....
        producer.createProducer(props);
    }
}

//show the properties in anotehr web page
public class ViewController {
    @GetMapping(...)
    public Properties getProperties() {
        return producer.getProperties(properties);
    }
}

public class Producer {
    private KafkaProducer<String, String> kafkaProducer;//or kafkaConsumer

    public void createProducer(Properties props) {
        kafkaProducer = new KafkaProducer<>(props);//or KafkaConsumer
    }

    public void getProperties() {
        // how to get the properties(include the default key/values in kafka) 
        // in kafkaProducer/kafkaConsumer here?
    }
}

Я ожидаю показать свойства в веб-интерфейсе из ViewController.getProperties() как выше код.

...