org.apache.kafka.common.config.ConfigException: Fehlt die erforderliche Konfiguration “bootstrap.Server", die hat keinen Standardwert

Bin ich immer diese Fehlermeldung beim ausführen von meinem Produzenten Klasse in Eclipse:
org.apache.kafka.common.config.ConfigException: Fehlt die erforderliche Konfiguration "bootstrap.Server", die hat keinen Standardwert

Hier ist mein producer-Klasse:

public class SimpleProducer {

  public static void main(String[] args) throws Exception {

    try {
        String topicName = "mytopic";
        String key = "key1";
        String value = "Value-1";

        Properties prop = new Properties();
        prop.put("bootstrap.server","localhost:9092");
        prop.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
        prop.put("value.serializer","org.apache.kafka.cpmmon.serialization.StringSerializer");

        Producer<String, String> producer = new KafkaProducer<>(prop);

        ProducerRecord<String, String> record = new ProducerRecord<>(topicName,key,value);
        producer.send(record);
        producer.close();
        System.out.println("SimpleProducer Completed.");
    }
    catch(Exception e) {
      e.printStackTrace();
    }
  }
}

Irgendwelche Hinweise, wie es zu lösen ist?

  • Sie falsch die Eigenschaft key "bootstrap.servers". Um diesen Fehler zu vermeiden in der Zukunft, verwenden Sie die Konstante ProducerConfig.BOOTSTRAP_SERVERS_CONFIG statt.
  • Warum tun Sie nie, nie, niemals, akzeptieren Sie alle Antworten auf Ihre Fragen, OP?
InformationsquelleAutor Amritesh Kumar | 2017-06-05
  1. 8

    Ändern Sie einfach die

    prop.put("bootstrap.server","localhost:9092");

    zu

    prop.put("bootstrap.servers","localhost:9092");

    In seinem code

    prop.put("value.serializer","prop.put("value.serializer","org.apache.kafka.cpmmon.serialization.StringSerializer");

    den common ist nicht richtig,das richtige Paket ist org.apache.kafka.common.serialization.StringSerializer

    InformationsquelleAutor dabaicai
  2. 1

    Verwenden Sie die folgende ein, und vermeiden Sie die Verwendung von hardcoded Werte

    Für

    prop.put("bootstrap.server","localhost:9092");
prop.put("key.serializer","org.apache.kafka.common.serialization.StringSerializer");
prop.put("value.serializer","org.apache.kafka.cpmmon.serialization.StringSerializer");

    Verwenden

    prop.put(ProducerConfig.BOOTSTRAP_SERVERS_CONFIG, bootstrapServer);
prop.put(ProducerConfig.KEY_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());
prop.put(ProducerConfig.VALUE_SERIALIZER_CLASS_CONFIG, StringSerializer.class.getName());

    ProducerConfig in org.apache.kafka.Kunden.Produzent Paket

    InformationsquelleAutor Nauman Shah
Schreibe einen Kommentar